controller

Documentation

Index

• func NewController(ctx context.Context, cmw configmap.Watcher) *controller.Impl
• type Reconciler
  • func (r *Reconciler) FinalizeKind(ctx context.Context, kc *v1alpha1.KinesisChannel) pkgreconciler.Event
  • func (r *Reconciler) ReconcileKind(ctx context.Context, kc *v1alpha1.KinesisChannel) pkgreconciler.Event

Functions

func NewController

func NewController(
	ctx context.Context,
	cmw configmap.Watcher,
) *controller.Impl

NewController initializes the controller and is called by the generated code. Registers event handlers to enqueue events.

Types

type Reconciler

type Reconciler struct {
	KubeClientSet kubernetes.Interface

	EventingClientSet eventingclientset.Interface
	// contains filtered or unexported fields
}

Reconciler reconciles Kinesis Channels.

func (*Reconciler) FinalizeKind

func (r *Reconciler) FinalizeKind(ctx context.Context, kc *v1alpha1.KinesisChannel) pkgreconciler.Event

func (*Reconciler) ReconcileKind

func (r *Reconciler) ReconcileKind(ctx context.Context, kc *v1alpha1.KinesisChannel) pkgreconciler.Event

ReconcileKind compares the actual state with the desired, and attempts to converge the two. It then updates the Status block of the KinesisChannel resource with the current status of the resource.