Documentation
¶
Index ¶
- type ElasticV6
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 (*ElasticV6) CreateIndex ¶
func (*ElasticV6) IsNotFoundError ¶
func (*ElasticV6) PutMapping ¶
func (*ElasticV6) RunBulkProcessor ¶
func (c *ElasticV6) RunBulkProcessor(ctx context.Context, parameters *bulk.BulkProcessorParameters) (bulk.GenericBulkProcessor, error)
Source Files
Click to show internal directories.
Click to hide internal directories.