model

type AddNodeReq struct {
	Ips   []string `json:"ips" example:"192.168.0.1,192.168.0.2"`
	Shard int      `json:"shard" example:"3"`
}

type AlterCkTableParams struct {
	Name    string
	Cluster string
	DB      string
	Add     []CkTableNameTypeAfter
	Drop    []string
	Modify  []CkTableNameType
}

type AlterCkTableReq struct {
	Name   string                 `json:"name" example:"test_table"`
	DB     string                 `json:"database" example:"default"`
	Add    []CkTableNameTypeAfter `json:"add"`
	Modify []CkTableNameType      `json:"modify"`
	Drop   []string               `json:"drop" example:"age"`
}

type ArchiveTableReq struct {
	Database    string   `json:"database" example:"default"`
	Tables      []string `json:"tables" example:"t1,t2,t3"`
	Begin       string   `json:"begin" example:"2021-01-01"`
	End         string   `json:"end" example:"2021-04-01"`
	MaxFileSize int      `json:"maxfilesize" example:"10000000000"`
	HdfsAddr    string   `json:"hdfsaddr" example:"localhost:8020"`
	HdfsUser    string   `json:"hdfsuser" example:"hdfs"`
	HdfsDir     string   `json:"hdfsdir" example:"/data01"`
	Parallelism int      `json:"parallelism" example:"4"`
}

type CKManClickHouseConfig struct {
	Mode         string            `json:"mode"`
	Hosts        []string          `json:"hosts"`
	Port         int               `json:"port"`
	HttpPort     int               `json:"httpPort"`
	User         string            `json:"user"`
	Password     string            `json:"password"`
	Cluster      string            `json:"cluster"`
	ZkNodes      []string          `json:"zkNodes"`
	ZkPort       int               `json:"zkPort"`
	ZkStatusPort int               `json:"zkStatusPort"`
	IsReplica    bool              `json:"isReplica"`
	Version      string            `json:"version"`
	SshUser      string            `json:"sshUser"`
	SshPassword  string            `json:"sshPassword"`
	SshPort      int               `json:"sshPort"`
	Shards       []CkShard         `json:"shards"`
	Path         string            `json:"path"`
	ZooPath      map[string]string `json:"zooPath"`
}

type CkClusterInfoRsp struct {
	Status  string          `json:"status"`
	Version string          `json:"version"`
	Nodes   []CkClusterNode `json:"nodes"`
	Mode    string          `json:"mode"`
}

type CkClusterNode struct {
	Ip            string `json:"ip"`
	HostName      string `json:"hostname"`
	Status        string `json:"status"`
	ShardNumber   int    `json:"shardNumber"`
	ReplicaNumber int    `json:"replicaNumber"`
	Disk          string `json:"disk"`
}

type CkColumnAttribute struct {
	Name              string `json:"name"`
	Type              string `json:"type"`
	DefaultType       string `json:"defaultType"`
	DefaultExpression string `json:"defaultExpression"`
	Comment           string `json:"comment"`
	CodecExpression   string `json:"codecExpression"`
	TTLExpression     string `json:"ttlExpression"`
}

type CkDeployConfig struct {
	Path           string    `json:"path" example:"/data01/"`
	User           string    `json:"user" example:"ck"`
	Password       string    `json:"password" example:"123456"`
	ZkNodes        []string  `json:"zkNodes" example:"192.168.101.102,192.168.101.105,192.168.101.107"`
	ZkPort         int       `json:"zkPort" example:"2181"`
	ZkStatusPort   int       `json:"zkStatusPort" example:"8080"`
	ClusterName    string    `json:"clusterName" example:"test"`
	Shards         []CkShard `json:"shards"`
	PackageVersion string    `json:"packageVersion" example:"20.8.5.45"`
	CkTcpPort      int       `json:"ckTcpPort" example:"9000"`
	CkHttpPort     int       `json:"ckHttpPort" example:"8123"`
	IsReplica      bool      `json:"isReplica"`
}

type CkImportConfig struct {
	Hosts        []string `json:"hosts" example:"192.168.101.105,192.168.101.107"`
	Port         int      `json:"port" example:"9000"`
	HttpPort     int      `json:"httpPort" example:"8123"`
	User         string   `json:"user" example:"ck"`
	Password     string   `json:"password" example:"123456"`
	Cluster      string   `json:"cluster" example:"test"`
	ZkNodes      []string `json:"zkNodes" example:"192.168.101.102,192.168.101.105,192.168.101.107"`
	ZkPort       int      `json:"zkPort" example:"2181"`
	ZkStatusPort int      `json:"zkStatusPort" example:"8080"`
}

type CkReplica struct {
	Ip       string `json:"ip" example:"192.168.101.105"`
	HostName string `json:"hostname" swaggerignore:"true"`
}

type CkSessionInfo struct {
	StartTime     int64  `json:"startTime"`
	QueryDuration uint64 `json:"queryDuration"`
	Query         string `json:"query"`
	User          string `json:"user"`
	QueryId       string `json:"queryId"`
	Address       string `json:"address"`
	Threads       int    `json:"threads"`
}

type CkShard struct {
	Replicas []CkReplica `json:"replicas"`
}

type CkTableCost struct {
	Middle       float64 `json:"middle"`
	SecondaryMax float64 `json:"secondaryMax"`
	Max          float64 `json:"max"`
}

type CkTableMetrics struct {
	Columns          uint64      `json:"columns"`
	Rows             uint64      `json:"rows"`
	Parts            uint64      `json:"parts"`
	DiskSpace        uint64      `json:"-"`
	Space            string      `json:"space"`
	CompletedQueries uint64      `json:"completedQueries"`
	FailedQueries    uint64      `json:"failedQueries"`
	QueryCost        CkTableCost `json:"queryCost"`
}

type CkTableNameType struct {
	Name    string   `json:"name" example:"_timestamp"`
	Type    string   `json:"type" example:"DateTime"`
	Options []string `json:"options"` //example:["DEFAULT now()", "CODEC(NONE)"]
}

type CkTableNameTypeAfter struct {
	Name    string   `json:"name" example:"age"`
	Type    string   `json:"type" example:"Int32"`
	Options []string `json:"options"` //example:["DEFAULT now()", "CODEC(NONE)"]
	After   string   `json:"after" example:"_timestamp"`
}

type CkTablePartition struct {
	// 0 split partition by day
	// 1 split partition by week
	// 2 split partition by month
	Policy int    `json:"policy" example:"0"`
	Name   string `json:"name" example:"_timestamp"`
}

type CkUpgradeCk struct {
	PackageVersion string `json:"packageVersion"`
}

type CreateCkTableParams struct {
	Name      string
	Cluster   string
	Engine    string
	Fields    []CkTableNameType
	Order     []string
	Partition CkTablePartition
	DB        string
}

type CreateCkTableReq struct {
	Name      string            `json:"name" example:"test_table"`
	DB        string            `json:"database" example:"default"`
	Fields    []CkTableNameType `json:"fields"`
	Order     []string          `json:"order" example:"_timestamp"`
	Partition CkTablePartition  `json:"partition"`
	Distinct  bool              `json:"distinct" example:"true"`
}

type DeleteCkTableParams struct {
	Name    string
	Cluster string
	DB      string
}

type DeployCkReq struct {
	Hosts      []string       `json:"hosts" example:"192.168.101.105"`
	User       string         `json:"user" example:"root"`
	Password   string         `json:"password" example:"123456"`
	Port       int            `json:"sshPort" example:"22"`
	ClickHouse CkDeployConfig `json:"clickhouse"`
}

type DescCkTableParams struct {
	Name string
	DB   string
}

type LoginReq struct {
	Username string `json:"username" example:"ckman"`
	Password string `json:"password" example:"63cb91a2ceb9d4f7c8b1ba5e50046f52"`
}

type LoginRsp struct {
	Username string `json:"username" example:"ckman"`
	Token    string `json:"token" example:"eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9"`
}

type MetricQueryRangeReq struct {
	Title  string
	Metric string
	Start  int64
	End    int64
	Step   int64
}

type MetricQueryReq struct {
	Metric string
	Time   int64
}

type PingClusterReq struct {
	Database string `json:"database" example:"default"`
	User     string `json:"user" example:"ck"`
	Password string `json:"password" example:"123456"`
}

type PurgerTableReq struct {
	Database string   `json:"database" example:"default"`
	Tables   []string `json:"tables" example:"t1,t2,t3"`
	Begin    string   `json:"begin" example:"2021-01-01"`
	End      string   `json:"end" example:"2021-04-01"`
}

type ResponseBody struct {
	RetCode int         `json:"retCode"`
	RetMsg  string      `json:"retMsg"`
	Entity  interface{} `json:"entity"`
}

type SessionList []*CkSessionInfo

type UpdateConfigReq struct {
	Peers         []string `json:"peers" example:"192.168.21.74"`
	Prometheus    []string `json:"prometheus" example:"192.168.101.105:19090"`
	AlertManagers []string `json:"alertManagers" example:"192.168.101.105:19093"`
}

type ZkReplicatedTableStatus struct {
	Name   string     `json:"name"`
	Values [][]string `json:"values"`
}

type ZkReplicatedTableStatusRsp struct {
	Header [][]string                `json:"header"`
	Tables []ZkReplicatedTableStatus `json:"tables"`
}

type ZkStatusRsp struct {
	Host                string  `json:"host"`
	Version             string  `json:"version"`
	ServerState         string  `json:"server_state"`
	PeerState           string  `json:"peer_state"`
	AvgLatency          float64 `json:"avg_latency"`
	ApproximateDataSize float64 `json:"approximate_data_size"`
	ZnodeCount          float64 `json:"znode_count"`
}