storage

type Filters struct {
	Term  TermFilter
	Range map[string]interface{}
}

type RangeFilter struct {
	Gt  interface{} `json:"gt,omitempty"`
	Lt  interface{} `json:"lt,omitempty"`
	Gte interface{} `json:"gte,omitempty"`
	Lte interface{} `json:"lte,omitempty"`
}

type Storage interface {
	Start()
	StoreFlows(flows []*flow.Flow) error
	SearchFlows(filters *Filters) ([]*flow.Flow, error)
	Stop()
}

type TermFilter struct {
	Op    TermFilterOp
	Terms map[string]interface{}
}

type TermFilterOp int