mqtrigger

Documentation

Index

• Constants
• 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
)

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()