elasticsearch

Dec 3, 2018

Changes in this version

+ type Storage struct

+ func (c *Storage) SearchFlows(fsq filters.SearchQuery) (*flow.FlowSet, error)

+ func (c *Storage) SearchMetrics(fsq filters.SearchQuery, metricFilter *filters.Filter) (map[string][]common.Metric, error)

+ func (c *Storage) SearchRawPackets(fsq filters.SearchQuery, packetFilter *filters.Filter) (map[string]*flow.RawPackets, error)

+ func (c *Storage) Start()

+ func (c *Storage) Stop()

+ func (c *Storage) StoreFlows(flows []*flow.Flow) error

Aug 1, 2017

Changes in this version

type ElasticSearchStorage

+ func (c *ElasticSearchStorage) SearchRawPackets(fsq filters.SearchQuery, packetFilter *filters.Filter) (map[string]*flow.RawPackets, error)

Jan 27, 2017

Changes in this version

+ type ElasticSearchStorage struct

+ func New() (*ElasticSearchStorage, error)

+ func (c *ElasticSearchStorage) SearchFlows(fsq flow.FlowSearchQuery) (*flow.FlowSet, error)

+ func (c *ElasticSearchStorage) SearchMetrics(fsq flow.FlowSearchQuery, metricFilter *flow.Filter) (map[string][]*flow.FlowMetric, error)

+ func (c *ElasticSearchStorage) Start()

+ func (c *ElasticSearchStorage) Stop()

+ func (c *ElasticSearchStorage) StoreFlows(flows []*flow.Flow) error