calculate

type AggFunc func(params map[string]interface{}, currentTerm ...string) elastic.Aggregation

type AggHistogramFunc func(aggList map[string]elastic.Aggregation) elastic.Aggregation

type CheckAggReverseNest func(metricName string, sceneName ...string) bool // 检测函数是否需要反转 true的时候, 不执行 reverse_nest 操作

type ESConfig struct {
	EsIndex         string                      // 要用到的 es 文档
	AggFuncList     map[string]AggFunc          // 存放 AggFunc 函数
	HistogramList   map[string]AggHistogramFunc // 存放直方图聚合指标
	GetAggListFunc  GetAggFunc
	ESIndexNameFunc ESIndexFunc
	sync.Mutex
}

type ESIndexFunc func(params map[string]interface{}, sceneName ...string) string

type EsAggregation struct {
	ESIndex     string         `json:"es_index"`
	Type        string         `json:"type"`         // 聚合类型  count/terms/avg
	MetricsName string         `json:"metrics_name"` // 指标名称
	Field       string         `json:"field"`        // 要聚合的字段名
	FieldPath   string         `json:"filed_path"`   // 字段路径
	Size        int            `json:"size"`         // 数量限制 1000
	FieldType   string         `json:"filed_type"`   // 字段类型 term/nested
	TermQuery   *EsQueryConfig `json:"term_query"`   // 如果是type是 terms 的, 需要指定筛选条件
	SearchQuery *EsQueryConfig `json:"search_query"` // 整体数据的搜索条件

	ParamsMapList *ParamsMapList // 初始化后的参数配置
	// contains filtered or unexported fields
}

type EsQueryBuilder struct {
	RequestQuery interface{} `json:"request_query"`
	// contains filtered or unexported fields
}

type EsQueryCondition struct {
	Type       string // key 类型   term/terms/nested
	Path       string // nested 的路径  join_classes
	Conditions []*SearchCondition
}

type EsQueryConfig struct {
	Conditions []*EsQueryCondition
}

type EsTerm struct {
	ConfigType string //指标的类型 terms
	ColumnType string //字段类型  term/nested
	Path       string // 字段是 nested 时的路径, 如 join_classes
	ColumnName string // 字段 key 值, 例如 join_classes.cust_wxid
}

type FilterFunc func(curTermItem []interface{}) bool

type GetAggFunc func(metricName string, sceneName ...string) AggFunc // 外部注入的获取指标的方法, 如果没有的话, 就默认读取AggFuncList这里的指标

type HistogramItem struct {
	KeyAsString string
	Key         interface{}
	DocCount    int64
	Metrics     map[string]interface{}
}

type HistogramResult struct {
	HistogramName string
	MetricsList   []string
	Result        []HistogramItem
}

type ParamsMapList struct {
	SceneName string `json:"scene_name"`
	//MetricsName   string                      `json:"metrics_name"`
	Params        map[string]string           `json:"params"`
	NestedGroup   map[string]map[string]bool  // 结构是 nested path: []key
	OriginList    map[string]*SearchCondition // 指定的 key => 最终生效的查询
	EsQueryConfig *EsQueryConfig              // 最终生成的 query 组合
}

type SearchCondition struct {
	Type     string      // term/terms/range/
	Key      string      // 字段名  join_classes.cust_wxid
	Optional int         // 是否可选, 1 可选, 0 必填
	Value    interface{} //字段值  xxxwww
}

type TermItem struct {
	Terms []interface{}
	Cnt   int64
	Data  map[string]interface{}
	// contains filtered or unexported fields
}

type TermResult struct {
	Result      []TermItem
	TermsList   []string
	MetricsList []string
}