controllers

Documentation

Index

• Constants
• func PopulateStatusFromAnnotation(a map[string]string, status *konsumeratorv1.ConsumerStatus)
• func UpdateStatusAnnotations(cm *corev1.ConfigMap, status *konsumeratorv1.ConsumerStatus) error
• type ConfigMapReconciler
  • func (r *ConfigMapReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ConfigMapReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ConsumerReconciler
  • func (r *ConsumerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ConsumerReconciler) SetupWithManager(mgr ctrl.Manager) error
• type Controller
• type InstanceState

Constants

const (
	InstanceStatusRunning          string = "RUNNING"
	InstanceStatusSaturated        string = "SATURATED"
	InstanceStatusPendingScaleUp   string = "PENDING_SCALE_UP"
	InstanceStatusPendingScaleDown string = "PENDING_SCALE_DOWN"

	PartitionAnnotation           = "konsumerator.lwolf.org/partition"
	ConsumerAnnotation            = "konsumerator.lwolf.org/consumer-id"
	DisableAutoscalerAnnotation   = "konsumerator.lwolf.org/disable-autoscaler"
	GenerationAnnotation          = "konsumerator.lwolf.org/generation"
	CPUSaturationLevel            = "konsumerator.lwolf.org/cpu-saturation-level"
	ScalingStatusAnnotation       = "konsumerator.lwolf.org/scaling-status"
	ScalingStatusChangeAnnotation = "konsumerator.lwolf.org/scaling-status-change"
	VerboseLoggingAnnotation      = "konsumerator.lwolf.org/verbose"
)

const (
	AnnotationIsManaged = "konsumerator.lwolf.org/managed"
)

Functions

func PopulateStatusFromAnnotation

func PopulateStatusFromAnnotation(a map[string]string, status *konsumeratorv1.ConsumerStatus)

func UpdateStatusAnnotations

func UpdateStatusAnnotations(cm *corev1.ConfigMap, status *konsumeratorv1.ConsumerStatus) error

Types

type ConfigMapReconciler

type ConfigMapReconciler struct {
	client.Client

	Log      logr.Logger
	Recorder record.EventRecorder
	Scheme   *runtime.Scheme
	Clock    clock.Clock
}

ConfigMapReconciler reconciles a ConfigMap object

func (*ConfigMapReconciler) Reconcile

func (r *ConfigMapReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ConfigMapReconciler) SetupWithManager

func (r *ConfigMapReconciler) SetupWithManager(mgr ctrl.Manager) error

type ConsumerReconciler

type ConsumerReconciler struct {
	client.Client

	Log      logr.Logger
	Recorder record.EventRecorder
	Scheme   *runtime.Scheme
	Clock    clock.Clock
}

ConsumerReconciler reconciles a Consumer object

func (*ConsumerReconciler) Reconcile

func (r *ConsumerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ConsumerReconciler) SetupWithManager

func (r *ConsumerReconciler) SetupWithManager(mgr ctrl.Manager) error

type Controller

type Controller interface {
	SetupWithManager(mgr ctrl.Manager) error
	Reconcile(context.Context, ctrl.Request) (ctrl.Result, error)
}

type InstanceState

type InstanceState struct {
	// contains filtered or unexported fields
}

InstanceState in a current form just caches the values in a single struct to reduce the duplication inside the operator.