index

Documentation

Index

• func ESClient() *elastic.Client
• type CustomRetrier
  • func NewCustomRetrier() *CustomRetrier
  • func (r *CustomRetrier) Retry(ctx context.Context, retry int, req *http.Request, resp *http.Response, ...) (time.Duration, bool, error)

Functions

func ESClient

func ESClient() *elastic.Client

ESClient creates or returns an ElasticSearch Client. This function should always be used to perform any ElasticSearch action. Deprecated: use elasticsearch driver package instead

Types

type CustomRetrier

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

CustomRetrier for configuring the retrier for the ElasticSearch client.

func NewCustomRetrier

func NewCustomRetrier() *CustomRetrier

NewCustomRetrier creates custom retrier for elasticsearch

func (*CustomRetrier) Retry

func (r *CustomRetrier) Retry(
	ctx context.Context,
	retry int,
	req *http.Request,
	resp *http.Response,
	err error) (time.Duration, bool, error)

Retry defines how the retrier should deal with retrying the elasticsearch connection.