cruisecontrol

Documentation

Index

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

Constants

const MinLogDirSizeInMB = int64(1)

Functions

func GenerateCapacityConfig

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

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

func GeneratePodAnnotations

func GeneratePodAnnotations(cruiseControlAnnotations, cruiseControlConfig map[string]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 CapacityConfig

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

type CapacityConfigAnnotation

type CapacityConfigAnnotation string

type JBODInvariantCapacityConfig

type JBODInvariantCapacityConfig struct {
	Capacities []interface{} `json:"brokerCapacities"`
}

type Reconciler

type Reconciler struct {
	resources.Reconciler
	KafkaClientProvider kafkaclient.Provider
}

Reconciler implements the Component Reconciler

func New

func New(client client.Client, cluster *v1beta1.KafkaCluster, kafkaClientProvider kafkaclient.Provider) *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