opensearch

type Backend struct {
	Address  string        `json:"address"`
	Username *types.EnvVar `json:"username,omitempty"`
	Password *types.EnvVar `json:"password,omitempty"`
}

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

type RawClientMixin interface {
	GetRawClient() any
}

type Request struct {
	Index string `json:"index" template:"true"`
	Query string `json:"query" template:"true"`
	Limit string `json:"limit,omitempty" template:"true"`
}

type Response struct {
	Took     float64  `json:"took"`
	TimedOut bool     `json:"timed_out"`
	Hits     HitsInfo `json:"hits"`
	ScrollID string   `json:"_scroll_id,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 ScrollOptions struct {
	// Size is the number of documents to fetch per scroll request
	Size int `json:"size,omitempty"`
	// Timeout is how long to keep the scroll context alive
	Timeout time.Duration `json:"timeout,omitempty"`
	// Enabled determines if scroll should be used automatically for large result sets
	Enabled bool `json:"enabled,omitempty"`
}

type ScrollRequest struct {
	Request
	Scroll ScrollOptions `json:"scroll,omitempty"`
}

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"`
}

type SearchResults struct {
	Total    int64            `json:"total,omitempty"`
	Results  []map[string]any `json:"results,omitempty"`
	NextPage string           `json:"nextPage,omitempty"`
}

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

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