controllers

package

v0.9.2 Latest Latest Go to latest Published: Jul 1, 2020 License: Apache-2.0 Imports: 30 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/lwolf/konsumerator

Links

Open Source Insights

Documentation ¶

Index ¶

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

Constants ¶

View Source

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"
)

View Source

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

Variables ¶

This section is empty.

Functions ¶

func PopulateStatusFromAnnotation ¶ added in v0.9.1

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

func UpdateStatusAnnotations ¶ added in v0.9.1

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

Types ¶

type ConfigMapReconciler ¶ added in v0.9.1

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

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

func (*ConfigMapReconciler) SetupWithManager ¶ added in v0.9.1

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
}

Consumer reconciles a Consumer object

func (*ConsumerReconciler) Reconcile ¶

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

func (*ConsumerReconciler) SetupWithManager ¶

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

type Controller ¶ added in v0.9.1

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

Source Files ¶

View all Source files

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