es

Documentation

Index

• type Config
• type ElasticClient
  • func NewElasticsearch(c *Config) *ElasticClient
  • func (e *ElasticClient) CreateDocument(index, docID, body string) (err error)
  • func (e *ElasticClient) CreateIndex(index, body string) (res *esapi.Response, err error)
  • func (e *ElasticClient) DeleteIndex(index []string) (res *esapi.Response, err error)
  • func (e *ElasticClient) Qurey(index string, query map[string]interface{}, res interface{}) (err error)
  • func (e *ElasticClient) UpdateDocumentByID(index, docID, body string) (err error)
  • func (e *ElasticClient) UpdateDocumentByQurey(body string) (err error)

Types

type Config

type Config struct {
	Addresses []string
}

TODO more config to add .

type ElasticClient

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

func NewElasticsearch

func NewElasticsearch(c *Config) *ElasticClient

func (*ElasticClient) CreateDocument

func (e *ElasticClient) CreateDocument(index, docID, body string) (err error)

func (*ElasticClient) CreateIndex

func (e *ElasticClient) CreateIndex(index, body string) (res *esapi.Response, err error)

func (*ElasticClient) DeleteIndex

func (e *ElasticClient) DeleteIndex(index []string) (res *esapi.Response, err error)

func (*ElasticClient) Qurey

func (e *ElasticClient) Qurey(index string, query map[string]interface{}, res interface{}) (err error)

Qurey query from es .

func (*ElasticClient) UpdateDocumentByID

func (e *ElasticClient) UpdateDocumentByID(index, docID, body string) (err error)

func (*ElasticClient) UpdateDocumentByQurey

func (e *ElasticClient) UpdateDocumentByQurey(body string) (err error)