v7

Documentation

Index

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

Types

type ElasticV7

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

ElasticV7 implements ES7

func NewV7Client

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

NewV7Client returns a new implementation of GenericClient

func (*ElasticV7) ClearScroll

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

func (*ElasticV7) Count

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

func (*ElasticV7) CreateIndex

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

func (*ElasticV7) IsNotFoundError

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

func (*ElasticV7) PutMapping

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

func (*ElasticV7) RunBulkProcessor

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

func (*ElasticV7) Scroll

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

func (*ElasticV7) Search

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