es

type BulkIndexByScrollResponse struct {
	*elastic.BulkIndexByScrollResponse
}

type BulkResponse struct {
	*elastic.BulkResponse
}

type Config struct {
	// Disabled 禁用 上层 初始化服务时候 可以判断该属性 如果为 配置 true 则不去初始化服务
	Disabled bool `json:"disabled,omitempty" yaml:"disabled,omitempty"`

	Url      string `json:"url,omitempty" yaml:"url,omitempty"`
	Username string `json:"username,omitempty" yaml:"username,omitempty"`
	Password string `json:"password,omitempty" yaml:"password,omitempty"`
	CertPath string `json:"certPath,omitempty" yaml:"certPath,omitempty"`
}

type DeleteResponse struct {
	*elastic.DeleteResponse
}

type HitData struct {
	Index   string `json:"_index,omitempty"`   // index name
	Type    string `json:"_type,omitempty"`    // type meta field
	Id      string `json:"_id,omitempty"`      // external or internal
	Uid     string `json:"_uid,omitempty"`     // uid meta field (see MapperService.java for all meta fields)
	Version *int64 `json:"_version,omitempty"` // version number, when Version is set to true in SearchService
	Source  string `json:"_source,omitempty"`  // stored document source
}

type IService interface {
	// Close  关闭 elasticsearch 客户端
	Close()
	// Info  获取 elasticsearch 信息
	Info() (res *elastic.NodesInfoResponse, err error)
	// DeleteIndex  删除 索引
	DeleteIndex(indexName string) (err error)
	// CreateIndex  创建 索引
	CreateIndex(indexName string, bodyJSON map[string]interface{}) (err error)
	// Indexes  查询 索引
	Indexes() (indexes []*IndexInfo, err error)
	// GetMapping  查询 索引 配置
	GetMapping(indexName string) (res interface{}, err error)
	// PutMapping  设置 索引 配置
	PutMapping(indexName string, bodyJSON map[string]interface{}) (err error)
	// SetFieldType  设置 索引 字段类型
	SetFieldType(indexName string, fieldName string, fieldType string) (err error)
	// Search  搜索
	Search(indexName string, pageIndex int, pageSize int, whereList []*Where, orderList []*Order) (res *SearchResult, err error)
	// Insert  插入数据 并且 等待刷新
	Insert(indexName string, id string, doc interface{}) (res *InsertResponse, err error)
	// InsertNotWait  插入数据 不 等待刷新
	InsertNotWait(indexName string, id string, doc interface{}) (res *InsertResponse, err error)
	// BatchInsertNotWait  批量插入数据 不 等待刷新
	BatchInsertNotWait(docs []*InsertDoc) (res *BulkResponse, err error)
	// Update  更新数据 并且 等待刷新
	Update(indexName string, id string, doc interface{}) (res *UpdateResponse, err error)
	// UpdateNotWait  更新数据 不 等待刷新
	UpdateNotWait(indexName string, id string, doc interface{}) (res *UpdateResponse, err error)
	// Delete  删除 并且 等待刷新
	Delete(indexName string, id string) (res *DeleteResponse, err error)
	// DeleteNotWait  删除 不 等待刷新
	DeleteNotWait(indexName string, id string) (res *DeleteResponse, err error)
	// Reindex 修改索引名称
	Reindex(sourceIndexName string, toIndexName string) (res *BulkIndexByScrollResponse, err error)
	// IndexStat 索引状态
	IndexStat(indexName string) (res *IndicesStatsResponse, err error)
	// Scroll 滚动查询
	Scroll(indexName string, scrollId string, pageSize int, whereList []*Where, orderList []*Order) (res *SearchResult, err error)
	// IndexAlias 索引别名
	IndexAlias(indexName string, aliasName string) (res *IndexAliasResponse, err error)
	PerformRequest(options PerformRequestOptions) (res *PerformResponse, err error)
	QuerySql(query string) (res *QuerySqlResult, err error)
}

type IndexAliasResponse struct {
	*elastic.AliasResult
}

type IndexInfo struct {
	IndexName string `json:"indexName"`
}

type IndicesStatsResponse struct {
	*elastic.IndicesStatsResponse
}

type InsertDoc struct {
	IndexName string
	Id        string
	Doc       interface{}
}

type InsertResponse struct {
	*elastic.IndexResponse
}

type Order struct {
	Name    string `json:"name"`
	AscDesc string `json:"ascDesc"`
}

type PerformRequestOptions struct {
	elastic.PerformRequestOptions
}

type PerformResponse struct {
	Header http.Header
	Body   []byte
}

type QuerySqlResult struct {
	Columns []*QuerySqlResultColumn `json:"columns"`
	Rows    [][]interface{}         `json:"rows"`
}

type QuerySqlResultColumn struct {
	Name string `json:"name"`
	Type string `json:"type"`
}

type SearchResult struct {
	TotalHits *elastic.TotalHits `json:"total,omitempty"`     // total number of hits found
	MaxScore  *float64           `json:"max_score,omitempty"` // maximum score of all hits
	Hits      []*HitData         `json:"hits,omitempty"`      // the actual hits returned
	ScrollId  string             `json:"_scroll_id,omitempty"`
}

type UpdateResponse struct {
	*elastic.UpdateResponse
}

type V7Service struct {
	*Config
	// contains filtered or unexported fields
}

type Where struct {
	Name                    string `json:"name"`
	Value                   string `json:"value"`
	Before                  string `json:"before"`
	After                   string `json:"after"`
	CustomSql               string `json:"customSql"`
	SqlConditionalOperation string `json:"sqlConditionalOperation"`
	AndOr                   string `json:"andOr"`
}