client

type Client interface {
	// ClearScroll clears the search context and results for a scrolling search.
	ClearScroll(ctx context.Context, scrollID string) error
	// Count returns number of document matches by given query
	Count(ctx context.Context, index, body string) (int64, error)
	// CreateIndex creates index with given name
	CreateIndex(ctx context.Context, index string) error
	// IsNotFoundError checks if error is a "not found"
	IsNotFoundError(err error) bool
	// RunBulkProcessor starts bulk indexing processor
	// @TODO consider to extract Bulk Processor as a separate entity
	RunBulkProcessor(ctx context.Context, p *bulk.BulkProcessorParameters) (bulk.GenericBulkProcessor, error)
	// Scroll retrieves the next batch of results for a scrolling search.
	Scroll(ctx context.Context, index, body, scrollID string) (*Response, error)
	// Search returns Elasticsearch hit bytes and additional metadata
	Search(ctx context.Context, index, body string) (*Response, error)

	// Admin schema management methods
	// IsHealthy checks if the client can connect to the server
	IsHealthy(ctx context.Context) error
	// PutIndexTemplate creates or updates an index template
	PutIndexTemplate(ctx context.Context, templateName string, template []byte) error
	// HasIndex checks if an index exists
	HasIndex(ctx context.Context, indexName string) (bool, error)
	// DeleteIndex deletes an index
	DeleteIndex(ctx context.Context, indexName string) error
	// GetMappings retrieves the mappings for an index
	GetMappings(ctx context.Context, indexName string) (map[string]any, error)
	// PutMappings updates the mappings for an index
	PutMappings(ctx context.Context, indexName string, mappings map[string]any) error
	// MappingsFromTemplate extracts mappings from a template
	MappingsFromTemplate(template []byte) (map[string]any, error)
	// LatestTemplate returns the latest schema template
	LatestTemplate() []byte
}

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

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

type Response struct {
	TookInMillis int64
	TotalHits    int64
	Hits         *SearchHits
	Aggregations map[string]json.RawMessage
	Sort         []interface{}
	ScrollID     string
}

type SearchHit struct {
	Index  string          // index name
	ID     string          // external or internal
	Sort   []interface{}   // sort information
	Source json.RawMessage // stored document source
}

type SearchHits struct {
	TotalHits *TotalHits   // total number of hits found
	Hits      []*SearchHit // the actual hits returned
}

type TotalHits struct {
	Value int64 // value of the total hit count
}