cluster

type AclOperationType string

type AclPatternType string

type AclPermissionType string

type AclResourceType string

type ConfigOp string

type ConfluentClusterClient struct {
	BaseUrl   string
	ClusterId string
	// contains filtered or unexported fields
}

type KafkaAcl struct {
	common.BaseModel
	ClusterId    string            `json:"cluster_id,omitempty" url:"-"`
	ResourceType AclResourceType   `json:"resource_type,omitempty" url:"resource_type,omitempty"`
	ResourceName string            `json:"resource_name,omitempty" url:"resource_name,omitempty"`
	PatternType  AclPatternType    `json:"pattern_type,omitempty" url:"pattern_type,omitempty"`
	Principal    string            `json:"principal,omitempty" url:"principal,omitempty"`
	Host         string            `json:"host,omitempty" url:"host,omitempty"`
	Operation    AclOperationType  `json:"operation,omitempty" url:"operation,omitempty"`
	Permission   AclPermissionType `json:"permission,omitempty" url:"permission,omitempty"`
}

type KafkaAclCreateReq struct {
	ResourceType AclResourceType   `json:"resource_type,omitempty"`
	ResourceName string            `json:"resource_name,omitempty"`
	PatternType  AclPatternType    `json:"pattern_type,omitempty"`
	Principal    string            `json:"principal,omitempty"`
	Host         string            `json:"host,omitempty"`
	Operation    AclOperationType  `json:"operation,omitempty"`
	Permission   AclPermissionType `json:"permission,omitempty"`
}

type KafkaAclList struct {
	common.BaseModel
	Data []KafkaAcl `json:"data"`
}

type KafkaAclSearchQry struct {
	common.PaginationOptions
	ResourceType AclResourceType   `url:"resource_type,omitempty"`
	ResourceName string            `url:"resource_name,omitempty"`
	Principal    string            `url:"principal,omitempty"`
	Host         string            `url:"host,omitempty"`
	Operation    AclOperationType  `url:"operation,omitempty"`
	Permission   AclPermissionType `url:"permission,omitempty"`
	PatternType  AclPatternType    `url:"pattern_type,omitempty"`
}

type KafkaCluster struct {
	common.BaseModel
	ClusterId              string    `json:"cluster_id"`
	Controller             *Resource `json:"controller"`
	Acls                   *Resource `json:"acls"`
	Brokers                *Resource `json:"brokers"`
	BrokerConfigs          *Resource `json:"broker_configs"`
	ConsumerGroups         *Resource `json:"consumer_groups"`
	Topics                 *Resource `json:"topics"`
	PartitionReassignments *Resource `json:"partition_reassignments"`
}

type KafkaConfig struct {
	common.BaseModel
	ClusterId   string `json:"cluster_id"`
	ToipcName   string `json:"topic_name"`
	Name        string `json:"name"`
	Value       string `json:"value"`
	IsDefault   bool   `json:"is_default"`
	IsReadOnly  bool   `json:"is_read_only"`
	IsSensitive bool   `json:"is_sensitive"`
	Source      string `json:"source"`
	Synonyms    []struct {
		Name   string `json:"name"`
		Value  string `json:"value"`
		Source string `json:"source"`
	} `json:"synonyms"`
}

type KafkaConfigList struct {
	common.BaseModel
	Data []KafkaConfig `json:"data"`
}

type KafkaConfigUpdateBatch struct {
	Data []*KafkaConfigUpdateItem `json:"data"`
}

type KafkaConfigUpdateItem struct {
	Name      string   `json:"name,omitempty"`
	Value     string   `json:"value,omitempty"`
	Operation ConfigOp `json:"operation,omitempty"`
}

type KafkaConfigUpdateReq struct {
	Value string `json:"value"`
}

type KafkaConsumer struct {
	common.BaseModel
	ClusterId       string   `json:"cluster_id"`
	ConsumerGroupId string   `json:"consumer_group_id"`
	ConsumerId      string   `json:"consumer_id"`
	InstanceId      string   `json:"instance_id"`
	ClientId        string   `json:"client_id"`
	Assignments     Resource `json:"assignments"`
}

type KafkaConsumerGroup struct {
	common.BaseModel
	ClusterId         string   `json:"cluster_id"`
	ConsumerGroupId   string   `json:"consumer_group_id"`
	IsSimple          bool     `json:"is_simple"`
	PartitionAssignor string   `json:"partition_assignor"`
	State             string   `json:"state"`
	Coordinator       Resource `json:"coordinator"`
	Consumers         Resource `json:"consumers"`
	LagSummary        Resource `json:"lag_summary"`
}

type KafkaConsumerGroupLag struct {
	common.BaseModel
	ClusterId         string   `json:"cluster_id"`
	ConsumerGroupId   string   `json:"consumer_group_id"`
	MaxLagConsumerId  string   `json:"max_lag_consumer_id"`
	MaxLagInstanceId  string   `json:"max_lag_instance_id"`
	MaxLagClientId    string   `json:"max_lag_client_id"`
	MaxLagTopicName   string   `json:"max_lag_topic_name"`
	MaxLagPartitionId int      `json:"max_lag_partition_id"`
	MaxLag            int64    `json:"max_lag"`
	TotalLag          int64    `json:"total_lag"`
	MaxLagConsumer    Resource `json:"max_lag_consumer"`
	MaxLagPartition   Resource `json:"max_lag_partition"`
}

type KafkaConsumerGroupList struct {
	common.BaseModel
	Data []KafkaConsumerGroup `json:"data"`
}

type KafkaConsumerLag struct {
	common.BaseModel
	ClusterId       string `json:"cluster_id"`
	ConsumerGroupId string `json:"consumer_group_id"`
	TopicName       string `json:"topic_name"`
	PartitionId     int    `json:"partition_id"`
	ConsumerId      string `json:"consumer_id"`
	InstanceId      string `json:"instance_id"`
	ClientId        string `json:"client_id"`
	CurrentOffset   int64  `json:"current_offset"`
	LogEndOffset    int64  `json:"log_end_offset"`
	Lag             int64  `json:"lag"`
}

type KafkaConsumerLagList struct {
	common.BaseModel
	Data []KafkaConsumerLag `json:"data"`
}

type KafkaConsumerList struct {
	common.BaseModel
	Data []KafkaConsumerGroup `json:"data"`
}

type KafkaPartition struct {
	common.BaseModel
	ClusterId    string   `json:"cluster_id"`
	TopicName    string   `json:"topic_name"`
	PartitionId  int      `json:"partition_id"`
	Leader       Resource `json:"leader"`
	Replicas     Resource `json:"replicas"`
	Reassignment Resource `json:"reassignment"`
}

type KafkaPartitionConsumerLag struct {
	common.BaseModel
	ClusterId       string `json:"cluster_id"`
	ConsumerGroupId string `json:"consumer_group_id"`
	TopicName       string `json:"topic_name"`
	PartitionId     int    `json:"partition_id"`
	ConsumerId      string `json:"consumer_id"`
	InstanceId      string `json:"instance_id"`
	ClientId        string `json:"client_id"`
	CurrentOffset   int    `json:"current_offset"`
	LogEndOffset    int    `json:"log_end_offset"`
	Lag             int    `json:"lag"`
}

type KafkaPartitionList struct {
	common.BaseModel
	Data []KafkaPartition `json:"data"`
}

type Resource struct {
	Related string `json:"related"`
}

type Topic struct {
	common.BaseModel
	ClusterId              string   `json:"cluster_id"`
	TopicName              string   `json:"topic_name"`
	IsInternal             bool     `json:"is_internal"`
	ReplicationFactor      int      `json:"replication_factor"`
	PartitionCount         int      `json:"partition_count"`
	Partitions             Resource `json:"partitions"`
	Configs                Resource `json:"configs"`
	PartitionReassignments Resource `json:"partition_reassignments"`
}

type TopicCreateReq struct {
	TopicName         string `json:"topic_name,omitempty"`
	PartitionCount    int    `json:"partitions_count,omitempty"`
	ReplicationFactor int    `json:"replication_factor,omitempty"`
	// ReplicasAssignment map[string][]int `json:"replicas_assignment"` TODO: implement this
	Configs []KafkaConfigUpdateItem `json:"configs,omitempty"`
}

type TopicList struct {
	common.BaseModel
	Data []Topic `json:"data"`
}