hub: add basic filter-by-time support

1 files changed, 15 insertions, 0 deletions

diff --git a/src/hub/src/spreadspace.org/sfive/s5cvt.go b/src/hub/src/spreadspace.org/sfive/s5cvt.go
index 24b458a..e908bc6 100644
--- a/src/hub/src/spreadspace.org/sfive/s5cvt.go
+++ b/src/hub/src/spreadspace.org/sfive/s5cvt.go
@@ -13,6 +13,10 @@ type StatsEncoder interface {
 	Encode(data StatisticsData) []byte
 }
 
+type FilterDecoder interface {
+	Decode(jsonString []byte) (StatsFilter, error)
+}
+
 type StatefulDecoder struct {
 	sourceId SourceId
 }
@@ -21,6 +25,8 @@ type PlainDecoder struct{}
 
 type PlainEncoder struct{}
 
+type filterDecoder struct{}
+
 func NewStatefulDecoder(jsonString []byte) (decoder StatsDecoder, err error) {
 	res := new(StatefulDecoder)
 	err = json.Unmarshal(jsonString, &res.sourceId)
@@ -38,6 +44,10 @@ func NewPlainDecoder() (decoder StatsDecoder) {
 	return new(PlainDecoder)
 }
 
+func NewFilterDecoder() (decoder FilterDecoder) {
+	return new(filterDecoder)
+}
+
 func (self *StatefulDecoder) Decode(jsonString []byte) (dat StatisticsData, err error) {
 	dat.CopyFrom(&self.sourceId)
 	err = json.Unmarshal(jsonString, &dat)
@@ -58,3 +68,8 @@ func (self *PlainEncoder) Encode(data *StatisticsData) []byte {
 	}
 	return res
 }
+
+func (self *filterDecoder) Decode(jsonString []byte) (dat StatsFilter, err error) {
+	err = json.Unmarshal(jsonString, &dat)
+	return
+}