elasticsearch

package
v0.28.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 17, 2021 License: Apache-2.0 Imports: 13 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Storage added in v0.21.0

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

Storage describes an ElasticSearch flow backend

func New

func New(cfg es.Config, etcdClient *etcd.Client) (*Storage, error)

New creates a new ElasticSearch database client

func (*Storage) SearchFlows added in v0.21.0

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

SearchFlows search flow matching filters in the database

func (*Storage) SearchMetrics added in v0.21.0

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

SearchMetrics searches flow metrics matching filters in the database

func (*Storage) SearchRawPackets added in v0.21.0

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

SearchRawPackets searches flow raw packets matching filters in the database

func (*Storage) Start added in v0.21.0

func (c *Storage) Start()

Start the Database client

func (*Storage) Stop added in v0.21.0

func (c *Storage) Stop()

Stop the Database client

func (*Storage) StoreFlows added in v0.21.0

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

StoreFlows push a set of flows in the database

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL