Documentation ¶
Index ¶
- Variables
- type ElasticSearchClient
- 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()
- type ElasticSearchStorage
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrBadConfig = errors.New("elasticsearch : Config file is misconfigured, check elasticsearch key format")
Functions ¶
This section is empty.
Types ¶
type ElasticSearchClient ¶ added in v0.6.0
type ElasticSearchClient struct {
// contains filtered or unexported fields
}
func NewElasticSearchClient ¶ added in v0.6.0
func (*ElasticSearchClient) Delete ¶ added in v0.6.0
func (c *ElasticSearchClient) Delete(obj string, id string) (elastigo.BaseResponse, error)
func (*ElasticSearchClient) Get ¶ added in v0.6.0
func (c *ElasticSearchClient) Get(obj string, id string) (elastigo.BaseResponse, error)
func (*ElasticSearchClient) Index ¶ added in v0.6.0
func (c *ElasticSearchClient) Index(obj string, id string, data interface{}) error
func (*ElasticSearchClient) IndexChild ¶ added in v0.6.0
func (c *ElasticSearchClient) IndexChild(obj string, parent string, id string, data interface{}) error
func (*ElasticSearchClient) Search ¶ added in v0.6.0
func (c *ElasticSearchClient) Search(obj string, query string) (elastigo.SearchResult, error)
func (*ElasticSearchClient) Start ¶ added in v0.6.0
func (c *ElasticSearchClient) Start(mappings []map[string][]byte)
func (*ElasticSearchClient) Started ¶ added in v0.6.0
func (c *ElasticSearchClient) Started() bool
func (*ElasticSearchClient) Stop ¶ added in v0.6.0
func (c *ElasticSearchClient) Stop()
type ElasticSearchStorage ¶
type ElasticSearchStorage struct {
// contains filtered or unexported fields
}
func New ¶
func New() (*ElasticSearchStorage, error)
func (*ElasticSearchStorage) SearchFlows ¶
func (*ElasticSearchStorage) Start ¶ added in v0.4.0
func (c *ElasticSearchStorage) Start()
func (*ElasticSearchStorage) Stop ¶ added in v0.4.0
func (c *ElasticSearchStorage) Stop()
func (*ElasticSearchStorage) StoreFlows ¶
func (c *ElasticSearchStorage) StoreFlows(flows []*flow.Flow) error
Click to show internal directories.
Click to hide internal directories.