opensearch

type Backend struct {
	Address     string        `json:"address"`
	Username    *types.EnvVar `json:"username,omitempty"`
	Password    *types.EnvVar `json:"password,omitempty"`
	InsecureTLS bool          `json:"insecureTLS,omitempty"`
	// InspectionKey identifies the resolved connection without placing its URL
	// or credentials in metadata cache keys.
	InspectionKey string `json:"-"`
}

type HitsInfo struct {
	Total    TotalHitsInfo `json:"total"`
	MaxScore float64       `json:"max_score"`
	Hits     []SearchHit   `json:"hits"`
}

type OpenSearchError struct {
	Operation     string
	StatusCode    int
	Status        string
	Type          string
	Reason        string
	Causes        []OpenSearchErrorCause
	BodyTruncated bool
}

type OpenSearchErrorCause struct {
	Type   string
	Reason string
}

type RawClientMixin interface {
	GetRawClient() any
}

type Request struct {
	Index string `json:"index" template:"true"`
	Query string `json:"query" template:"true"`

	// Limit is how many documents to return. It is required — "0" asks for none,
	// which is what an aggregation-only search wants.
	Limit string `json:"limit,omitempty" template:"true"`

	// PIT pins the search to a point-in-time, so consecutive pages of one walk
	// read the same view of the index.
	PIT string `json:"-"`
}

type Response struct {
	Took         float64        `json:"took"`
	TimedOut     bool           `json:"timed_out"`
	Hits         HitsInfo       `json:"hits"`
	ScrollID     string         `json:"_scroll_id,omitempty"`
	Aggregations map[string]any `json:"aggregations,omitempty"`
}

type Result struct {
	// Id is the unique identifier provided by the underlying system, use to link to a point in time of a log stream
	Id string `json:"id,omitempty"`
	// RFC3339 timestamp
	Time    string            `json:"timestamp,omitempty"`
	Message string            `json:"message,omitempty"`
	Labels  map[string]string `json:"labels,omitempty"`
}

type ScrollPageRequest struct {
	ID        string
	KeepAlive time.Duration
}

type ScrollRequest struct {
	Request
	KeepAlive time.Duration
}

type SearchHit struct {
	Index  string         `json:"_index"`
	Type   string         `json:"_type"`
	ID     string         `json:"_id"`
	Score  float64        `json:"_score"`
	Sort   []any          `json:"sort"`
	Source map[string]any `json:"_source"`
	Fields map[string]any `json:"fields,omitempty"`
}

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

type TotalHitsInfo struct {
	Value    int64  `json:"value"`
	Relation string `json:"relation"`
}

type Value struct {
	Value string `json:"value"`
	Count int64  `json:"count"`
}

type ValuesRequest struct {
	Index string
	Field string
	// Search keeps only the values containing it, matched as a substring.
	Search string
	Limit  int
	Body   map[string]any

	// Nested names the `nested` field Field lives inside, and Where pins the
	// entry of it the values are read from — the key of a key/value tag list.
	//
	// Both are required for a nested field to answer at all: its entries are
	// indexed as separate documents, so an aggregation that does not descend into
	// them returns no buckets, and one that descends without pinning the entry
	// returns every tag's values mixed together.
	Nested string
	Where  map[string]string
}

type ValuesResult struct {
	Values []Value `json:"values"`
	Total  int     `json:"total"`
}