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

Sep 14, 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 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

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

+ 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

Jan 27, 2017

Changes in this version

+ type ElasticSearchClient struct

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

+ func NewElasticSearchClientFromConfig() (*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()

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

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

Sep 15, 2016

Changes in this version

type ElasticSearchStorage

+ func (c *ElasticSearchStorage) Start()

+ func (c *ElasticSearchStorage) Stop()

Apr 26, 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) Close()

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

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