ukafka

type ClusterSet struct {
	Zone string

	ClusterInstanceId string

	ClusterInstanceName string

	Framework string

	FrameworkVersion string

	Remark string

	CreateTime int

	RunningTime int
	ExpireTime  int

	AutoRenew string

	ChargeType string

	UHostCount int

	UHostSet []UHostSet

	RedundantCount int

	State string

	Tag string

	NewMessage string
	// 所在的VPC的ID
	VPCId string

	// 为 InnerMode 时，ULB 所属的子网ID，默认为空
	SubnetId string

	// 所属的业务组ID
	BusinessId string
}

type ConsumersGroups struct {
	GroupName string

	Type string

	NumOfTopics int
}

type DescribeUKafkaInstance struct {
	request.CommonBase

	ClusterInstanceId *string `required:"true"`

	Filter *string `required:"false"`
}

type DescribeUKafkaInstanceResponse struct {
	response.CommonBase

	ClusterSet []ClusterSet
}

type GetShockwaveMetricRequest struct {
	request.CommonBase

	// 资源类型
	ResourceType *string `required:"true"`

	// 指标名称（不同ResourceType对应不同的MetricName）
	MetricName []string `required:"true"`

	// 资源Id（目前除sharebandwidth可以不传入ResourceId外，其他资源必须传入，sharebandwidth不传入会默认使用获取到的第一个资源Id）
	ResourceId []string `required:"true"`

	// 拉取最近多少秒的监控数据，默认1小时，即3600；最大1个月
	TimeRange *int `required:"false"`

	DistrictType *string `required:"true"`

	PublicIP []string `required:"true"`
}

type GetShockwaveMetricResponse struct {
	response.CommonBase

	DataSet []MetricItemSet
}

type IPSet struct {
	IP   string
	Type string
}

type ListUKafkaConsumers struct {
	request.CommonBase

	ClusterInstanceId *string `required:"true"`
}

type ListUKafkaConsumersResponse struct {
	response.CommonBase

	TotalCount int

	Groups []ConsumersGroups
}

type ListUKafkaInstance struct {
	request.CommonBase

	// 数据偏移量，默认为0
	Offset *int `required:"false"`

	// 数据分页值，默认为20
	Limit *int `required:"false"`

	ClusterInstanceId *string `required:"true"`

	Filter *string `required:"false"`
	VPCId  *string `required:"false"`

	SubnetId *string `required:"false"`

	BusinessId *string `required:"false"`
}

type ListUKafkaInstanceResponse struct {
	response.CommonBase

	TotalCount int

	ClusterSet []ClusterSet
}

type MetricItem struct {
	Value interface{}

	Timestamp    int
	DistrictName string
	IspName      string
}

type MetricItemSet struct {
	MetricName  string
	Granularity int
	MetricData  []MetricItem
}

type PartitionsInfo struct {
	Consumer      string
	CurrentOffset int64

	LogEndOffset int64
	Lag          int
	// contains filtered or unexported fields
}

type TopicsInfo struct {
	TotalLag   int
	Partitions map[string]*PartitionsInfo
	//LogPer               float64
	//PartitionAssignedPer int
	LastUpdateTime int
	TopicName      string
}

type UHostConfig struct {
	BootDiskSize int
	CPU          int
	DataDiskSize int
	Memory       int
	OS           string
}

type UHostSet struct {
	BrokerId          string
	UHostId           string
	ResourceId        string
	UHostRole         string
	UHostName         string
	DomainName        string
	Remark            string
	InstanceGroupType string

	UHostConfig map[string]UHostConfig

	IPSet []IPSet
	State string
}

type UKafkaClient struct {
	*ucloud.Client
}

type UKafkaConsumers struct {
	request.CommonBase

	ClusterInstanceId *string `required:"true"`

	ConsumerGroup *string `required:"true"`

	Type *string `required:"true"`
}

type UKafkaConsumersResponse struct {
	response.CommonBase

	GroupName string
	Type      string

	Topics []*TopicsInfo
}