elasticsearch

Documentation

Index

• type ElasticSearchStorage
  • func New() (*ElasticSearchStorage, error)
  • func (c *ElasticSearchStorage) SearchFlows(fsq flow.FlowSearchQuery) ([]*flow.Flow, 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

Types

type ElasticSearchStorage

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

func New

func New() (*ElasticSearchStorage, error)

func (*ElasticSearchStorage) SearchFlows

func (c *ElasticSearchStorage) SearchFlows(fsq flow.FlowSearchQuery) ([]*flow.Flow, error)

func (*ElasticSearchStorage) SearchMetrics

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

func (*ElasticSearchStorage) Start

func (c *ElasticSearchStorage) Start()

func (*ElasticSearchStorage) Stop

func (c *ElasticSearchStorage) Stop()

func (*ElasticSearchStorage) StoreFlows

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