v6

Documentation

Index

• type ElasticV6
  • func NewV6Client(connectConfig *config.ElasticSearchConfig, logger log.Logger, ...) (*ElasticV6, error)
  • func (c *ElasticV6) ClearScroll(ctx context.Context, scrollID string) error
  • func (c *ElasticV6) Count(ctx context.Context, index, query string) (int64, error)
  • func (c *ElasticV6) CreateIndex(ctx context.Context, index string) error
  • func (c *ElasticV6) IsNotFoundError(err error) bool
  • func (c *ElasticV6) PutMapping(ctx context.Context, index, body string) error
  • func (c *ElasticV6) RunBulkProcessor(ctx context.Context, parameters *bulk.BulkProcessorParameters) (bulk.GenericBulkProcessor, error)
  • func (c *ElasticV6) Scroll(ctx context.Context, index, body, scrollID string) (*client.Response, error)
  • func (c *ElasticV6) Search(ctx context.Context, index, body string) (*client.Response, error)

Types

type ElasticV6

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

ElasticV6 implements Client

func NewV6Client

func NewV6Client(
	connectConfig *config.ElasticSearchConfig,
	logger log.Logger,
	tlsClient *http.Client,
	awsSigningClient *http.Client,
) (*ElasticV6, error)

NewV6Client returns a new implementation of GenericClient

func (*ElasticV6) ClearScroll

func (c *ElasticV6) ClearScroll(ctx context.Context, scrollID string) error

func (*ElasticV6) Count

func (c *ElasticV6) Count(ctx context.Context, index, query string) (int64, error)

func (*ElasticV6) CreateIndex

func (c *ElasticV6) CreateIndex(ctx context.Context, index string) error

func (*ElasticV6) IsNotFoundError

func (c *ElasticV6) IsNotFoundError(err error) bool

func (*ElasticV6) PutMapping

func (c *ElasticV6) PutMapping(ctx context.Context, index, body string) error

func (*ElasticV6) RunBulkProcessor

func (c *ElasticV6) RunBulkProcessor(ctx context.Context, parameters *bulk.BulkProcessorParameters) (bulk.GenericBulkProcessor, error)

func (*ElasticV6) Scroll

func (c *ElasticV6) Scroll(ctx context.Context, index, body, scrollID string) (*client.Response, error)

func (*ElasticV6) Search

func (c *ElasticV6) Search(ctx context.Context, index, body string) (*client.Response, error)