elasticModel

type ESCount struct {
	Count int64 `json:"count"`
}

type ESError struct {
	Status int `json:"status"` // HTTP状态码
	// 错误信息
	Error *ErrorDetail `json:"error"` // 错误详情
}

type ESScrollCallback func(hits []*Hit) error

type ESSearchResponse struct {
	// 请求元信息
	Took     int  `json:"took"`      // 查询耗时(毫秒)
	TimedOut bool `json:"timed_out"` // 是否超时

	// 分片信息
	Shards *ShardsInfo `json:"_shards"` // 分片信息

	// 查询结果
	Hits *HitsContainer `json:"hits"` // 命中结果

	// 聚合结果
	Aggregations map[string]interface{} `json:"aggregations"` // 聚合结果

	// 分页/滚动
	ScrollID string `json:"_scroll_id"` // 滚动查询ID
	PitID    string `json:"pit_id"`     // Point in Time ID

	ESError
}

type ESState struct {
	All struct {
		Primaries struct {
			Store struct {
				SizeInBytes int64 `json:"size_in_bytes"`
			} `json:"store"`
		} `json:"primaries"`
		Total struct {
			Store struct {
				SizeInBytes int64 `json:"size_in_bytes"`
			} `json:"store"`
		} `json:"total"`
	} `json:"_all"`
}

type ErrorDetail struct {
	Type         string         `json:"type"`          // 错误类型
	Reason       string         `json:"reason"`        // 可读的错误原因
	ResourceType string         `json:"resource.type"` // 相关资源类型
	ResourceID   string         `json:"resource.id"`   // 相关资源ID
	Index        string         `json:"index"`         // 相关索引
	Phase        string         `json:"phase"`         // 错误阶段
	RootCause    []*ErrorDetail `json:"root_cause"`    // 根本原因列表
	CausedBy     map[string]any `json:"caused_by"`     // 导致错误的底层原因
	Metadata     map[string]any `json:"metadata"`      // 错误元数据
}

type EsScroll struct {
	ESClient      *elasticsearch.Client // Elasticsearch客户端
	SearchRequest *esapi.SearchRequest  // 搜索请求

	ScrollTime time.Duration // 滚动查询保持时间
	BatchSize  int           // 每批处理的数据量
	Index      []string      // 查询索引
	QueryBody  io.Reader     // 查询体
	SortFields []string      // 排序字段
}

type Hit struct {
	Index       string              `json:"_index"`        // 索引名
	ID          string              `json:"_id"`           // 文档ID
	Score       float64             `json:"_score"`        // 相关性得分
	Source      map[string]any      `json:"_source"`       // 文档原始数据
	Version     int                 `json:"_version"`      // 版本号
	SeqNo       int64               `json:"_seq_no"`       // 序列号
	PrimaryTerm int64               `json:"_primary_term"` // 主任期
	Highlight   map[string][]string `json:"highlight"`     // 高亮结果
	Fields      map[string]any      `json:"fields"`        // 字段数据
	Sort        []any               `json:"sort"`          // 排序值
}

type HitsContainer struct {
	Total    *TotalHits `json:"total"`     // 总命中数信息
	MaxScore float64    `json:"max_score"` // 最大得分
	Hits     []*Hit     `json:"hits"`      // 命中文档列表
}

type ShardsInfo struct {
	Total      int `json:"total"`      // 总分片数
	Successful int `json:"successful"` // 成功分片数
	Skipped    int `json:"skipped"`    // 跳过分片数
	Failed     int `json:"failed"`     // 失败分片数
}

type TotalHits struct {
	Value    int    `json:"value"`    // 命中总数
	Relation string `json:"relation"` // 关系("eq"精确/"gte"估算)
}