mqtrigger

Documentation

Index

• Constants
• Variables
• func StartScalerManager(logger *zap.Logger, routerURL string) error
• type MessageQueueTriggerManager
  • func MakeMessageQueueTriggerManager(logger *zap.Logger, fissionClient *crd.FissionClient, ...) *MessageQueueTriggerManager
  • func (mqt *MessageQueueTriggerManager) Run()

Constants

const (
	ADD_TRIGGER requestType = iota
	DELETE_TRIGGER
	GET_ALL_TRIGGERS
)

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(logger *zap.Logger, 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 MessageQueueTriggerManager

type MessageQueueTriggerManager struct {
	// contains filtered or unexported fields
}

func MakeMessageQueueTriggerManager

func MakeMessageQueueTriggerManager(logger *zap.Logger,
	fissionClient *crd.FissionClient, mqType fv1.MessageQueueType, messageQueue messageQueue.MessageQueue) *MessageQueueTriggerManager

func (*MessageQueueTriggerManager) Run

func (mqt *MessageQueueTriggerManager) Run()