mqtrigger

Documentation

Index

• Variables
• func StartScalerManager(ctx context.Context, clientGen crd.ClientGeneratorInterface, ...) error
• type MessageQueue
• type Subscription

Variables

var (
	// Group refers to the group name in KEDA CRD
	Group = "keda.sh"
	// Version refers to the version name in KEDA CRD
	Version = "v1alpha1"
)

Functions

func StartScalerManager

func StartScalerManager(ctx context.Context, clientGen crd.ClientGeneratorInterface, logger *zap.Logger, mgr manager.Interface, routerURL string) error

StartScalerManager watches for changes in MessageQueueTrigger and, Based on changes, it Creates, Updates and Deletes Objects of Kind ScaledObjects, AuthenticationTriggers and Deployments

Types

type MessageQueue

type MessageQueue interface {
	Subscribe(trigger *fv1.MessageQueueTrigger) (Subscription, error)
	Unsubscribe(triggerSub Subscription) error
}

type Subscription

type Subscription interface{}