elasticsearch

package

v0.5.0 Latest Latest Go to latest Published: Sep 15, 2016 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

View Source

var ErrBadConfig = errors.New("elasticsearch : Config file is misconfigured, check elasticsearch key format")

This section is empty.

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

func New() (*ElasticSearchStorage, error)

func (c *ElasticSearchStorage) SearchFlows(filter *flow.Filter) ([]*flow.Flow, error)

func (c *ElasticSearchStorage) Start()

func (c *ElasticSearchStorage) Stop()

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