cruisecontrol

Documentation

Index

• func GenerateCapacityConfig(kafkaCluster *v1beta1.KafkaCluster, log logr.Logger, config *corev1.ConfigMap) string
• func GeneratePodAnnotations(kafkaCluster *v1beta1.KafkaCluster, log logr.Logger, capacityConfig string) map[string]string
• type BrokerCapacity
• type Capacity
• type CruiseControlCapacityConfig
• type Reconciler
  • func New(client client.Client, cluster *v1beta1.KafkaCluster) *Reconciler
  • func (r *Reconciler) Reconcile(log logr.Logger) error

Functions

func GenerateCapacityConfig

func GenerateCapacityConfig(kafkaCluster *v1beta1.KafkaCluster, log logr.Logger, config *corev1.ConfigMap) string

generateCapacityConfig generates a CC capacity config with default values or returns the manually overridden value if it exists

func GeneratePodAnnotations

func GeneratePodAnnotations(kafkaCluster *v1beta1.KafkaCluster, log logr.Logger, capacityConfig string) map[string]string

Types

type BrokerCapacity

type BrokerCapacity struct {
	BrokerID string   `json:"brokerId"`
	Capacity Capacity `json:"capacity"`
	Doc      string   `json:"doc"`
}

type Capacity

type Capacity struct {
	DISK  map[string]string `json:"DISK"`
	CPU   string            `json:"CPU"`
	NWIN  string            `json:"NW_IN"`
	NWOUT string            `json:"NW_OUT"`
}

type CruiseControlCapacityConfig

type CruiseControlCapacityConfig struct {
	BrokerCapacities []BrokerCapacity `json:"brokerCapacities"`
}

type Reconciler

type Reconciler struct {
	resources.Reconciler
}

Reconciler implements the Component Reconciler

func New

func New(client client.Client, cluster *v1beta1.KafkaCluster) *Reconciler

New creates a new reconciler for CC

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(log logr.Logger) error

Reconcile implements the reconcile logic for CC