controller

Documentation

Index

• func NewController(ctx context.Context, _ configmap.Watcher) *controller.Impl
• type Reconciler
  • func (r *Reconciler) FinalizeKind(ctx context.Context, nc *v1alpha1.NatsJetStreamChannel) (err reconciler.Event)
  • func (r *Reconciler) ReconcileKind(ctx context.Context, nc *v1alpha1.NatsJetStreamChannel) reconciler.Event

Functions

func NewController

func NewController(ctx context.Context, _ 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 {
	// contains filtered or unexported fields
}

Reconciler is the controller reconciler which manages dispatcher deployments and other related manifests in response to NATSJetStreamChannel resource changes.

func (*Reconciler) FinalizeKind

func (r *Reconciler) FinalizeKind(ctx context.Context, nc *v1alpha1.NatsJetStreamChannel) (err reconciler.Event)

FinalizeKind checks whether there are still resources requiring a dispatcher to exist. This handles both namespace-scoped and cluster-scoped resources

func (*Reconciler) ReconcileKind

func (r *Reconciler) ReconcileKind(ctx context.Context, nc *v1alpha1.NatsJetStreamChannel) reconciler.Event