es

type BaseES struct {
	ClusterVersion string
	Addresses      []string
	User           string
	Password       string

	ActionRuleMap map[RequestActionType]*UriParserRule
	MethodRuleMap map[MethodType][]*MatchRule

	Settings IESSettings
}

type BulkRequestItem struct {
	ActionType string
	Metadata   map[string]interface{}
	Document   map[string]interface{}
}

type BulkResponse struct {
	Items []map[string]BulkResponseItem `mapstructure:"items"`
}

type BulkResponseItem struct {
	Id     string `mapstructure:"_id"`
	Status int    `mapstructure:"status"`
}

type ClusterHealthRespV5 struct {
	ActivePrimaryShards         int     `json:"active_primary_shards"`
	ActiveShards                int     `json:"active_shards"`
	ActiveShardsPercentAsNumber float64 `json:"active_shards_percent_as_number"`
	ClusterName                 string  `json:"cluster_name"`
	DelayedUnassignedShards     int     `json:"delayed_unassigned_shards"`
	InitializingShards          int     `json:"initializing_shards"`
	NumberOfDataNodes           int     `json:"number_of_data_nodes"`
	NumberOfInFlightFetch       int     `json:"number_of_in_flight_fetch"`
	NumberOfNodes               int     `json:"number_of_nodes"`
	NumberOfPendingTasks        int     `json:"number_of_pending_tasks"`
	RelocatingShards            int     `json:"relocating_shards"`
	Status                      string  `json:"status"`
	TaskMaxWaitingInQueueMillis int     `json:"task_max_waiting_in_queue_millis"`
	TimedOut                    bool    `json:"timed_out"`
	UnassignedShards            int     `json:"unassigned_shards"`
}

type ClusterVersion struct {
	Name        string `json:"name,omitempty"`
	ClusterName string `json:"cluster_name,omitempty"`
	Version     struct {
		Number        string `json:"number,omitempty"`
		LuceneVersion string `json:"lucene_version,omitempty"`
	} `json:"version,omitempty"`
}

type Doc struct {
	Type   string                 `mapstructure:"_type" json:"_type"`
	ID     string                 `mapstructure:"_id" json:"_id"`
	Source map[string]interface{} `mapstructure:"_source" json:"_source"`
	Hash   uint64                 `mapstructure:"_hash" json:"_hash"`
	Op     Operation              `mapstructure:"_op" json:"_op"`
}

type DocTypeReservationType string

type ES interface {
	GetClusterVersion() string
	IndexExisted(index string) (bool, error)
	GetIndexes() ([]string, error)

	NewScroll(ctx context.Context, index string, option *ScrollOption) (*ScrollResult, error)
	NextScroll(ctx context.Context, scrollId string, scrollTime uint) (*ScrollResult, error)
	ClearScroll(scrollId string) error

	BulkBody(index string, buf *bytes.Buffer, doc *Doc) error
	Bulk(buf *bytes.Buffer) error

	GetIndexMappingAndSetting(index string) (IESSettings, error)

	CreateIndex(esSetting IESSettings) error
	DeleteIndex(index string) error

	Count(ctx context.Context, index string) (uint64, error)

	CreateTemplate(ctx context.Context, name string, body map[string]interface{}) error

	ClusterHealth(ctx context.Context) (map[string]interface{}, error)

	GetInfo(ctx context.Context) (map[string]interface{}, error)

	GetAddresses() []string

	GetUser() string

	GetPassword() string

	MatchRule(c *gin.Context) *UriPathParserResult

	MakeUri(c *gin.Context, uriPathParserResult *UriPathParserResult) (*UriPathMakeResult, error)

	GetSearchResponse(bodyMap map[string]interface{}) map[string]interface{}

	GetActionRuleMap() map[RequestActionType]*UriParserRule

	GetMethodRuleMap() map[MethodType][]*MatchRule

	IsWrite(requestActionType RequestActionType) bool

	Request(c *gin.Context, bodyBytes []byte, parserUriResult *UriPathParserResult) (map[string]interface{}, int, error)
}

type FixUnit struct {
	SourceESVersionRange *version.Constraints
	TargetESVersionRange *version.Constraints
	Actions              []string
	Callback             fixCallback
}

type IESSettings interface {
	ToESV5Setting() map[string]interface{}
	ToESV6Setting() map[string]interface{}
	ToESV7Setting() map[string]interface{}
	ToESV8Setting() map[string]interface{}

	ToESV5Mapping() map[string]interface{}
	ToESV6Mapping() map[string]interface{}
	ToESV7Mapping() map[string]interface{}
	ToESV8Mapping() map[string]interface{}

	ToTargetV5Settings(targetIndex string) *V5Settings
	ToTargetV6Settings(targetIndex string) *V6Settings
	ToTargetV7Settings(targetIndex string) *V7Settings
	ToTargetV8Settings(targetIndex string) *V8Settings

	ToV5TemplateSettings(pattern []string, order int) map[string]interface{}
	ToV6TemplateSettings(pattern []string, order int) map[string]interface{}
	ToV7TemplateSettings(pattern []string, order int) map[string]interface{}
	ToV8TemplateSettings(pattern []string, order int) map[string]interface{}

	GetIndex() string
	GetMappings() map[string]interface{}
	GetSettings() map[string]interface{}
	GetAliases() map[string]interface{}
	GetProperties() map[string]interface{}
	GetFieldMap() map[string]interface{}
}

type IResponse interface {
	String() string
	Status() string
}

type MatchRule struct {
	Method     MethodType
	UriPattern string
	Priority   int

	RequestActionType RequestActionType
}

type MethodType string

type Operation int

type RequestActionType string

type ScrollOption struct {
	Query      map[string]interface{}
	SortFields []string
	ScrollSize uint
	ScrollTime uint
	SliceId    *uint
	SliceSize  *uint
}

type ScrollResult struct {
	Total    uint64
	Docs     []*Doc
	ScrollId string
}

type ScrollResultV5 struct {
	Took     int    `json:"took,omitempty"`
	ScrollId string `json:"_scroll_id,omitempty"`
	TimedOut bool   `json:"timed_out,omitempty"`
	Hits     struct {
		MaxScore float32       `json:"max_score,omitempty"`
		Total    int           `json:"total,omitempty"`
		Docs     []interface{} `json:"hits,omitempty"`
	} `json:"hits"`
	Shards 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"`
			Status int         `json:"status,omitempty"`
			Reason interface{} `json:"reason,omitempty"`
		} `json:"failures,omitempty"`
	} `json:"_shards,omitempty"`
}

type ScrollResultV7 struct {
	Took     int    `json:"took,omitempty"`
	ScrollId string `json:"_scroll_id,omitempty"`
	TimedOut bool   `json:"timed_out,omitempty"`
	Hits     struct {
		MaxScore float32 `json:"max_score,omitempty"`
		Total    struct {
			Value    int    `json:"value,omitempty"`
			Relation string `json:"relation,omitempty"`
		} `json:"total,omitempty"`
		Docs []interface{} `json:"hits,omitempty"`
	} `json:"hits"`
	Shards struct {
		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"`
			Status int         `json:"status,omitempty"`
			Reason interface{} `json:"reason,omitempty"`
		} `json:"failures,omitempty"`
	} `json:"_shards,omitempty"`
}

type ScrollResultV8 struct {
	Took     int    `json:"took,omitempty"`
	ScrollId string `json:"_scroll_id,omitempty"`
	TimedOut bool   `json:"timed_out,omitempty"`
	Hits     struct {
		MaxScore *float32 `json:"max_score,omitempty"`
		Total    struct {
			Value    int    `json:"value,omitempty"`
			Relation string `json:"relation,omitempty"`
		} `json:"total,omitempty"`
		Docs []interface{} `json:"hits,omitempty"`
	} `json:"hits"`
	Shards 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"`
			Status int         `json:"status,omitempty"`
			Reason interface{} `json:"reason,omitempty"`
		} `json:"failures,omitempty"`
	} `json:"_shards,omitempty"`
}

type UriParserRule struct {
	MatchRules []*MatchRule
	IsWrite    bool
}

type UriPathMakeResult struct {
	Uri      string
	Method   MethodType
	Address  string
	User     string
	Password string
}

type UriPathParserResult struct {
	RequestAction RequestActionType
	VariableMap   map[string]string
}

type V0 struct {
	Config *config.ESConfig
}

type V5 struct {
	*elasticsearch5.Client
	*BaseES
}

type V5Settings struct {
	Settings map[string]interface{}
	Mappings map[string]interface{}
	Aliases  map[string]interface{}

	SourceIndex string
}

type V6 struct {
	*elasticsearch6.Client
	*BaseES
}

type V6Settings struct {
	*V5Settings
}

type V7 struct {
	*elasticsearch7.Client
	*BaseES
}

type V7Settings struct {
	*V6Settings
}

type V8 struct {
	*elasticsearch8.Client
	*BaseES
}

type V8Settings struct {
	*V7Settings
}