es

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

type Config struct {
	// Addresses 节点地址列表(如 http://127.0.0.1:9200)。
	Addresses []string
	// Username/Password 认证(可选)。
	Username string
	Password string
	// Timeout 请求超时(默认 10s)。
	Timeout time.Duration
	// CloudID 弹性云 ID(可选,优先于 Addresses)。
	CloudID string
	// APIKey API Key 认证(可选)。
	APIKey string
}

type EsTemplate interface {
	// Ping 健康检查。
	Ping(ctx context.Context) error
	// Index 写入文档(指定 ID;存在即覆盖)。
	Index(ctx context.Context, index, id string, document interface{}) error
	// IndexWithRefresh 写入文档并强制 refresh(测试/低延迟场景)。
	IndexWithRefresh(ctx context.Context, index, id string, document interface{}) error
	// Get 按 ID 获取文档原始 JSON。
	Get(ctx context.Context, index, id string) ([]byte, error)
	// Delete 按 ID 删除文档。
	Delete(ctx context.Context, index, id string) error
	// Search 执行查询(DSL 原始字节);返回解析后的搜索响应。
	Search(ctx context.Context, index string, query []byte) (*SearchResponse, error)
	// ExistsIndex 判断索引是否存在。
	ExistsIndex(ctx context.Context, index string) (bool, error)
	// CreateIndex 创建索引(带 settings/mappings JSON;已存在时返回 false 不报错)。
	CreateIndex(ctx context.Context, index string, settingsJSON []byte) (bool, error)
	// Client 返回底层原生客户端(高级操作入口)。
	Client() *elasticsearch.Client
}

type Hit struct {
	Index  string          `json:"_index"`
	ID     string          `json:"_id"`
	Score  float64         `json:"_score"`
	Source json.RawMessage `json:"_source"`
}

type SearchResponse struct {
	Took     int  `json:"took"`
	TimedOut bool `json:"timed_out"`
	Hits     struct {
		Total struct {
			Value int64 `json:"value"`
		} `json:"total"`
		Hits []Hit `json:"hits"`
	} `json:"hits"`
}