elasticsearch

Nov 22, 2021

Changes in this version

+ var ErrorInternalServer = errors.New("error internal server error")

type Client

+ func (cli *Client) BulkUpdate(ctx context.Context, esDestIndex string, esDestURL string, bulk []byte) ([]byte, int, error)

Sep 13, 2021

Changes in this version

type Client

+ func (cli *Client) GetIndices(ctx context.Context, indexPatterns []string) (int, []byte, error)

May 14, 2021

Changes in this version

type Client

+ func NewClientWithHTTPClientAndAwsSigner(url string, signer *esauth.Signer, signRequests bool, httpCli dphttp.Clienter, ...) *Client

Apr 19, 2021

Changes in this version

type Client

+ func NewClientWithHTTPClientAndOptionalAWSSignage(url, awsRegion, awsService string, awsSDKSigner, signRequests bool, ...) *Client

Nov 11, 2020

Changes in this version

+ const HealthGreen

+ const HealthRed

+ const HealthYellow

+ const MsgHealthy

+ const ServiceName

+ var ErrorClusterAtRisk = errors.New("error cluster state yellow. Data might be at risk, check your replica shards")

+ var ErrorIndexDoesNotExist = errors.New("error index does not exist in cluster")

+ var ErrorInvalidHealthStatus = errors.New("error invalid health status returned")

+ var ErrorParsingBody = errors.New("error parsing cluster health response body")

+ var ErrorUnexpectedStatusCode = errors.New("unexpected status code from api")

+ var ErrorUnhealthyClusterStatus = errors.New("error cluster health red. Cluster is unhealthy")

+ type Client struct

+ func NewClient(url string, signRequests bool, maxRetries int, indexes ...string) *Client

+ func NewClientWithHTTPClient(url string, signRequests bool, httpCli dphttp.Clienter, indexes ...string) *Client

+ func (cli *Client) AddDocument(ctx context.Context, indexName, documentType, documentID string, ...) (int, error)

+ func (cli *Client) Checker(ctx context.Context, state *health.CheckState) error

+ func (cli *Client) CreateIndex(ctx context.Context, indexName string, indexSettings []byte) (int, error)

+ func (cli *Client) DeleteIndex(ctx context.Context, indexName string) (int, error)

+ type ClusterHealth struct

+ Status string

+ type HealthStatus int

+ func (hs HealthStatus) String() string