entity

Documentation

Index

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

Types

type ColumnType

type ColumnType = string

var (
	Tag   ColumnType = "tag"
	Field ColumnType = "field"
)

type KafkaConsumerGroup

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

func NewKafkaConsumerGroup

func NewKafkaConsumerGroup(consumerGroup kafka.ConsumerGroup) KafkaConsumerGroup

type KafkaTopic

type KafkaTopic struct {
	Name                   string `datahubcolumntype:"tag" datahubcolumn:"name" datahubdatatype:"DATATYPE_STRING"`
	ExporterNamespace      string `datahubcolumntype:"tag" datahubcolumn:"namespace" datahubdatatype:"DATATYPE_STRING"`
	ClusterName            string `datahubcolumntype:"tag" datahubcolumn:"cluster_name" datahubdatatype:"DATATYPE_STRING"`
	AlamedaScalerName      string `datahubcolumntype:"tag" datahubcolumn:"alameda_scaler_name" datahubdatatype:"DATATYPE_STRING"`
	AlamedaScalerNamespace string `datahubcolumntype:"tag" datahubcolumn:"alameda_scaler_namespace" datahubdatatype:"DATATYPE_STRING"`
	Dummy                  string `datahubcolumntype:"field" datahubcolumn:"dummy" datahubdatatype:"DATATYPE_STRING"`
}

func NewKafkaTopic

func NewKafkaTopic(topic kafka.Topic) KafkaTopic