elasticsearch

Documentation

Index

• Variables
• type ElasticSearchClient
  • 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

Variables

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

Types

type ElasticSearchClient

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

func NewElasticSearchClient

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

func NewElasticSearchClientFromConfig

func NewElasticSearchClientFromConfig() (*ElasticSearchClient, error)

func (*ElasticSearchClient) Delete

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

func (*ElasticSearchClient) Get

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

func (*ElasticSearchClient) Index

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

func (*ElasticSearchClient) IndexChild

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

func (*ElasticSearchClient) Search

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

func (*ElasticSearchClient) Start

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

func (*ElasticSearchClient) Started

func (c *ElasticSearchClient) Started() bool

func (*ElasticSearchClient) Stop

func (c *ElasticSearchClient) Stop()

func (*ElasticSearchClient) Update

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

func (*ElasticSearchClient) UpdateWithPartialDoc

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