mqtrigger

Documentation

Index

• Constants
• Variables
• func DecreaseSubscriptionCount()
• func IncreaseMessageCount(trigname, trignamespace string)
• func IncreaseSubscriptionCount()
• func SetMessageLagCount(trigname, trignamespace, topic, partition string, lag int64)
• func StartScalerManager(ctx context.Context, logger *zap.Logger, routerURL string) error
• type MessageQueueTriggerManager
  • func MakeMessageQueueTriggerManager(logger *zap.Logger, fissionClient versioned.Interface, ...) *MessageQueueTriggerManager
  • func (mqt *MessageQueueTriggerManager) RegisterTrigger(trigger *fv1.MessageQueueTrigger)
  • func (mqt *MessageQueueTriggerManager) Run(ctx context.Context)

Constants

const (
	ADD_TRIGGER requestType = iota
	DELETE_TRIGGER
	GET_TRIGGER_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 DecreaseSubscriptionCount

func DecreaseSubscriptionCount()

func IncreaseMessageCount

func IncreaseMessageCount(trigname, trignamespace string)

func IncreaseSubscriptionCount

func IncreaseSubscriptionCount()

func SetMessageLagCount

func SetMessageLagCount(trigname, trignamespace, topic, partition string, lag int64)

func StartScalerManager

func StartScalerManager(ctx context.Context, 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 versioned.Interface, mqType fv1.MessageQueueType, messageQueue messageQueue.MessageQueue) *MessageQueueTriggerManager

func (*MessageQueueTriggerManager) RegisterTrigger

func (mqt *MessageQueueTriggerManager) RegisterTrigger(trigger *fv1.MessageQueueTrigger)

func (*MessageQueueTriggerManager) Run

func (mqt *MessageQueueTriggerManager) Run(ctx context.Context)