entity

Documentation

Index

• type KafkaConsumerGroup
  • func NewKafkaConsumerGroup(consumerGroup kafka.ConsumerGroup) KafkaConsumerGroup
• type KafkaTopic
  • func NewKafkaTopic(topic kafka.Topic) KafkaTopic

Types

type KafkaConsumerGroup

type KafkaConsumerGroup struct {
	Name                      string `datahubcolumn:"name" datahubdatatype:"DATATYPE_STRING"`
	ExporterNamespace         string `datahubcolumn:"namespace" datahubdatatype:"DATATYPE_STRING"`
	ClusterName               string `datahubcolumn:"cluster_name" datahubdatatype:"DATATYPE_STRING"`
	AlamedaScalerName         string `datahubcolumn:"alameda_scaler_name" datahubdatatype:"DATATYPE_STRING"`
	Policy                    string `datahubcolumn:"policy" datahubdatatype:"DATATYPE_STRING"`
	EnableExecution           bool   `datahubcolumn:"enable_execution" datahubdatatype:"DATATYPE_BOOL"`
	ConsumeTopic              string `datahubcolumn:"topic_name" datahubdatatype:"DATATYPE_STRING"`
	ResourceCustomName        string `datahubcolumn:"resource_custom_name" datahubdatatype:"DATATYPE_STRING"`
	ResourceK8SNamespace      string `datahubcolumn:"resource_k8s_namespace" datahubdatatype:"DATATYPE_STRING"`
	ResourceK8SName           string `datahubcolumn:"resource_k8s_name" datahubdatatype:"DATATYPE_STRING"`
	ResourceK8SKind           string `datahubcolumn:"resource_k8s_kind" datahubdatatype:"DATATYPE_STRING"`
	ReadyReplicas             int32  `datahubcolumn:"resource_k8s_replicas" datahubdatatype:"DATATYPE_INT32"`
	SpecReplicas              int32  `datahubcolumn:"resource_k8s_spec_replicas" datahubdatatype:"DATATYPE_INT32"`
	MinReplicas               int32  `datahubcolumn:"resource_k8s_min_replicas" datahubdatatype:"DATATYPE_INT32"`
	MaxReplicas               int32  `datahubcolumn:"resource_k8s_max_replicas" datahubdatatype:"DATATYPE_INT32"`
	ResourceK8SCPULimit       string `datahubcolumn:"resource_cpu_limit" datahubdatatype:"DATATYPE_STRING"`
	ResourceK8SCPURequest     string `datahubcolumn:"resource_cpu_request" datahubdatatype:"DATATYPE_STRING"`
	ResourceK8SMemoryLimit    string `datahubcolumn:"resource_memory_limit" datahubdatatype:"DATATYPE_STRING"`
	ResourceK8SMemoryRequest  string `datahubcolumn:"resource_memory_request" datahubdatatype:"DATATYPE_STRING"`
	ResourceK8SVolumesSize    string `datahubcolumn:"volumes_size" datahubdatatype:"DATATYPE_STRING"`
	ResourceK8SVolumesPVCSize string `datahubcolumn:"volumes_pvc_size" datahubdatatype:"DATATYPE_STRING"`
}

func NewKafkaConsumerGroup

func NewKafkaConsumerGroup(consumerGroup kafka.ConsumerGroup) KafkaConsumerGroup

type KafkaTopic

type KafkaTopic struct {
	Name              string `datahubcolumn:"name" datahubdatatype:"DATATYPE_STRING"`
	ExporterNamespace string `datahubcolumn:"namespace" datahubdatatype:"DATATYPE_STRING"`
	ClusterName       string `datahubcolumn:"cluster_name" datahubdatatype:"DATATYPE_STRING"`
	AlamedaScalerName string `datahubcolumn:"alameda_scaler_name" datahubdatatype:"DATATYPE_STRING"`
}

func NewKafkaTopic

func NewKafkaTopic(topic kafka.Topic) KafkaTopic