keda

Documentation

Overview

Package keda implements the Pub/Sub PullSubscription controller for Keda-based PullSubscriptions.

Index

• func NewController(ctx context.Context, cmw configmap.Watcher) *controller.Impl
• type DiscoverFunc
• type Reconciler
  • func (r *Reconciler) Reconcile(ctx context.Context, key string) error
  • func (r *Reconciler) ReconcileScaledObject(ctx context.Context, ra *appsv1.Deployment, src *v1alpha1.PullSubscription) error

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 DiscoverFunc

type DiscoverFunc func(discovery.DiscoveryInterface, schema.GroupVersion) error

type Reconciler

type Reconciler struct {
	*psreconciler.Base
	// contains filtered or unexported fields
}

Reconciler implements controller.Reconciler for PullSubscription resources.

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context, key string) error

func (*Reconciler) ReconcileScaledObject

func (r *Reconciler) ReconcileScaledObject(ctx context.Context, ra *appsv1.Deployment, src *v1alpha1.PullSubscription) error

TODO upstream to pkg