ckafka

type AddPartitionResp struct {
	Code     int64         `json:"code"`
	CodeDesc string        `json:"codeDesc"`
	Data     []interface{} `json:"data"`
	Message  string        `json:"message"`
}

type AddTopicIpWhitelistResp struct {
	Code     int64         `json:"code"`
	CodeDesc string        `json:"codeDesc"`
	Data     []interface{} `json:"data"`
	Message  string        `json:"message"`
}

type CkafkaClient struct {
	*core.Client
}

type CreateTopicResp struct {
	Code     int64  `json:"code"`
	CodeDesc string `json:"codeDesc"`
	Data     struct {
		TopicID string `json:"topicId"`
	} `json:"data"`
	Message string `json:"message"`
}

type DeleteTopicIpWhitelistResp struct {
	Code     int64         `json:"code"`
	CodeDesc string        `json:"codeDesc"`
	Data     []interface{} `json:"data"`
	Message  string        `json:"message"`
}

type DeleteTopicResp struct {
	Code     int64         `json:"code"`
	CodeDesc string        `json:"codeDesc"`
	Data     []interface{} `json:"data"`
	Message  string        `json:"message"`
}

type GetInstanceAttributesResp struct {
	Code     int64  `json:"code"`
	CodeDesc string `json:"codeDesc"`
	Data     struct {
		Bandwidth        int64  `json:"bandwidth"`
		CreateTime       int64  `json:"createTime"`
		DiskSize         int64  `json:"diskSize"`
		ExpireTime       int64  `json:"expireTime"`
		InstanceID       string `json:"instanceId"`
		InstanceName     string `json:"instanceName"`
		MsgRetentionTime int64  `json:"msgRetentionTime"`
		Status           int64  `json:"status"`
		SubnetID         string `json:"subnetId"`
		Vip              string `json:"vip"`
		VipList          []struct {
			Vip   string `json:"vip"`
			Vport string `json:"vport"`
		} `json:"vipList"`
		VpcID  string `json:"vpcId"`
		Vport  string `json:"vport"`
		ZoneID int64  `json:"zoneId"`
	} `json:"data"`
	Message string `json:"message"`
}

type GetTopicAttributesResp struct {
	Code     int64  `json:"code"`
	CodeDesc string `json:"codeDesc"`
	Data     struct {
		CreateTime      int64         `json:"createTime"`
		EnableWhiteList int64         `json:"enableWhiteList"`
		IPWhiteList     []interface{} `json:"ipWhiteList"`
		PartitionNum    int64         `json:"partitionNum"`
		Partitions      []struct {
			IsrNum       int64 `json:"isrNum"`
			LeaderStatus int64 `json:"leaderStatus"`
			Partition    int64 `json:"partition"`
			ReplicaNum   int64 `json:"replicaNum"`
		} `json:"partitions"`
		TopicID string `json:"topicId"`
	} `json:"data"`
	Message string `json:"message"`
}

type ListInstanceResp struct {
	Code     int64  `json:"code"`
	CodeDesc string `json:"codeDesc"`
	Data     struct {
		InstanceList []struct {
			InstanceID   string `json:"instanceId"`
			InstanceName string `json:"instanceName"`
			Status       int64  `json:"status"`
		} `json:"instanceList"`
		TotalCount int64 `json:"totalCount"`
	} `json:"data"`
	Message string `json:"message"`
}

type ListTopicResp struct {
	Code     int64  `json:"code"`
	CodeDesc string `json:"codeDesc"`
	Data     struct {
		TopicList []struct {
			TopicID   string `json:"topicId"`
			TopicName string `json:"topicName"`
		} `json:"topicList"`
		TotalCount int64 `json:"totalCount"`
	} `json:"data"`
	Message string `json:"message"`
}

type SetInstanceAttributesResp struct {
	Code     int64  `json:"code"`
	CodeDesc string `json:"codeDesc"`
	Message  string `json:"message"`
}

type SetTopicAttributesResp struct {
	Code     int64         `json:"code"`
	CodeDesc string        `json:"codeDesc"`
	Data     []interface{} `json:"data"`
	Message  string        `json:"message"`
}