elasticsearch

Documentation

Index

• type ElasticSearchStorage
  • func New(backend string) (*ElasticSearchStorage, error)
  • func (c *ElasticSearchStorage) SearchFlows(fsq filters.SearchQuery) (*flow.FlowSet, error)
  • func (c *ElasticSearchStorage) SearchMetrics(fsq filters.SearchQuery, metricFilter *filters.Filter) (map[string][]common.Metric, error)
  • func (c *ElasticSearchStorage) SearchRawPackets(fsq filters.SearchQuery, packetFilter *filters.Filter) (map[string]*flow.RawPackets, error)
  • func (c *ElasticSearchStorage) Start()
  • func (c *ElasticSearchStorage) Stop()
  • func (c *ElasticSearchStorage) StoreFlows(flows []*flow.Flow) error

Types

type ElasticSearchStorage

type ElasticSearchStorage struct {
	// contains filtered or unexported fields
}

ElasticSearchStorage describes an ElasticSearch flow backend

func New

func New(backend string) (*ElasticSearchStorage, error)

New creates a new ElasticSearch database client

func (*ElasticSearchStorage) SearchFlows

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

SearchFlows search flow matching filters in the database

func (*ElasticSearchStorage) SearchMetrics

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

SearchMetrics searches flow metrics matching filters in the database

func (*ElasticSearchStorage) SearchRawPackets

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

SearchRawPackets searches flow raw packets matching filters in the database

func (*ElasticSearchStorage) Start

func (c *ElasticSearchStorage) Start()

Start the Database client

func (*ElasticSearchStorage) Stop

func (c *ElasticSearchStorage) Stop()

Stop the Database client

func (*ElasticSearchStorage) StoreFlows

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

StoreFlows push a set of flows in the database