elasticsearch

type AggRequest struct {
	ValueCount  *ValueCountAggRequest  `json:"value_count,omitempty"`
	Cardinality *CardinalityAggRequest `json:"cardinality,omitempty"`
	Terms       *TermsAggRequest       `json:"terms,omitempty"`
	Aggs        map[string]AggRequest  `json:"aggs,omitempty"`
	Filter      *Filter                `json:"filter,omitempty"`
}

type AggregationResult struct {
	Value     int                        `json:"value,omitempty"`
	DocCount  int                        `json:"doc_count,omitempty"`
	TermCount AggregationTermCountResult `json:"termcount,omitempty"`
}

type AggregationTermCountBucket struct {
	DocCount int    `json:"doc_count"`
	Key      string `json:"key"`
}

type AggregationTermCountResult struct {
	Buckets []AggregationTermCountBucket `json:"buckets"`
}

type Analyzer struct {
	Tokenizer string   `json:"tokenizer"`
	Filter    []string `json:"filter"`
}

type Analyzers struct {
	Analyzers map[string]Analyzer `json:"analyzer,omitempty"`
}

type BoolFilter struct {
	Must    []Filter `json:"must,omitempty"`
	MustNot []Filter `json:"must_not,omitempty"`
	Should  []Filter `json:"should,omitempty"`
}

type BoolQuery struct {
	Must               []Query `json:"must,omitempty"`
	MustNot            []Query `json:"must_not,omitempty"`
	Should             []Query `json:"should,omitempty"`
	MinimumShouldMatch int     `json:"minimum_should_match,omitempty"`
	Boost              float64 `json:"boost,omitempty"`
}

type CardinalityAggRequest struct {
	Field string `json:"field"`
}

type DynamicTemplate struct {
	Match            string      `json:"match"`
	MatchMappingType string      `json:"match_mapping_type"`
	Mapping          *Properties `json:"mapping,omitempty"`
}

type ElasticConnector interface {
	Client() *http.Client
	GetElasticService() string
	GetElasticUsername() string
	GetElasticPassword() string
}

type ElasticDoc struct {
	Index  string                      `json:"_index"`
	Type   string                      `json:"_type"`
	Id     string                      `json:"_id"`
	Score  float64                     `json:"_score"`
	Source map[string]*json.RawMessage `json:"_source"`
}

type ElasticSearchContext interface {
	ElasticConnector
	Debugf(format string, args ...interface{})
}

type FacetRequest struct {
	Terms *TermsFacetRequest `json:"terms,omitempty"`
}

type FacetResponse struct {
	Type    string              `json:"_type"`
	Missing int                 `json:"missing"`
	Total   int                 `json:"total"`
	Other   int                 `json:"other"`
	Terms   []TermFacetResponse `json:"terms"`
}

type Filter struct {
	Or      []Query                `json:"or,omitempty"`
	Query   *Query                 `json:"query,omitempty"`
	Bool    *BoolFilter            `json:"bool,omitempty"`
	Term    map[string]interface{} `json:"term,omitempty"`
	Range   map[string]RangeDef    `json:"range,omitempty"`
	Missing *MissingFilter         `json:"missing,omitempty"`
}

type FilteredQuery struct {
	Query  *Query  `json:"query"`
	Filter *Filter `json:"filter"`
}

type Hits struct {
	Total    int          `json:"total"`
	MaxScore float64      `json:"max_score"`
	Hits     []ElasticDoc `json:"hits"`
}

type IndexDef struct {
	Settings Settings           `json:"settings,omitempty"`
	Mappings map[string]Mapping `json:"mappings,omitempty"`
	Template string             `json:"template,omitempty"`
}

type IndexOption string

type Mapping struct {
	DynamicTemplates []map[string]DynamicTemplate `json:"dynamic_templates,omitempty"`
	Properties       map[string]Properties        `json:"properties,omitempty"`
}

type MatchAllQuery struct {
	Boost float64 `json:"boost,omitempty"`
}

type MissingFilter struct {
	Field string `json:"field"`
}

type PageableItems struct {
	Items   []interface{} `json:"items"`
	Total   int           `json:"total"`
	Page    int           `json:"page"`
	PerPage int           `json:"per_page"`
}

type Properties struct {
	Type     string                `json:"type"`
	Index    IndexOption           `json:"index,omitempty"`
	Store    bool                  `json:"store"`
	Fields   map[string]Properties `json:"fields,omitempty"`
	Analyzer string                `json:"analyzer,omitempty"`
}

type Query struct {
	String       *StringQuery           `json:"query_string,omitempty"`
	SimpleString *SimpleStringQuery     `json:"simple_query_string,omitempty"`
	Term         map[string]string      `json:"term,omitempty"`
	Range        map[string]RangeDef    `json:"range,omitempty"`
	Bool         *BoolQuery             `json:"bool,omitempty"`
	Filtered     *FilteredQuery         `json:"filtered,omitempty"`
	MatchAll     *MatchAllQuery         `json:"match_all,omitempty"`
	Ids          map[string]interface{} `json:"ids,omitempty"`
}

type RangeDef struct {
	Gt    string `json:"gt,omitempty"`
	Gte   string `json:"gte,omitempty"`
	Lt    string `json:"lt,omitempty"`
	Lte   string `json:"lte,omitempty"`
	Boost string `json:"boost,omitempty"`
}

type SearchRequest struct {
	Query  *Query                  `json:"query,omitempty"`
	From   int                     `json:"from,omitempty"`
	Size   int                     `json:"size,omitempty"`
	Sort   []map[string]Sort       `json:"sort,omitempty"`
	Facets map[string]FacetRequest `json:"facets,omitempty"`
	Aggs   map[string]AggRequest   `json:"aggs,omitempty"`
}

type SearchResponse struct {
	Took         float64                      `json:"took"`
	Hits         Hits                         `json:"hits"`
	Facets       map[string]FacetResponse     `json:"facets,omitempty"`
	Page         int                          `json:"page"`
	PerPage      int                          `json:"per_page"`
	Aggregations map[string]AggregationResult `json:"aggregations,omitempty"`
}

type Settings struct {
	Analysis Analyzers `json:"analysis,omitempty"`
}

type SimpleStringQuery StringQuery

type Sort struct {
	Order          string `json:"order"`
	Missing        string `json:"missing,omitempty"`
	IgnoreUnmapped bool   `json:"ignore_unmapped"`
}

type Sources []map[string]*json.RawMessage

type StringQuery struct {
	Query           string `json:"query"`
	AnalyzeWildcard bool   `json:"analyze_wildcard"`
	DefaultField    string `json:"default_field"`
}

type TermFacetResponse struct {
	Term  string `json:"term"`
	Count int    `json:"count"`
}

type TermsAggRequest struct {
	Field string `json:"field"`
}

type TermsFacetRequest struct {
	Field string `json:"field"`
	Size  int    `json:"size"`
}

type UpdateRequest struct {
	Script string                 `json:"script"`
	Params map[string]interface{} `json:"params"`
}

type ValueCountAggRequest struct {
	Field string `json:"field"`
}