kafka

package
v4.2.712+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 21, 2020 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 added in v0.9.167

func (m KubernetesMeta) IsEmpty() bool

func (*KubernetesMeta) SetResourceRequirements added in v0.9.167

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL