elasticsearch

Documentation

Index

• type Storage
  • func New(cfg es.Config, etcdClient *etcd.Client) (*Storage, error)
  • 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.RawPacket, error)
  • func (c *Storage) Start()
  • func (c *Storage) Stop()
  • func (c *Storage) StoreFlows(flows []*flow.Flow) error

Types

type Storage

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

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

SearchFlows search flow matching filters in the database

func (*Storage) SearchMetrics

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

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

func (c *Storage) Start()

Start the Database client

func (*Storage) Stop

func (c *Storage) Stop()

Stop the Database client

func (*Storage) StoreFlows

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

StoreFlows push a set of flows in the database