elasticsearch

Mar 21, 2019

Changes in this version

type Client

+ func (c *Client) AddEventListener(listener storage.EventListener)

+ func (c *Client) UpdateByScript(typ string, query elastic.Query, script *elastic.Script, indices ...string) error

type ClientInterface

+ AddEventListener func(listener storage.EventListener)

+ UpdateByScript func(typ string, query elastic.Query, script *elastic.Script, indices ...string) error

Aug 8, 2018

Changes in this version

+ var ErrIndexTypeNotFound = errors.New("Index type not found in the indices map")

+ var RollingRate = time.Minute

+ func FormatFilter(filter *filters.Filter, mapKey string) elastic.Query

+ func SetRollingRate(rate time.Duration)

+ type Client struct

+ func NewClient(indices []Index, cfg Config, etcdClient *etcd.Client) (*Client, error)

+ func (c *Client) BulkDelete(index Index, id string) error

+ func (c *Client) BulkIndex(index Index, id string, data interface{}) error

+ func (c *Client) Delete(index Index, id string) (*elastic.DeleteResponse, error)

+ func (c *Client) Get(index Index, id string) (*elastic.GetResult, error)

+ func (c *Client) GetClient() *elastic.Client

+ func (c *Client) Index(index Index, id string, data interface{}) error

+ func (c *Client) RollIndex()

+ func (c *Client) Search(typ string, query elastic.Query, opts filters.SearchQuery, indices ...string) (*elastic.SearchResult, error)

+ func (c *Client) Start()

+ func (c *Client) Started() bool

+ func (c *Client) Stop()

+ type ClientInterface interface

+ BulkDelete func(index Index, id string) error

+ BulkIndex func(index Index, id string, data interface{}) error

+ Delete func(index Index, id string) (*elastic.DeleteResponse, error)

+ Get func(index Index, id string) (*elastic.GetResult, error)

+ Index func(index Index, id string, data interface{}) error

+ Search func(typ string, query elastic.Query, pagination filters.SearchQuery, ...) (*elastic.SearchResult, error)

+ Start func()

+ type Index struct

+ Mapping string

+ Name string

+ RollIndex bool

+ Type string

+ URL string

+ func (i *Index) Alias() string

+ func (i *Index) FullName() string

+ func (i *Index) IndexWildcard() string

Jun 21, 2018

Changes in this version

+ type Config struct

+ AgeLimit int

+ BulkMaxDelay int

+ BulkMaxDocs int

+ ElasticHost string

+ EntriesLimit int

+ IndicesLimit int

+ MaxConns int

+ RetrySeconds int

+ func NewConfig(name ...string) Config

+ type ElasticIndex struct

type ElasticSearchClient

+ func (c *ElasticSearchClient) GetClient() *elastic.Client

+ func (c *ElasticSearchClient) GetIndexAlias() string

+ func (c *ElasticSearchClient) GetIndexAllAlias() string

+ func (c *ElasticSearchClient) IndexPath() string

+ func (c *ElasticSearchClient) RollIndex() error

+ func (c *ElasticSearchClient) ShouldRollIndex() bool

type ElasticSearchClientInterface

+ GetIndexAlias func() string

+ GetIndexAllAlias func() string

+ RollIndex func() error

+ type Mappings []map[string][]byte

Aug 1, 2017

Changes in this version

+ type ElasticSearchClientInterface interface

+ BulkDelete func(obj string, id string)

+ BulkIndex func(obj string, id string, data interface{}) error

+ BulkIndexChild func(obj string, parent string, id string, data interface{}) error

+ BulkUpdate func(obj string, id string, data interface{}) error

+ BulkUpdateWithPartialDoc func(obj string, id string, data interface{}) error

+ Delete func(obj string, id string) (elastigo.BaseResponse, error)

+ FormatFilter func(filter *filters.Filter, mapKey string) map[string]interface{}

+ Get func(obj string, id string) (elastigo.BaseResponse, error)

+ Index func(obj string, id string, data interface{}) error

+ IndexChild func(obj string, parent string, id string, data interface{}) error

+ Search func(obj string, query string) (elastigo.SearchResult, error)

+ Start func(mappings []map[string][]byte)

+ Update func(obj string, id string, data interface{}) error

+ UpdateWithPartialDoc func(obj string, id string, data interface{}) error

May 5, 2017

Changes in this version

type ElasticSearchClient

+ func (c *ElasticSearchClient) BulkDelete(obj string, id string)

+ func (c *ElasticSearchClient) BulkIndex(obj string, id string, data interface{}) error

+ func (c *ElasticSearchClient) BulkIndexChild(obj string, parent string, id string, data interface{}) error

+ func (c *ElasticSearchClient) BulkUpdate(obj string, id string, data interface{}) error

+ func (c *ElasticSearchClient) BulkUpdateWithPartialDoc(obj string, id string, data interface{}) error

Mar 31, 2017

Changes in this version

+ const AscendingOrder

+ const DescendingOrder

+ func EscapeField(f string) string

+ func UnescapeField(f string) string

type ElasticSearchClient

+ func (c *ElasticSearchClient) FormatFilter(filter *filters.Filter, prefix string, escape bool) map[string]interface{}

Dec 9, 2016

Changes in this version

type ElasticSearchClient

+ func NewElasticSearchClientFromConfig() (*ElasticSearchClient, error)

+ func (c *ElasticSearchClient) Update(obj string, id string, data interface{}) error

+ func (c *ElasticSearchClient) UpdateWithPartialDoc(obj string, id string, data interface{}) error

Oct 6, 2016

Changes in this version

+ type ElasticSearchClient struct

+ func NewElasticSearchClient(addr string, port string, maxConns int, retrySeconds int) (*ElasticSearchClient, error)

+ func (c *ElasticSearchClient) Delete(obj string, id string) (elastigo.BaseResponse, error)

+ func (c *ElasticSearchClient) Get(obj string, id string) (elastigo.BaseResponse, error)

+ func (c *ElasticSearchClient) Index(obj string, id string, data interface{}) error

+ func (c *ElasticSearchClient) IndexChild(obj string, parent string, id string, data interface{}) error

+ func (c *ElasticSearchClient) Search(obj string, query string) (elastigo.SearchResult, error)

+ func (c *ElasticSearchClient) Start(mappings []map[string][]byte)

+ func (c *ElasticSearchClient) Started() bool

+ func (c *ElasticSearchClient) Stop()

Aug 4, 2016

Changes in this version

type ElasticSearchStorage

+ func (c *ElasticSearchStorage) Start()

+ func (c *ElasticSearchStorage) Stop()

Feb 23, 2016

Changes in this version

type ElasticSearchStorage

+ func (c *ElasticSearchStorage) Close()

Feb 10, 2016

Changes in this version

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

+ type ElasticSearchStorage struct

+ func New() (*ElasticSearchStorage, error)

+ func (c *ElasticSearchStorage) SearchFlows(filters storage.Filters) ([]*flow.Flow, error)

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

+ type OldFlow struct

+ EtherDst string

+ EtherSrc string

+ ID uint64

+ IfDstGraphPath string

+ IfDstName string

+ IfDstTenantID string

+ IfDstType string

+ IfDstVNI uint64

+ IfSrcGraphPath string

+ IfSrcName string

+ IfSrcTenantID string

+ IfSrcType string

+ IfSrcVNI uint64

+ Ipv4Dst string

+ Ipv4Src string

+ LayersPath string

+ PortDst uint32

+ PortSrc uint32

+ ProbeGraphPath string

+ Timestamp uint64

+ UUID string