elasticsearch

Documentation

Index

• Constants
• func GetDefaultResultSize() int
• type Client
  • func NewClient() (*Client, error)
  • func (e *Client) AddAliasesToMappings(ctx context.Context, aliasToIndexMap map[string]string, ...)
  • func (e *Client) GetAliases(ctx context.Context) (aliasToIndexMap map[string]string, err error)
  • func (e *Client) GetIndices(ctx context.Context) ([]string, error)
  • func (e *Client) GetInfo(ctx context.Context) (interface{}, error)
  • func (e *Client) GetMappings(ctx context.Context, indices []string) (mappings map[string]interface{}, err error)
  • func (e *Client) Ping() error
  • func (e *Client) Search(ctx context.Context, index string, body map[string]interface{}) (map[string]interface{}, error)

Constants

const DEFAULT_RESULT_SIZE_KEY = "esDefaultResultSize"

Functions

func GetDefaultResultSize

func GetDefaultResultSize() int

Types

type Client

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

func NewClient

func NewClient() (*Client, error)

NewClient creates a new client with configuration from cfg.

func (*Client) AddAliasesToMappings

func (e *Client) AddAliasesToMappings(ctx context.Context, aliasToIndexMap map[string]string, mappings map[string]interface{})

AddAliasesToMappings adds aliases to mappings Each alias is added as a separate index The mappings of original index are copied to alias index

func (*Client) GetAliases

func (e *Client) GetAliases(ctx context.Context) (aliasToIndexMap map[string]string, err error)

GetAliases Returns aliases for all indices.

func (*Client) GetIndices

func (e *Client) GetIndices(ctx context.Context) ([]string, error)

GetIndices Returns comma seperated list of indices that matches the ELASTICSEARCH_INDEX_PATTERN env character.

func (*Client) GetInfo

func (e *Client) GetInfo(ctx context.Context) (interface{}, error)

GetInfo retrieves information about Elasticsearch.

func (*Client) GetMappings

func (e *Client) GetMappings(ctx context.Context, indices []string) (mappings map[string]interface{}, err error)

GetMappings Returns mappings for comma seperated list of indices.

func (*Client) Ping

func (e *Client) Ping() error

Ping returns whether the Elasticsearch cluster is running.

func (*Client) Search

func (e *Client) Search(ctx context.Context, index string, body map[string]interface{}) (map[string]interface{}, error)

Search performs a search operation in elastic search.