Documentation
¶
Index ¶
- type ElasticSearchStorage
- func (c *ElasticSearchStorage) SearchFlows(fsq filters.SearchQuery) (*flow.FlowSet, error)
- func (c *ElasticSearchStorage) SearchMetrics(fsq filters.SearchQuery, metricFilter *filters.Filter) (map[string][]*common.TimedMetric, error)
- func (c *ElasticSearchStorage) Start()
- func (c *ElasticSearchStorage) Stop()
- func (c *ElasticSearchStorage) StoreFlows(flows []*flow.Flow) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 filters.SearchQuery) (*flow.FlowSet, error)
func (*ElasticSearchStorage) SearchMetrics ¶
func (c *ElasticSearchStorage) SearchMetrics(fsq filters.SearchQuery, metricFilter *filters.Filter) (map[string][]*common.TimedMetric, 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
Source Files
¶
- elasticsearch.go
Click to show internal directories.
Click to hide internal directories.