es

type Agg struct {
	Key         string
	Aggregation *aggContainer
}

type AggArray []*Agg

type AggBuilder interface {
	Histogram(key, field string, fn func(a *HistogramAgg, b AggBuilder)) AggBuilder
	DateHistogram(key, field string, fn func(a *DateHistogramAgg, b AggBuilder)) AggBuilder
	Terms(key, field string, fn func(a *TermsAggregation, b AggBuilder)) AggBuilder
	Nested(key, path string, fn func(a *NestedAggregation, b AggBuilder)) AggBuilder
	Filters(key string, fn func(a *FiltersAggregation, b AggBuilder)) AggBuilder
	GeoHashGrid(key, field string, fn func(a *GeoHashGridAggregation, b AggBuilder)) AggBuilder
	Metric(key, metricType, field string, fn func(a *MetricAggregation)) AggBuilder
	Pipeline(key, pipelineType string, bucketPath interface{}, fn func(a *PipelineAggregation)) AggBuilder
	Build() (AggArray, error)
}

type Aggregation interface{}

type BoolQuery struct {
	Filters []Filter
}

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

type Client interface {
	ExecuteMultisearch(r []*SearchRequest) ([]*json.RawMessage, error)
}

type ConfiguredFields struct {
	TimeField        string
	TimeOutputFormat string
	LogMessageField  string
	LogLevelField    string
}

type DatasourceInfo struct {
	ID                         int64
	HTTPClient                 *http.Client
	URL                        string
	Database                   string
	ConfiguredFields           ConfiguredFields
	MaxConcurrentShardRequests int64
	ReadyStatus                chan ReadyStatus
	ShouldInit                 bool
}

type DateHistogramAgg struct {
	Field          string          `json:"field"`
	FixedInterval  string          `json:"fixed_interval,omitempty"`
	MinDocCount    int             `json:"min_doc_count"`
	Missing        *string         `json:"missing,omitempty"`
	ExtendedBounds *ExtendedBounds `json:"extended_bounds"`
	// Format         string          `json:"format"`
	Offset   string `json:"offset,omitempty"`
	TimeZone string `json:"time_zone,omitempty"`
}

type DateRangeFilter struct {
	Filter
	Key    string
	Gte    string
	Lte    string
	Format string
}

type ExtendedBounds struct {
	Min int64 `json:"min"`
	Max int64 `json:"max"`
}

type Filter interface{}

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

type FiltersAggregation struct {
	Filters map[string]interface{} `json:"filters"`
}

type GeoHashGridAggregation struct {
	Field     string `json:"field"`
	Precision int    `json:"precision"`
}

type HistogramAgg struct {
	Interval    int    `json:"interval,omitempty"`
	Field       string `json:"field"`
	MinDocCount int    `json:"min_doc_count"`
	Missing     *int   `json:"missing,omitempty"`
}

type MetricAggregation struct {
	Type     string
	Field    string
	Settings map[string]interface{}
}

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

type MultiSearchResponse struct {
	Responses []*json.RawMessage `json:"responses"`
}

type NestedAggregation struct {
	Path string `json:"path"`
}

type PipelineAggregation struct {
	BucketPath interface{}
	Settings   map[string]interface{}
}

type Query struct {
	Bool *BoolQuery `json:"bool"`
}

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

type QueryStringFilter struct {
	Filter
	Query           string
	AnalyzeWildcard bool
	DefaultOperator string
}

type QuickwitQueryError struct {
	Status       int              `json:"status"`
	Message      string           `json:"message"`
	ResponseBody io.ReadCloser    `json:"response_body"`
	RequestBody  []*SearchRequest `json:"request_body"`
	QueryParam   string           `json:"query_param"`
}

type RangeFilter struct {
	Filter
	Key    string
	Gte    int64
	Lte    int64
	Format string
}

type ReadyStatus struct {
	IsReady bool
	Err     error
}

type SearchRequest struct {
	Index       []string
	Interval    time.Duration
	Size        int
	Sort        []map[string]map[string]interface{}
	Query       *Query
	Aggs        AggArray
	CustomProps map[string]interface{}
}

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

type SearchResponse struct {
	Error        map[string]interface{} `json:"error"`
	Aggregations map[string]interface{} `json:"aggregations"`
	Hits         *SearchResponseHits    `json:"hits"`
}

type SearchResponseHits struct {
	Hits []map[string]interface{}
}

type SortOrder string

type TermsAggregation struct {
	Field       string                 `json:"field"`
	Size        int                    `json:"size"`
	ShardSize   int                    `json:"shard_size"`
	Order       map[string]interface{} `json:"order"`
	MinDocCount *int                   `json:"min_doc_count,omitempty"`
	Missing     *string                `json:"missing,omitempty"`
}