elasticsearch

type Client interface {
	GetNodeStats(ctx context.Context) (*NodeStats, error)
	GetIndexSettings(ctx context.Context, indexName string) (*IndexSettings, error)
	GetIndexHealth(ctx context.Context, indexName string) (*IndexHealth, error)
	UpdateIndexReplicaNum(ctx context.Context, indexName string, replicaNum int) error
}

type IndexHealth struct {
	ClusterName                 string  `json:"cluster_name"`
	Status                      string  `json:"status"`
	NumberOfNodes               int     `json:"number_of_nodes"`
	NumberOfDataNodes           int     `json:"number_of_data_nodes"`
	ActivePrimaryShards         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 int     `json:"task_max_waiting_in_queue_millis"`
	ActiveShardsPercentAsNumber float64 `json:"active_shards_percent_as_number"`
}

type IndexSettings struct {
	ShardNum   int `json:"number_of_shards,string"`
	ReplicaNum int `json:"number_of_replicas,string"`
}

type NodeStats struct {
	Nodes map[string]*NodeStatsNode `json:"nodes"`
}

type NodeStatsNode struct {
	ID    string           `json:"-"`
	Roles []string         `json:"roles"`
	OS    *NodeStatsNodeOS `json:"os"`
}

type NodeStatsNodeOS struct {
	CPU *NodeStatsNodeOSCPU `json:"cpu"`
}

type NodeStatsNodeOSCPU struct {
	Percent float64 `json:"percent"`
}

type NodeStatsNodes []*NodeStatsNode