nes

type BulkRequest = esapi.BulkRequest

type Client = es.Client

type CountRequest = esapi.CountRequest

type CreateRequest = esapi.CreateRequest

type DeleteByQueryRequest = esapi.DeleteByQueryRequest

type DeleteRequest = esapi.DeleteRequest

type ESConfig struct {
	Addrs    []string `yaml:"addrs"`
	Username string   `yaml:"username"`
	Password string   `yaml:"password"`
}

type ESOper interface {
	ESClient() *Client

	Get(ctx context.Context, model interface{}, index string, id string, opts ...func(*GetRequest)) (interface{}, error)

	MultiGet(ctx context.Context, model interface{}, index string, ids []string, opts ...func(*MgetRequest)) (interface{}, error)

	// Bulk allows to perform multiple index/update/delete operations in a single request.
	//
	// See full documentation at https://www.elastic.co/guide/en/elasticsearch/reference/master/docs-bulk.html.
	Bulk(ctx context.Context, index string, writeReqBody func(ctx context.Context, buf *bytes.Buffer) error, opts ...func(*BulkRequest)) error

	Create(ctx context.Context, index string, id string, obj interface{}, opts ...func(*CreateRequest)) error
	Index(ctx context.Context, index string, id string, obj interface{}, opts ...func(*IndexRequest)) error

	Delete(ctx context.Context, id string, index string, opts ...func(*DeleteRequest)) error
	DeleteByQuery(ctx context.Context, query string, indexes []string, opts ...func(*DeleteByQueryRequest)) error
	DeleteByQueryTemplate(ctx context.Context, t *TemplateParam, indexes []string, opts ...func(*DeleteByQueryRequest)) error

	UpdateByQuery(ctx context.Context, query string, indexes []string, opts ...func(*UpdateByQueryRequest)) error
	UpdateByQueryTemplate(ctx context.Context, t *TemplateParam, indexes []string, opts ...func(*UpdateByQueryRequest)) error

	Count(ctx context.Context, query string, indexes []string, opts ...func(*CountRequest)) (int64, error)
	CountTemplate(ctx context.Context, t *TemplateParam, indexes []string, opts ...func(*CountRequest)) (int64, error)
	Search(ctx context.Context, model interface{}, query string, indexes []string, opts ...func(*SearchRequest)) (interface{}, error)
	SearchTemplate(ctx context.Context, model interface{}, t *TemplateParam, indexes []string, opts ...func(*SearchRequest)) (interface{}, error)
	// Scroll allows to retrieve a large numbers of results from a single search request.
	//
	// We no longer recommend using the scroll API for deep pagination.
	// If you need to preserve the index state while paging through more than 10,000 hits, use the search_after parameter with a point in time (PIT).
	// See documentation at https://www.elastic.co/guide/en/elasticsearch/reference/master/paginate-search-results.html#scroll-search-results
	SearchByScrollID(ctx context.Context, model interface{}, scrollID string, opts ...func(*ScrollRequest)) (interface{}, error)
}

type GetRequest = esapi.GetRequest

type IndexRequest = esapi.IndexRequest

type MgetRequest = esapi.MgetRequest

type Response = esapi.Response

type ScrollRequest = esapi.ScrollRequest

type SearchRequest = esapi.SearchRequest

type TemplateParam struct {
	Template *ntemplate.TextTemplate
	Data     interface{}
	Name     string
}

type UpdateByQueryRequest = esapi.UpdateByQueryRequest

type UpdateRequest = esapi.UpdateRequest