storage

Documentation

Index

• type Filters
  • func NewFilters() *Filters
• type RangeFilter
• type Storage
• type TermFilter
• type TermFilterOp

Types

type Filters

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

func NewFilters

func NewFilters() *Filters

type RangeFilter

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

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

type TermFilter

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

type TermFilterOp

type TermFilterOp int

const (
	OR TermFilterOp = iota
	AND
)