elastic

type AAIR_Alias struct {
	Name    string   `json:"name"`
	Indices []string `json:"indices"`
}

type AAIR_Indices struct {
	Name       string   `json:"name"`
	Attributes []string `json:"attributes"`
	Aliases    []string `json:"aliases,omitempty"`
}

type API interface {
	ScrollAPI
	MappingAPI
	TemplateAPI
	ReplicationAPI
	SecurityAPI
	ScriptAPI

	InitDefaultTemplate(templateName, indexPrefix string)

	GetMajorVersion() int

	ClusterHealth(ctx context.Context) (*ClusterHealth, error)
	ClusterHealthSpecEndpoint(ctx context.Context, endPoint string, level string) (*ClusterHealth, error)

	GetClusterState() (*ClusterState, error)

	GetClusterStats(ctx context.Context, node string) (*ClusterStats, error)
	GetClusterStatsSpecEndpoint(ctx context.Context, node string, endPoint string) (*ClusterStats, error)

	GetNodesStats(nodeID, host string, level string) *NodesStats

	GetIndicesStats() *IndicesStats

	GetVersion() Version

	CreateIndex(name string, settings map[string]interface{}) error

	Index(indexName, docType string, id interface{}, data interface{}, refresh string) (*InsertResponse, error)

	Update(indexName, docType string, id interface{}, data interface{}, refresh string) (*InsertResponse, error)

	Bulk(data []byte) (*util.Result, error)

	Get(indexName, docType, id string) (*GetResponse, error)
	Delete(indexName, docType, id string, refresh ...string) (*DeleteResponse, error)
	Count(ctx context.Context, indexName string, body []byte) (*CountResponse, error)
	Search(indexName string, query *SearchRequest) (*SearchResponse, error)

	QueryDSL(ctx context.Context, indexName string, queryArgs *[]util.KV, queryDSL []byte) (*SearchResponse, error)

	SearchWithRawQueryDSL(indexName string, queryDSL []byte) (*SearchResponse, error)

	GetIndexSettings(indexNames string) (*util.MapStr, error)
	UpdateIndexSettings(indexName string, settings map[string]interface{}) error

	IndexExists(indexName string) (bool, error)

	DeleteIndex(name string) error

	Refresh(name string) (err error)

	GetNodes() (*map[string]NodesInfo, error)

	GetNodeInfo(nodeID string) (*NodesInfo, error)

	GetIndices(pattern string) (*map[string]IndexInfo, error)

	GetPrimaryShards() (*map[string]map[int]ShardInfo, error)
	GetAliases() (*map[string]AliasInfo, error)
	GetAliasesDetail() (*map[string]AliasDetailInfo, error)
	GetAliasesAndIndices() (*AliasAndIndicesResponse, error)

	SearchTasksByIds(ids []string) (*SearchResponse, error)
	Reindex(body []byte) (*ReindexResponse, error)
	DeleteByQuery(indexName string, body []byte) (*DeleteByQueryResponse, error)
	UpdateByQuery(indexName string, body []byte) (*UpdateByQueryResponse, error)

	GetIndexStats(indexName string) (*util.MapStr, error)
	GetStats() (*Stats, error)
	Forcemerge(indexName string, maxCount int) error
	SetSearchTemplate(templateID string, body []byte) error
	DeleteSearchTemplate(templateID string) error
	RenderTemplate(body map[string]interface{}) ([]byte, error)
	SearchTemplate(body map[string]interface{}) ([]byte, error)
	Alias(body []byte) error
	FieldCaps(target string) ([]byte, error)
	CatShards() ([]CatShardResponse, error)
	CatShardsSpecEndpoint(endPoint string) ([]CatShardResponse, error)
	CatNodes(colStr string) ([]CatNodeResponse, error)

	GetIndexRoutingTable(index string) (map[string][]IndexShardRouting, error)
	GetClusterSettings(values url.Values) (map[string]interface{}, error)
	UpdateClusterSettings(body []byte) error
	GetIndex(indexName string) (map[string]interface{}, error)
	Exists(target string) (bool, error)
	GetILMPolicy(target string) (map[string]interface{}, error)
	PutILMPolicy(target string, policyConfig []byte) error
	DeleteILMPolicy(target string) error
	GetRemoteInfo() ([]byte, error)
	Flush(indexName string) ([]byte, error)
	ClusterAllocationExplain(ctx context.Context, body []byte, params url.Values) ([]byte, error)
}

type APIContext struct {
	context.Context `json:"-"`
	Client          *fasthttp.Client
	Request         *fasthttp.Request
	Response        *fasthttp.Response
}

type Aggregation struct {
}

type AggregationRequest struct {
	Aggregations map[string]Aggregation `json:"aggregations,omitempty"`
}

type AggregationResponse struct {
	Buckets []BucketBase `json:"buckets,omitempty"`
	Value   interface{}  `json:"value,omitempty"`
}

type AliasAction map[string]map[string]interface{}

type AliasActionBody struct {
	Index         string                 `json:"index,omitempty"`
	Alias         string                 `json:"alias"`
	Indices       []string               `json:"indices,omitempty"`
	Filter        map[string]interface{} `json:"filter,omitempty"`
	Routing       string                 `json:"routing,omitempty"`
	SearchRouting string                 `json:"search_routing,omitempty"`
	IndexRouting  string                 `json:"index_routing,omitempty"`
	IsWriteIndex  bool                   `json:"is_write_index,omitempty"`
}

type AliasAndIndicesResponse struct {
	Aliases []AAIR_Alias   `json:"aliases"`
	Indices []AAIR_Indices `json:"indices"`
}

type AliasDetailInfo struct {
	Alias      string       `json:"alias,omitempty"`
	Indexes    []AliasIndex `json:"indexes,omitempty"`
	WriteIndex string       `json:"write_index,omitempty"`
}

type AliasIndex struct {
	Index         string      `json:"index"`
	Filter        interface{} `json:"filter"`
	IndexRouting  string      `json:"index_routing"`
	SearchRouting string      `json:"search_routing"`
	IsHidden      bool        `json:"is_hidden"`
	IsWriteIndex  bool        `json:"is_write_index"`
}

type AliasInfo struct {
	Alias      string   `json:"alias,omitempty"`
	Index      []string `json:"index,omitempty"`
	WriteIndex string   `json:"write_index,omitempty"`
}

type AliasRequest struct {
	Actions []AliasAction `json:"actions"`
}

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

type BoundValuesResult struct {
	Min             float64
	Max             float64
	Null            int64
	NotExistsFilter map[string]interface{}
}

type Bucket struct {
	KeyAsString interface{} `json:"key_as_string,omitempty"`
	Key         interface{} `json:"key,omitempty"`
	DocCount    int64       `json:"doc_count,omitempty"`
}

type BucketBase map[string]interface{}

type BulkActionMetadata struct {
	Index  *BulkIndexMetadata `json:"index,omitempty"`
	Delete *BulkIndexMetadata `json:"delete,omitempty"`
	Create *BulkIndexMetadata `json:"create,omitempty"`
	Update *BulkIndexMetadata `json:"update,omitempty"`
	Stats  int                `json:"-,omitempty"`
}

type BulkBuffer struct {
	Queue string

	MessageIDs []string
	Reason     []string
	// contains filtered or unexported fields
}

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

type BulkDetail struct {
	Failure BulkDetailItem `json:"failure,omitempty"`
	Invalid BulkDetailItem `json:"invalid,omitempty"`
}

type BulkDetailItem struct {
	Documents []string `json:"documents,omitempty"`
	Reasons   []string `json:"reasons,omitempty"`
}

type BulkIndexMetadata struct {
	Index           string      `json:"_index,omitempty"`
	Type            string      `json:"_type,omitempty"`
	ID              string      `json:"_id,omitempty"`
	Pipeline        string      `json:"pipeline,omitempty"`
	Refresh         string      `json:"refresh,omitempty"`
	Source          interface{} `json:"_source,omitempty"`
	SourceExcludes  interface{} `json:"_source_excludes,omitempty"`
	SourceIncludes  interface{} `json:"_source_includes,omitempty"`
	RetryOnConflict interface{} `json:"retry_on_conflict,omitempty"`
	RequireAlias    interface{} `json:"require_alias,omitempty"`
	Parent1         interface{} `json:"_parent,omitempty"`
	Parent2         interface{} `json:"parent,omitempty"`
	Routing1        interface{} `json:"routing,omitempty"`
	Routing2        interface{} `json:"_routing,omitempty"`
	Version1        interface{} `json:"_version,omitempty"`
	Version2        interface{} `json:"version,omitempty"`

	//for bulk response
	Result      string    `json:"result,omitempty"`
	SeqNo       int64     `json:"_seq_no,omitempty"`
	PrimaryTerm int64     `json:"_primary_term,omitempty"`
	Shards      *struct{} `json:"_shards,omitempty"`

	ErrorResponse
}

type BulkProcessor struct {
	Config         BulkProcessorConfig
	BulkBufferPool *BulkBufferPool
	HttpPool       *fasthttp.RequestResponsePool
}

type BulkProcessorConfig struct {
	BulkSizeInKb     int `config:"batch_size_in_kb,omitempty"`
	BulkSizeInMb     int `config:"batch_size_in_mb,omitempty"`
	BulkMaxDocsCount int `config:"batch_size_in_docs,omitempty"`

	Compress               bool `config:"compress"`
	RetryDelayInSeconds    int  `config:"retry_delay_in_seconds"`
	RejectDelayInSeconds   int  `config:"reject_retry_delay_in_seconds"`
	MaxRejectRetryTimes    int  `config:"max_reject_retry_times"`
	RequestTimeoutInSecond int  `config:"request_timeout_in_second"`

	InvalidRequestsQueue    string `config:"invalid_queue"`
	DeadletterRequestsQueue string `config:"dead_letter_queue"`

	RetryRules RetryRules `config:"retry_rules"`

	BulkResponseParseConfig BulkResponseParseConfig `config:"response_handle"`

	RemoveDuplicatedNewlines bool `config:"remove_duplicated_newlines"`
	// contains filtered or unexported fields
}

type BulkResponse struct {
	Took   int                  `json:"took"`
	Errors bool                 `json:"errors"`
	Items  []BulkActionMetadata `json:"items"`
}

type BulkResponseParseConfig struct {
	SaveSuccessBulkResultToMessageQueue bool `config:"save_success_results"`
	SaveErrorBulkResultToMessageQueue   bool `config:"save_error_results"`
	SaveBusyBulkResultToMessageQueue    bool `config:"save_busy_results"`

	//save bulk results to message queue, include versions
	OutputVersions          bool   `config:"output_result_versions"`
	ResultVersionsQueueName string `config:"result_versions_queue_name"`

	OutputBulkStats    bool `config:"output_bulk_stats"`
	IncludeIndexStats  bool `config:"include_index_stats"`
	IncludeActionStats bool `config:"include_action_stats"`

	IncludeErrorDetails        bool `config:"include_error_details"`
	MaxItemOfErrorDetailsCount int  `config:"max_error_details_count"`

	BulkResultMessageQueue                 string `config:"bulk_result_message_queue"`
	BulkResultMessageMaxRequestBodyLength  int    `config:"max_request_body_size"`
	BulkResultMessageMaxResponseBodyLength int    `config:"max_response_body_size"`
}

type BulkResult struct {
	Error     bool          `json:"error,omitempty"`
	ErrorMsgs []string      `json:"error_msgs,omitempty"`
	Codes     []int         `json:"codes,omitempty"`
	Indices   []string      `json:"indices,omitempty"`
	Actions   []string      `json:"actions,omitempty"`
	Summary   BulkSummary   `json:"summary,omitempty"`
	Stats     BulkStats     `json:"stats,omitempty"`
	Detail    BulkDetail    `json:"detail,omitempty"`
	Versions  []VersionInfo `json:"versions,omitempty"`
}

type BulkStats struct {
	Code    map[int]int    `json:"code,omitempty"`
	Indices map[string]int `json:"indices,omitempty"`
	Actions map[string]int `json:"actions,omitempty"`
}

type BulkSummary struct {
	Failure BulkSummaryItem `json:"failure,omitempty"`
	Invalid BulkSummaryItem `json:"invalid,omitempty"`
	Success BulkSummaryItem `json:"success,omitempty"`
}

type BulkSummaryItem struct {
	Count int `json:"count,omitempty"`
	Size  int `json:"size,omitempty"`
}

type CatIndexResponse struct {
	Health       string `json:"health,omitempty"`
	Status       string `json:"status,omitempty"`
	Index        string `json:"index,omitempty"`
	Uuid         string `json:"uuid,omitempty"`
	Pri          string `json:"pri,omitempty"`
	Rep          string `json:"rep,omitempty"`
	DocsCount    string `json:"docs.count,omitempty"`
	DocsDeleted  string `json:"docs.deleted,omitempty"`
	StoreSize    string `json:"store.size,omitempty"`
	PriStoreSize string `json:"pri.store.size,omitempty"`
	SegmentCount string `json:"segments.count,omitempty"`
}

type CatNodeResponse struct {
	Id          string      `json:"id"`
	Ip          string      `json:"ip"`
	Port        string      `json:"port"`
	HeapPercent string      `json:"heap.percent"`
	RamPercent  string      `json:"ram.percent"`
	Cpu         string      `json:"cpu"`
	Load1M      string      `json:"load_1m"`
	Load5M      interface{} `json:"load_5m"`
	Load15M     interface{} `json:"load_15m"`
	NodeRole    string      `json:"node.role"`
	Master      string      `json:"master"`
	Name        string      `json:"name"`
	DiskAvail   string      `json:"disk.avail"`
	DiskUsed    string      `json:"disk.used"`
	Shards      int         `json:"shards,omitempty"`
	Uptime      string      `json:"uptime"`
	HeapMax     string      `json:"heap.max"`
}

type CatShardResponse struct {
	Index            string `json:"index,omitempty"`
	ShardID          string `json:"shard,omitempty"`
	ShardType        string `json:"prirep,omitempty"`
	State            string `json:"state,omitempty"`
	UnassignedReason string `json:"unassigned,omitempty"`
	Docs             string `json:"docs,omitempty"`
	Store            string `json:"store,omitempty"`
	StoreInBytes     int64  `json:"store_in_bytes,omitempty"`
	NodeID           string `json:"id,omitempty"`
	NodeName         string `json:"node,omitempty"`
	NodeIP           string `json:"ip,omitempty"`
}

type ClusterHealth struct {
	ResponseBase
	Name                        string                            `json:"cluster_name"`
	Status                      string                            `json:"status"`
	TimedOut                    bool                              `json:"timed_out"`
	NumberOfNodes               int                               `json:"number_of_nodes"`
	NumberOf_data_nodes         int                               `json:"number_of_data_nodes"`
	ActivePrimary_shards        int                               `json:"active_primary_shards"`
	ActiveShards                int                               `json:"active_shards"`
	RelocatingShards            int                               `json:"relocating_shards"`
	InitializingShards          int                               `json:"initializing_shards"`
	UnassignedShards            int                               `json:"unassigned_shards"`
	DelayedUnassignedShards     int                               `json:"delayed_unassigned_shards"`
	NumberOfPendingTasks        int                               `json:"number_of_pending_tasks"`
	NumberOfInFlightFetch       int                               `json:"number_of_in_flight_fetch"`
	TaskMaxWaitingInQueueMillis float64                           `json:"task_max_waiting_in_queue_millis"`
	ActiveShardsPercentAsNumber float64                           `json:"active_shards_percent_as_number"`
	Indices                     map[string]map[string]interface{} `json:"indices"`
}

type ClusterInformation struct {
	Name        string `json:"name,intern"`
	ClusterName string `json:"cluster_name,intern"`
	ClusterUUID string `json:"cluster_uuid"`
	Version     struct {
		Number        string `json:"number,intern"`
		LuceneVersion string `json:"lucene_version,intern"`
		Distribution  string `json:"distribution"`
	} `json:"version"`
}

type ClusterRoutingTable struct {
	Indices map[string]struct {
		Shards map[string][]IndexShardRouting `json:"shards"`
	} `json:"indices"`
}

type ClusterState struct {
	ResponseBase

	ClusterName string `json:"cluster_name"`
	Version     int64  `json:"version"`
	StateUUID   string `json:"state_uuid"`
	ClusterUUID string `json:"cluster_uuid"`
	MasterNode  string `json:"master_node"`
	//Nodes        map[string]ClusterStateNodes `json:"nodes"`
	RoutingTable *ClusterRoutingTable `json:"routing_table,omitempty"`

	CompressedSizeInBytes int `json:"compressed_size_in_bytes"` //v6.0+
	Metadata              *struct {
		Indices map[string]interface{} `json:"indices"`
	} `json:"metadata,omitempty"`
}

type ClusterStateNodes struct {
	Name string `json:"name"`

	EphemeralId string `json:"ephemeral_id"` //v5.0+

	TransportAddress string                 `json:"transport_address"`
	Attributes       map[string]interface{} `json:"attributes,omitempty"`
}

type ClusterStats struct {
	ResponseBase
	ClusterName string                 `json:"cluster_name"`
	Status      string                 `json:"status"`
	ClusterUUID string                 `json:"cluster_uuid"`
	Timestamp   int64                  `json:"timestamp"`
	Indices     map[string]interface{} `json:"indices"`
	Nodes       map[string]interface{} `json:"nodes"`
}

type Collapse struct {
	Field string `json:"field,omitempty"`
}

type CommandRequest struct {
	Path   string `json:"path"`
	Method string `json:"method"`
	Body   string `json:"body"`
}

type CommonCommand struct {
	ID       string           `json:"-" index:"id"`
	Title    string           `json:"title" elastic_mapping:"title:{type:text,fields:{keyword:{type:keyword}}}"`
	Tag      []string         `json:"tag" elastic_mapping:"tag:{type:keyword}"`
	Requests []CommandRequest `json:"requests" elastic_mapping:"requests:{type:object}"`
	Created  time.Time        `json:"created,omitempty" elastic_mapping:"created:{type:date}"`
}

type CountResponse struct {
	ResponseBase
	Count int64 `json:"count"`
}

type DeleteByQueryResponse struct {
	Deleted int64 `json:"deleted"`
	Total   int64 `json:"total"`
}

type DeleteResponse struct {
	ResponseBase
	Result  string `json:"result"`
	Index   string `json:"_index"`
	Type    string `json:"_type"`
	ID      string `json:"_id"`
	Version int    `json:"_version"`
	Shards  struct {
		Total      int `json:"total" `
		Failed     int `json:"failed"`
		Successful int `json:"successful"`
	} `json:"_shards"` //es 2.x index api
}

type DiscoveryResult struct {
	Nodes          map[string]*LocalNodeInfo `json:"nodes,omitempty,nocopy"`
	UnknownProcess []model.ProcessInfo       `json:"unknown_process,omitempty,nocopy"`
}

type ElasticField struct {
	Aggregatable      bool     `json:"aggregatable"`
	ESTypes           []string `json:"esTypes"`
	Name              string   `json:"name"`
	ReadFromDocValues bool     `json:"readFromDocValues"`
	Searchable        bool     `json:"searchable"`
	Type              string   `json:"type"`
}

type ElasticFieldType struct {
	Name    string
	ESTypes []string
}

type ElasticsearchConfig struct {
	orm.ORMObjectBase

	Source      string `json:"source,omitempty"`
	Name        string `json:"name,omitempty" config:"name" elastic_mapping:"name:{type:keyword,fields:{text: {type: text}}}"`
	Description string `json:"description,omitempty" elastic_mapping:"description:{type:text}"`

	//reserved means can't be deleted from console or API
	Reserved       bool           `json:"reserved,omitempty" config:"reserved" elastic_mapping:"reserved:{type:boolean}"`
	Enabled        bool           `json:"enabled,omitempty" config:"enabled" elastic_mapping:"enabled:{type:boolean}"`
	Monitored      bool           `json:"monitored,omitempty" config:"monitored" elastic_mapping:"monitored:{type:boolean}"`
	MonitorConfigs *MonitorConfig `config:"monitor_configs" json:"monitor_configs,omitempty" elastic_mapping:"monitor_configs:{type:object}"`
	HttpProxy      string         `json:"http_proxy,omitempty" config:"http_proxy"`
	Endpoint       string         `json:"endpoint,omitempty" config:"endpoint" elastic_mapping:"endpoint:{type:keyword}"`
	Endpoints      []string       `json:"endpoints,omitempty" config:"endpoints" elastic_mapping:"endpoints:{type:keyword}"`
	Version        string         `json:"version,omitempty" config:"version" elastic_mapping:"version:{type:keyword,copy_to:search_text}"`
	ClientMode     string         `json:"client_mode,omitempty" config:"client_mode"`

	RequestTimeout  int  `json:"request_timeout,omitempty" config:"request_timeout"`
	RequestCompress bool `json:"request_compress,omitempty" config:"request_compress"`

	MetadataCacheEnabled bool `json:"metadata_cache_enabled,omitempty" config:"metadata_cache_enabled"`

	AllowAccessWhenMasterNotFound bool `json:"allow_access_when_master_not_found,omitempty" config:"allow_access_when_master_not_found"`

	BasicAuth *model.BasicAuth `config:"basic_auth" json:"basic_auth,omitempty" elastic_mapping:"basic_auth:{type:object}"`

	TrafficControl *struct {
		Enabled              bool `json:"enabled,omitempty" config:"enabled"`
		MaxConnectionPerNode int  `` /* 130-byte string literal not displayed */
		MaxWaitTimeInMs      int  `json:"max_wait_time_in_ms,omitempty" config:"max_wait_time_in_ms" elastic_mapping:"max_wait_time_in_ms:{type:keyword}"`
		MaxBytesPerNode      int  `json:"max_bytes_per_node,omitempty" config:"max_bytes_per_node" elastic_mapping:"max_bytes_per_node:{type:keyword}"`
		MaxQpsPerNode        int  `json:"max_qps_per_node,omitempty" config:"max_qps_per_node" elastic_mapping:"max_qps_per_node:{type:keyword}"`
	} `config:"traffic_control" json:"traffic_control,omitempty" elastic_mapping:"traffic_control:{type:object}"`

	Discovery struct {
		Enabled bool     `json:"enabled,omitempty" config:"enabled"`
		Modules []string `json:"module,omitempty" config:"module"`
		Refresh struct {
			Enabled  bool   `json:"enabled,omitempty" config:"enabled"`
			Interval string `json:"interval,omitempty" config:"interval"`
		} `json:"refresh,omitempty" config:"refresh"`
	} `json:"discovery,omitempty" config:"discovery"`

	Order int `json:"order,omitempty" elastic_mapping:"order:{type:integer}"`

	Schema string `json:"schema,omitempty" elastic_mapping:"schema:{type:keyword}"`

	Host  string   `json:"host,omitempty" elastic_mapping:"host:{type:keyword,copy_to:search_text}"`
	Hosts []string `json:"hosts,omitempty" elastic_mapping:"hosts:{type:keyword}"`

	GeoLocation *GeoLocation `json:"location,omitempty" elastic_mapping:"location:{type:object}"`

	Project string `json:"project,omitempty" elastic_mapping:"project:{type:keyword,copy_to:search_text}"`

	Owner []struct {
		Department string `json:"department,omitempty" elastic_mapping:"department:{type:keyword,copy_to:search_text}"`
		Name       string `json:"name,omitempty" elastic_mapping:"name:{type:keyword,copy_to:search_text}"`
		ID         string `json:"id,omitempty" elastic_mapping:"id:{type:keyword}"`
	} `json:"owner,omitempty" elastic_mapping:"owner:{type:object}"`
	Labels          util.MapStr     `json:"labels,omitempty"`
	Tags            []string        `json:"tags,omitempty" elastic_mapping:"tags:{type:keyword,copy_to:search_text}"`
	SearchText      string          `` /* 138-byte string literal not displayed */
	MaxCachedSize   int64           `json:"max_cached_size,omitempty" elastic_mapping:"max_cached_size:{type:integer}"`
	MetadataConfigs *MetadataConfig `config:"metadata_configs" json:"metadata_configs,omitempty" elastic_mapping:"metadata_configs:{type:object}"`
	ClusterUUID     string          `json:"cluster_uuid,omitempty" elastic_mapping:"cluster_uuid:{type:keyword}"`
	RawName         string          `json:"raw_name,omitempty" elastic_mapping:"raw_name:{type:keyword}"`
	CredentialID    string          `json:"credential_id,omitempty" elastic_mapping:"credential_id:{type:keyword}"`

	//TODO merge to cluster settings
	AgentCredentialID string           `json:"agent_credential_id,omitempty" elastic_mapping:"agent_credential_id:{type:keyword}"`
	AgentBasicAuth    *model.BasicAuth `config:"agent_basic_auth" json:"agent_basic_auth,omitempty" elastic_mapping:"agent_basic_auth:{type:object}"`

	Distribution          string `json:"distribution,omitempty" elastic_mapping:"distribution:{type:keyword}"`
	NoDefaultAuthForAgent bool   `json:"no_default_auth_for_agent,omitempty" config:"no_default_auth_for_agent"`
	MetricCollectionMode  string `json:"metric_collection_mode,omitempty" elastic_mapping:"metric_collection_mode:{type:keyword}"`
}

type ElasticsearchMetadata struct {
	Config *ElasticsearchConfig

	ClusterState *ClusterState

	NodesTopologyVersion int

	Nodes *map[string]NodesInfo

	IndexSettings map[string]*util.MapStr

	//PrimaryShards *map[string]map[int]ShardInfo
	Aliases *map[string]AliasInfo
	Health  *ClusterHealth

	IsAgentMode bool
	// contains filtered or unexported fields
}

type ErrorDetail struct {
	RootCause []RootCause `json:"root_cause,omitempty"`
	Type      string      `json:"type,omitempty"`
	Reason    string      `json:"reason,omitempty"`
}

type ErrorResponse struct {
	Status    int         `json:"status,omitempty"`
	RootCause interface{} `json:"root_cause,omitempty"`
	Error     *struct {
		Type   string `json:"type,omitempty"`
		Reason string `json:"reason,omitempty"`
	} `json:"error,omitempty"`
}

type EventAction string

type FieldCap struct {
	Type         string   `json:"type"`
	Searchable   bool     `json:"searchable"`
	Aggregatable bool     `json:"aggregatable"`
	Indices      []string `json:"indices"`
}

type FieldCapsResponse struct {
	Indices []string                       `json:"indices"`
	Fields  map[string]map[string]FieldCap `json:"fields"`
}

type GeoLocation struct {
	Provider string `json:"provider,omitempty" elastic_mapping:"provider:{type:keyword}"`
	Region   string `json:"region,omitempty" elastic_mapping:"region:{type:keyword}"`
	DC       string `json:"dc,omitempty" elastic_mapping:"dc:{type:keyword}"`
	Rack     string `json:"rack,omitempty" elastic_mapping:"rack:{type:keyword}"`
}

type GetResponse struct {
	ResponseBase
	Found   bool                   `json:"found"`
	Index   string                 `json:"_index"`
	Type    string                 `json:"_type"`
	ID      string                 `json:"_id"`
	Version int                    `json:"_version"`
	Source  map[string]interface{} `json:"_source"`
}

type HostMetadata struct {
	ID        string    `json:"id,omitempty"      elastic_meta:"_id" elastic_mapping:"id: { type: keyword }"`
	Timestamp time.Time `json:"timestamp,omitempty" elastic_mapping:"timestamp: { type: date }"`
	ClusterID string    `json:"cluster_id" elastic_mapping:"cluster_id:{type:keyword}"`
	NodeID    string    `json:"node_id" elastic_mapping:"node_id:{type:keyword}"`
	Metadata  struct {
		Host string                 `json:"host" elastic_mapping:"host:{type:keyword}"`
		IPs  []string               `json:"ips" elastic_mapping:"ips:{type:keyword}"`
		OS   map[string]interface{} `json:"os" elastic_mapping:"os:{type:object,enabled:false}"`
	} `json:"metadata" elastic_mapping:"metadata:{type:object}"`
}

type IndexConfig struct {
	ID         string        `json:"id,omitempty"      elastic_meta:"_id" elastic_mapping:"id: { type: keyword }"`
	Timestamp  time.Time     `json:"timestamp,omitempty" elastic_mapping:"timestamp: { type: date }"`
	Metadata   IndexMetadata `json:"metadata"`
	Fields     util.MapStr   `json:"payload" elastic_mapping:"payload:{type:object,enabled:false}"`
	SearchText string        `` /* 138-byte string literal not displayed */
}

type IndexDocument struct {
	Index     string                   `json:"_index,omitempty"`
	Type      string                   `json:"_type,omitempty"`
	ID        string                   `json:"_id,omitempty"`
	Routing   string                   `json:"_routing,omitempty"`
	Source    map[string]interface{}   `json:"_source,omitempty"`
	Highlight map[string][]interface{} `json:"highlight,omitempty"`
}

type IndexInfo struct {
	ID            string `json:"id,omitempty"`
	Index         string `json:"index,omitempty"`
	Status        string `json:"status,omitempty"`
	Health        string `json:"health,omitempty"`
	Shards        int    `json:"shards,omitempty"`
	Replicas      int    `json:"replicas,omitempty"`
	DocsCount     int64  `json:"docs_count,omitempty"`
	DocsDeleted   int64  `json:"docs_deleted,omitempty"`
	SegmentsCount int64  `json:"segments_count,omitempty"`
	StoreSize     string `json:"store_size,omitempty"`
	PriStoreSize  string `json:"pri_store_size,omitempty"`
}

type IndexLevelStats struct {
	Docs struct {
		Count   int `json:"count"`
		Deleted int `json:"deleted"`
	} `json:"docs"`
	Store struct {
		SizeInBytes             int `json:"size_in_bytes"`
		TotalDataSetSizeInBytes int `json:"total_data_set_size_in_bytes"`
		ReservedInBytes         int `json:"reserved_in_bytes"`
	} `json:"store"`
	Indexing struct {
		IndexTotal           int  `json:"index_total"`
		IndexTimeInMillis    int  `json:"index_time_in_millis"`
		IndexCurrent         int  `json:"index_current"`
		IndexFailed          int  `json:"index_failed"`
		DeleteTotal          int  `json:"delete_total"`
		DeleteTimeInMillis   int  `json:"delete_time_in_millis"`
		DeleteCurrent        int  `json:"delete_current"`
		NoopUpdateTotal      int  `json:"noop_update_total"`
		IsThrottled          bool `json:"is_throttled"`
		ThrottleTimeInMillis int  `json:"throttle_time_in_millis"`
	} `json:"indexing"`
	Get struct {
		Total               int `json:"total"`
		TimeInMillis        int `json:"time_in_millis"`
		ExistsTotal         int `json:"exists_total"`
		ExistsTimeInMillis  int `json:"exists_time_in_millis"`
		MissingTotal        int `json:"missing_total"`
		MissingTimeInMillis int `json:"missing_time_in_millis"`
		Current             int `json:"current"`
	} `json:"get"`
	Search struct {
		OpenContexts        int `json:"open_contexts"`
		QueryTotal          int `json:"query_total"`
		QueryTimeInMillis   int `json:"query_time_in_millis"`
		QueryCurrent        int `json:"query_current"`
		FetchTotal          int `json:"fetch_total"`
		FetchTimeInMillis   int `json:"fetch_time_in_millis"`
		FetchCurrent        int `json:"fetch_current"`
		ScrollTotal         int `json:"scroll_total"`
		ScrollTimeInMillis  int `json:"scroll_time_in_millis"`
		ScrollCurrent       int `json:"scroll_current"`
		SuggestTotal        int `json:"suggest_total"`
		SuggestTimeInMillis int `json:"suggest_time_in_millis"`
		SuggestCurrent      int `json:"suggest_current"`
	} `json:"search"`
	Merges struct {
		Current                    int `json:"current"`
		CurrentDocs                int `json:"current_docs"`
		CurrentSizeInBytes         int `json:"current_size_in_bytes"`
		Total                      int `json:"total"`
		TotalTimeInMillis          int `json:"total_time_in_millis"`
		TotalDocs                  int `json:"total_docs"`
		TotalSizeInBytes           int `json:"total_size_in_bytes"`
		TotalStoppedTimeInMillis   int `json:"total_stopped_time_in_millis"`
		TotalThrottledTimeInMillis int `json:"total_throttled_time_in_millis"`
		TotalAutoThrottleInBytes   int `json:"total_auto_throttle_in_bytes"`
	} `json:"merges"`
	Refresh struct {
		Total                     int `json:"total"`
		TotalTimeInMillis         int `json:"total_time_in_millis"`
		ExternalTotal             int `json:"external_total"`
		ExternalTotalTimeInMillis int `json:"external_total_time_in_millis"`
		Listeners                 int `json:"listeners"`
	} `json:"refresh"`
	Flush struct {
		Total             int `json:"total"`
		Periodic          int `json:"periodic"`
		TotalTimeInMillis int `json:"total_time_in_millis"`
	} `json:"flush"`
	Warmer struct {
		Current           int `json:"current"`
		Total             int `json:"total"`
		TotalTimeInMillis int `json:"total_time_in_millis"`
	} `json:"warmer"`
	QueryCache struct {
		MemorySizeInBytes int `json:"memory_size_in_bytes"`
		TotalCount        int `json:"total_count"`
		HitCount          int `json:"hit_count"`
		MissCount         int `json:"miss_count"`
		CacheSize         int `json:"cache_size"`
		CacheCount        int `json:"cache_count"`
		Evictions         int `json:"evictions"`
	} `json:"query_cache"`
	Fielddata struct {
		MemorySizeInBytes int `json:"memory_size_in_bytes"`
		Evictions         int `json:"evictions"`
	} `json:"fielddata"`
	Completion struct {
		SizeInBytes int `json:"size_in_bytes"`
	} `json:"completion"`
	Segments struct {
		Count                     int   `json:"count"`
		MemoryInBytes             int   `json:"memory_in_bytes"`
		TermsMemoryInBytes        int   `json:"terms_memory_in_bytes"`
		StoredFieldsMemoryInBytes int   `json:"stored_fields_memory_in_bytes"`
		TermVectorsMemoryInBytes  int   `json:"term_vectors_memory_in_bytes"`
		NormsMemoryInBytes        int   `json:"norms_memory_in_bytes"`
		PointsMemoryInBytes       int   `json:"points_memory_in_bytes"`
		DocValuesMemoryInBytes    int   `json:"doc_values_memory_in_bytes"`
		IndexWriterMemoryInBytes  int   `json:"index_writer_memory_in_bytes"`
		VersionMapMemoryInBytes   int   `json:"version_map_memory_in_bytes"`
		FixedBitSetMemoryInBytes  int   `json:"fixed_bit_set_memory_in_bytes"`
		MaxUnsafeAutoIdTimestamp  int64 `json:"max_unsafe_auto_id_timestamp"`
		FileSizes                 struct {
		} `json:"file_sizes"`
	} `json:"segments"`
	Translog struct {
		Operations              int `json:"operations"`
		SizeInBytes             int `json:"size_in_bytes"`
		UncommittedOperations   int `json:"uncommitted_operations"`
		UncommittedSizeInBytes  int `json:"uncommitted_size_in_bytes"`
		EarliestLastModifiedAge int `json:"earliest_last_modified_age"`
	} `json:"translog"`
	RequestCache struct {
		MemorySizeInBytes int `json:"memory_size_in_bytes"`
		Evictions         int `json:"evictions"`
		HitCount          int `json:"hit_count"`
		MissCount         int `json:"miss_count"`
	} `json:"request_cache"`
	Recovery struct {
		CurrentAsSource      int `json:"current_as_source"`
		CurrentAsTarget      int `json:"current_as_target"`
		ThrottleTimeInMillis int `json:"throttle_time_in_millis"`
	} `json:"recovery"`
}

type IndexMetadata struct {
	ClusterID   string        `json:"cluster_id" elastic_mapping:"cluster_id:{type:keyword}"`
	IndexID     string        `json:"index_id" elastic_mapping:"index_id:{type:keyword}"` //cluster_id:index_name (some metrics not return index uuid of lower es version )
	IndexName   string        `json:"index_name" elastic_mapping:"index_name:{type:keyword,copy_to:search_text}"`
	ClusterName string        `json:"cluster_name" elastic_mapping:"cluster_name:{type:keyword,copy_to:search_text}"`
	Labels      util.MapStr   `json:"labels,omitempty"`
	Aliases     interface{}   `json:"aliases,omitempty" elastic_mapping:"aliases:{type:keyword,copy_to:search_text}"`
	Category    string        `json:"category,omitempty"`
	Tags        []interface{} `json:"tags,omitempty" elastic_mapping:"tags:{type:keyword,copy_to:search_text}"`
}

type IndexShardRouting struct {
	State          string      `json:"state"`
	Primary        bool        `json:"primary"`
	Node           string      `json:"node"`
	RelocatingNode interface{} `json:"relocating_node,omitempty"`
	Shard          int         `json:"shard"`
	Index          string      `json:"index"`
	Version        int         `json:"version"` //< v5.0

	//v5.0+ START
	RecoverySource *struct {
		Type string `json:"type"`
	} `json:"recovery_source,omitempty"`
	UnassignedInfo *struct {
		Reason           string    `json:"reason"`
		At               time.Time `json:"at"`
		Delayed          bool      `json:"delayed"`
		AllocationStatus string    `json:"allocation_status"`
	} `json:"unassigned_info,omitempty"`

	AllocationId *struct {
		Id string `json:"id"`
	} `json:"allocation_id,omitempty"`
}

type IndexStats struct {
	All struct {
		Primary struct {
			Store struct {
				SizeInBytes int64 `json:"size_in_bytes"`
			} `json:"store"`

			Segments struct {
				Count int `json:"count"`
			} `json:"segments"`

			Merges struct {
				Current int `json:"current"`
			} `json:"merges"`
		} `json:"primaries"`
	} `json:"_all"`
}

type IndicesStats struct {
	ResponseBase
	Nodes map[string]interface{} `json:"indices"`
}

type InsertResponse struct {
	ResponseBase
	Result  string `json:"result"`
	Index   string `json:"_index"`
	Type    string `json:"_type"`
	ID      string `json:"_id"`
	Version int    `json:"_version"`

	Shards struct {
		Total      int `json:"total" `
		Failed     int `json:"failed"`
		Successful int `json:"successful"`
	} `json:"_shards"` //es 2.x index api
}

type InternalError struct {
	Error  *ErrorDetail `json:"error,omitempty"`
	Status int          `json:"status,omitempty"`
}

type LocalNodeInfo struct {
	Enrolled    bool                `json:"enrolled,omitempty,nocopy"`   //whether this node is enrolled or not
	ClusterID   string              `json:"cluster_id,omitempty,nocopy"` //infini system assigned cluster id
	ClusterInfo *ClusterInformation `json:"cluster_info,omitempty,nocopy"`
	NodeUUID    string              `json:"node_id,omitempty,nocopy"`
	NodeInfo    *NodesInfo          `json:"node_info,omitempty,nocopy"`
	Status      string              `json:"status,omitempty,nocopy"`
}

type MappingAPI interface {
	GetMapping(copyAllIndexes bool, indexNames string) (string, int, *util.MapStr, error)
	UpdateMapping(indexName string, docType string, mappings []byte) ([]byte, error)
}

type MatchQuery struct {
	Match map[string]interface{} `json:"match,omitempty"`
}

type MetadataChangeEvent func(meta, oldMeta *ElasticsearchMetadata, action EventAction)

type MetadataConfig struct {
	HealthCheck           TaskConfig `json:"health_check"`
	ClusterSettingsCheck  TaskConfig `json:"cluster_settings_check"`
	MetadataRefresh       TaskConfig `json:"metadata_refresh"`
	NodeAvailabilityCheck TaskConfig `json:"node_availability_check"`
}

type MonitorConfig struct {
	ClusterHealth TaskConfig `json:"cluster_health"`
	ClusterStats  TaskConfig `json:"cluster_stats"`
	NodeStats     TaskConfig `json:"node_stats"`
	IndexStats    TaskConfig `json:"index_stats"`
}

type NodeAvailable struct {
	ClusterID string //TODO should be removed
	Host      string
	// contains filtered or unexported fields
}

type NodeConfig struct {
	ID         string       `json:"id,omitempty"      elastic_meta:"_id" elastic_mapping:"id: { type: keyword }"`
	Timestamp  time.Time    `json:"timestamp,omitempty" elastic_mapping:"timestamp: { type: date }"`
	Metadata   NodeMetadata `json:"metadata" elastic_mapping:"metadata: { type: object }"`
	Payload    NodePayload  `json:"payload" elastic_mapping:"payload:{type:object,enabled:false}"`
	SearchText string       `` /* 138-byte string literal not displayed */
}

type NodeMetadata struct {
	ClusterID   string      `json:"cluster_id" elastic_mapping:"cluster_id:{type:keyword}"`
	ClusterName string      `json:"cluster_name" elastic_mapping:"cluster_name:{type:keyword,copy_to:search_text}"`
	Host        string      `json:"host" elastic_mapping:"host:{type:keyword,copy_to:search_text}"`
	NodeID      string      `json:"node_id" elastic_mapping:"node_id:{type:keyword}"`
	NodeName    string      `json:"node_name" elastic_mapping:"node_name:{type:keyword,copy_to:search_text}"`
	Tags        []string    `json:"tags,omitempty" elastic_mapping:"tags:{type:keyword,copy_to:search_text}"`
	Labels      util.MapStr `json:"labels,omitempty"`
	Category    string      `json:"category,omitempty"`
}

type NodePayload struct {
	NodeInfo *NodesInfo `json:"node_state,omitempty" elastic_mapping:"node_state:{type:object,enabled:false}"`
}

type NodesInfo struct {
	Name    string `json:"name,omitempty,nocopy"`
	Version string `json:"version,omitempty,nocopy"`

	Http struct {
		BoundAddress            []string `json:"bound_address"`
		PublishAddress          string   `json:"publish_address,omitempty"`
		MaxContentLengthInBytes int64    `json:"max_content_length_in_bytes,omitempty"`
	} `json:"http,omitempty"`

	Attributes map[string]interface{} `json:"attributes,omitempty"`
	Roles      []string               `json:"roles,omitempty"`

	TransportAddress string `json:"transport_address"`
	Host             string `json:"host"`
	Ip               string `json:"ip"`

	BuildFlavor string `json:"build_flavor"`
	BuildType   string `json:"build_type"`
	BuildHash   string `json:"build_hash"`

	TotalIndexingBuffer int64 `json:"total_indexing_buffer,omitempty"`

	Settings map[string]interface{} `json:"settings"`
	Os       map[string]interface{} `json:"os"`
	Process  struct {
		RefreshIntervalInMillis int  `json:"refresh_interval_in_millis"`
		Id                      int  `json:"id"`
		Mlockall                bool `json:"mlockall"`
	} `json:"process"`
	Jvm        map[string]interface{} `json:"jvm"`
	ThreadPool map[string]interface{} `json:"thread_pool"`
	Transport  struct {
		BoundAddress   []string `json:"bound_address"`
		PublishAddress string   `json:"publish_address"`
		Profiles       struct {
		} `json:"profiles"`
	} `json:"transport"`

	Plugins      []interface{}            `json:"plugins"`
	Modules      []map[string]interface{} `json:"modules"`
	Ingest       map[string]interface{}   `json:"ingest"`
	Aggregations map[string]interface{}   `json:"aggregations"`
}

type NodesResponse struct {
	NodesCount  map[string]interface{} `json:"_nodes"`
	ClusterName string                 `json:"cluster_name"`
	Nodes       map[string]NodesInfo   `json:"nodes"`
}

type NodesStats struct {
	ResponseBase
	Nodes map[string]interface{} `json:"nodes"`
}

type PartitionInfo struct {
	Key    float64                `json:"key"`
	Start  float64                `json:"start"`
	End    float64                `json:"end"`
	Filter map[string]interface{} `json:"filter"`
	Docs   int64                  `json:"docs"`
	Other  bool
}

type PartitionQuery struct {
	IndexName string      `json:"index_name"`
	FieldType string      `json:"field_type"`
	FieldName string      `json:"field_name"`
	Step      interface{} `json:"step"`
	Filter    interface{} `json:"filter"`
	DocType   string      `json:"doc_type"`
}

type Query struct {
	BoolQuery *BoolQuery `json:"bool"`
}

type QueryStringQuery struct {
	Query map[string]interface{} `json:"query_string,omitempty"`
}

type RangeQuery struct {
	Range map[string]map[string]interface{} `json:"range,omitempty"`
}

type ReindexResponse struct {
	Task string `json:"task"`
}

type ReplicationAPI interface {
	StartReplication(followIndex string, body []byte) error
	StopReplication(indexName string, body []byte) error
	PauseReplication(followIndex string, body []byte) error
	ResumeReplication(followIndex string, body []byte) error
	GetReplicationStatus(followIndex string) ([]byte, error)
	GetReplicationFollowerStats(followIndex string) ([]byte, error)
	CreateAutoFollowReplication(autoFollowPatternName string, body []byte) error
	GetAutoFollowStats(autoFollowPatternName string) ([]byte, error)
	DeleteAutoFollowReplication(autoFollowPatternName string, body []byte) error
}

type ResponseBase struct {
	RawResult   *util.Result `json:"-"`
	StatusCode  int          `json:"-"`
	ErrorObject error        `json:"-"`
	InternalError
}

type RetryRule struct {
	//response
	Status  []int    `config:"status"`
	Keyword []string `config:"keyword"`
}

type RetryRules struct {
	//Retry3xx        bool     `config:"retry_3xx"`
	Retry4xx bool `config:"retry_4xx"`
	Retry429 bool `config:"retry_429"`

	Default bool `config:"default"`

	Permitted RetryRule `config:"permitted"`
	Denied    RetryRule `config:"denied"`
}

type RootCause struct {
	Type   string `json:"type,omitempty"`
	Reason string `json:"reason,omitempty"`
}

type ScriptAPI interface {
	ScriptExists(scriptName string) (bool, error)
	PutScript(scriptName string, script []byte) ([]byte, error)
	SearchByTemplate(indexName, scriptName string, params map[string]interface{}) (*SearchResponse, error)
}

type ScrollAPI interface {
	NewScroll(indexNames string, scrollTime string, docBufferCount int, query *SearchRequest, slicedId, maxSlicedCount int) ([]byte, error)
	NextScroll(ctx *APIContext, scrollTime string, scrollId string) ([]byte, error)
	ClearScroll(scrollId string) error
}

type ScrollResponse struct {
	Took     int    `json:"took,omitempty"`
	ScrollId string `json:"_scroll_id,omitempty,nocopy"`
	TimedOut bool   `json:"timed_out,omitempty"`
	Hits     struct {
		MaxScore float32         `json:"max_score,omitempty"`
		Total    int64           `json:"total,omitempty"`
		Docs     []IndexDocument `json:"hits,omitempty"`
	} `json:"hits"`
	Shards ShardResponse `json:"_shards,omitempty"`
}

type ScrollResponseAPI interface {
	GetScrollId() string
	SetScrollId(id string)
	GetHitsTotal() int64
	GetShardResponse() ShardResponse
	GetDocs() []IndexDocument
}

type ScrollResponseV7 struct {
	Took     int    `json:"took,omitempty"`
	ScrollId string `json:"_scroll_id,omitempty,nocopy"`
	TimedOut bool   `json:"timed_out,omitempty"`
	Hits     struct {
		MaxScore float32 `json:"max_score,omitempty"`
		Total    struct {
			Value    int64  `json:"value,omitempty"`
			Relation string `json:"relation,omitempty"`
		} `json:"total,omitempty"`
		Docs []IndexDocument `json:"hits,omitempty"`
	} `json:"hits"`
	Shards ShardResponse `json:"_shards,omitempty"`
}

type SearchAggParam struct {
	Field          string      `json:"field"`
	TermsAggParams util.MapStr `json:"params"`
}

type SearchFilterParam map[string][]string

type SearchHighlightParam struct {
	Fields           []string `json:"fields"`
	FragmentSize     int      `json:"fragment_size"`
	NumberOfFragment int      `json:"number_of_fragment"`
}

type SearchRequest struct {
	Query *Query `json:"query,omitempty"`
	From  int    `json:"from"`
	Size  int    `json:"size"`

	Collapse *Collapse `json:"collapse,omitempty"`

	Sort               *[]interface{}      `json:"sort,omitempty"`
	Source             interface{}         `json:"_source,omitempty"`
	AggregationRequest *AggregationRequest `json:"aggs,omitempty"`
	// contains filtered or unexported fields
}

type SearchResponse struct {
	ResponseBase
	Took     int  `json:"took"`
	TimedOut bool `json:"timed_out"`
	Hits     struct {
		Total    interface{}     `json:"total"`
		MaxScore float32         `json:"max_score"`
		Hits     []IndexDocument `json:"hits,omitempty"`
	} `json:"hits"`
	Aggregations map[string]AggregationResponse `json:"aggregations,omitempty"`
}

type SearchTemplate struct {
	ID        string    `json:"-" index:"id"`
	Name      string    `json:"name" elastic_mapping:"name:{type:text}"`
	Source    string    `json:"source" elastic_mapping:"source:{type:text}"`
	ClusterID string    `json:"cluster_id" elastic_mapping:"cluster_id:{type:keyword}"`
	Created   time.Time `json:"created,omitempty" elastic_mapping:"created:{type:date}"`
	Updated   time.Time `json:"updated,omitempty" elastic_mapping:"updated:{type:date}"`
}

type SearchTemplateHistory struct {
	ID         string                 `json:"-" index:"id"`
	TemplateID string                 `json:"template_id" elastic_mapping:"template_id:{type:keyword}"`
	Action     string                 `json:"action" elastic_mapping:"action:{type:keyword}"`
	Content    map[string]interface{} `json:"content,omitempty" elastic_mapping:"content:{type:object}"`
	Created    time.Time              `json:"created,omitempty" elastic_mapping:"created:{type:date}"`
}

type SecurityAPI interface {
	GetUser(username string) ([]byte, error)
	GetUsers() ([]byte, error)
	DeleteUser(username string) error
	PutUser(username string, body []byte) error
	GetRole(roleName string) ([]byte, error)
	GetRoles() ([]byte, error)
	DeleteRole(roleName string) error
	PutRole(roleName string, body []byte) error
	GetPrivileges() ([]byte, error)
}

type Setting struct {
	ID        string    `json:"-" index:"id"`
	ClusterID string    `json:"cluster_id" elastic_mapping:"cluster_id:{type:keyword}"`
	Key       string    `json:"key" elastic_mapping:"key:{type:keyword}"`
	Value     string    `json:"value" elastic_mapping:"value:{type:keyword}"`
	UpdatedAt time.Time `json:"updated_at,omitempty" elastic_mapping:"updated_at:{type:date}"`
}

type ShardInfo struct {
	Index            string `json:"index,omitempty"`
	ShardID          string `json:"shard_id,omitempty"`
	Primary          bool   `json:"primary,omitempty"`
	State            string `json:"state,omitempty"`
	UnassignedReason string `json:"unassigned_reason,omitempty"`
	Docs             int64  `json:"docs_count,omitempty"`
	Store            string `json:"store_size,omitempty"`
	NodeID           string `json:"node_id,omitempty"`
	NodeName         string `json:"node_name,omitempty"`
	NodeIP           string `json:"node_ip,omitempty"`
}

type ShardResponse struct {
	Total      int `json:"total,omitempty"`
	Successful int `json:"successful,omitempty"`
	Skipped    int `json:"skipped,omitempty"`
	Failed     int `json:"failed,omitempty"`
	Failures   []struct {
		Shard  int             `json:"shard,omitempty"`
		Index  string          `json:"index,omitempty,intern"`
		Status int             `json:"status,omitempty"`
		Reason json.RawMessage `json:"reason,omitempty,nocopy"`
	} `json:"failures,omitempty"`
}

type Stats struct {
	All struct {
		Primaries IndexLevelStats `json:"primaries"`
		Total     IndexLevelStats `json:"total"`
	} `json:"_all"`

	Indices map[string]struct {
		Uuid      string          `json:"uuid"` //v7.0+
		Primaries IndexLevelStats `json:"primaries"`
		Total     IndexLevelStats `json:"total"`
	} `json:"indices"`
}

type TaskConfig struct {
	Enabled  bool   `json:"enabled"`
	Interval string `json:"interval"`
}

type TemplateAPI interface {
	TemplateExists(scriptName string) (bool, error)
	PutTemplate(scriptName string, template []byte) ([]byte, error)
	GetTemplate(scriptName string) (map[string]interface{}, error)
	SearchByTemplate(indexName, scriptName string, params map[string]interface{}) (*SearchResponse, error)
}

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

type TermsQuery struct {
	Match map[string][]interface{} `json:"terms,omitempty"`
}

type TraceMeta struct {
	TraceID   bool   `json:"trace_id" elastic_mapping:"trace_id:{type:keyword}"`
	Index     string `json:"index" elastic_mapping:"index:{type:keyword}"`
	ClusterID string `json:"cluster_id" elastic_mapping:"cluster_id:{type:keyword}"`
}

type TraceTemplate struct {
	ID             string    `json:"-" index:"id"`
	Name           string    `json:"name" elastic_mapping:"name:{type:text}"`
	MetaIndex      string    `json:"meta_index" elastic_mapping:"meta_index:{type:keyword}"`
	TraceField     string    `json:"trace_field" elastic_mapping:"trace_field:{type:keyword}"`
	TimestampField string    `json:"timestamp_field" elastic_mapping:"timestamp_field:{type:keyword}"`
	AggField       string    `json:"agg_field" elastic_mapping:"agg_field:{type:keyword}"`
	Description    string    `json:"description" elastic_mapping:"description:{type:text}"`
	ClusterID      string    `json:"cluster_id" elastic_mapping:"cluster_id:{type:keyword}"`
	Created        time.Time `json:"created,omitempty" elastic_mapping:"created:{type:date}"`
	Updated        time.Time `json:"updated,omitempty" elastic_mapping:"updated:{type:date}"`
}

type UpdateByQueryResponse struct {
	Updated  int64         `json:"updated"`
	Total    int64         `json:"total"`
	Failures []interface{} `json:"failures"`
}

type Version struct {
	Number       string
	Major        int
	Distribution string
}

type VersionInfo struct {
	Path           string `json:"path"`
	Index          string `json:"_index"`
	ID             string `json:"_id"`
	Version        int64  `json:"_version"`
	PrimaryTerm    int64  `json:"_primary_term"`
	SequenceNumber int64  `json:"_seq_no"`
	Status         int64  `json:"status"`

	Payload [][]byte `json:"-"` //request

	Time              time.Time    //Not record time, but local access time
	DocOffset         int          `json:"doc_offset,omitempty"`
	MessageOffset     string       `json:"msg_offset,omitempty"`
	ThisMessageOffset queue.Offset `json:"this_msg_offset,omitempty"`
	ReplicationID     string       `json:"replication_id,omitempty"`
	MessageTime       time.Time
}

type View struct {
	ID              string    `json:"-" elastic_meta:"_id" elastic_mapping:"id: { type: keyword }"`
	ClusterID       string    `json:"cluster_id" elastic_mapping:"cluster_id:{type:keyword}"`
	Title           string    `json:"title" elastic_mapping:"title:{type:keyword}"`
	ViewName        string    `json:"viewName" elastic_mapping:"view_name:{type:text}`
	TimeFieldName   string    `json:"timeFieldName" elastic_mapping:"timeFieldName:{type:keyword}"`
	Fields          string    `json:"fields" elastic_mapping:"fields:{type:text}"`
	FieldFormatMap  string    `json:"fieldFormatMap" elastic_mapping:"fields:{type:text}`
	UpdatedAt       time.Time `json:"updated_at,omitempty" elastic_mapping:"updated_at:{type:date}"`
	DefaultLayoutID string    `json:"default_layout_id" elastic_mapping:"default_layout_id:{type:keyword}"`
	ComplexFields   string    `json:"complex_fields" elastic_mapping:"complex_fields:{type:text}"`
	//determine if this view is built-in
	Builtin bool `json:"builtin" elastic_mapping:"builtin:{type:boolean}"`
}

type ViewRequest struct {
	Attributes View `json:"attributes"`
}