kafka

Documentation

Index

• type ConsumerGroup
• type KubernetesMeta
  • func (m KubernetesMeta) IsEmpty() bool
  • func (m *KubernetesMeta) SetResourceRequirements(r corev1.ResourceRequirements)
• type ResourceMeta
• type Topic

Types

type ConsumerGroup

type ConsumerGroup struct {
	Name                   string
	ExporterNamespace      string
	ClusterName            string
	AlamedaScalerName      string
	AlamedaScalerNamespace string
	Policy                 string
	EnableExecution        bool
	ConsumeTopic           string
	ResourceMeta
	// Since value of min/max replicas are initialized from counts of topic's partition, define these fields in here rather than KubernetesMeta.
	MinReplicas int32
	MaxReplicas int32
}

type KubernetesMeta

type KubernetesMeta struct {
	Namespace      string
	Name           string
	Kind           string
	ReadyReplicas  int32
	SpecReplicas   int32
	CPULimit       string
	CPURequest     string
	MemoryLimit    string
	MemoryRequest  string
	VolumesSize    string
	VolumesPVCSize string
}

func (KubernetesMeta) IsEmpty

func (m KubernetesMeta) IsEmpty() bool

func (*KubernetesMeta) SetResourceRequirements

func (m *KubernetesMeta) SetResourceRequirements(r corev1.ResourceRequirements)

type ResourceMeta

type ResourceMeta struct {
	KubernetesMeta
	CustomName string
}

type Topic

type Topic struct {
	Name                   string
	ExporterNamespace      string
	ClusterName            string
	AlamedaScalerName      string
	AlamedaScalerNamespace string
}