mqtrigger

Documentation

Index

• Constants
• func DecreaseInprocessCount()
• func DecreaseSubscriptionCount()
• func IncreaseInprocessCount()
• func IncreaseMessageCount(trigname, trignamespace string)
• func IncreaseSubscriptionCount()
• func ResetTriggerStatus(trigname, trignamespace string)
• func SetMessageLagCount(trigname, trignamespace, topic, partition string, lag int64)
• func SetTriggerStatus(trigname, trignamespace string)
• func StartScalerManager(ctx context.Context, clientGen crd.ClientGeneratorInterface, ...) error
• type MessageQueueTriggerManager
  • func MakeMessageQueueTriggerManager(logger *zap.Logger, fissionClient versioned.Interface, ...) (*MessageQueueTriggerManager, error)
  • func (mqt *MessageQueueTriggerManager) RegisterTrigger(trigger *fv1.MessageQueueTrigger) error
  • func (mqt *MessageQueueTriggerManager) Run(ctx context.Context, stopCh <-chan struct{}, mgr manager.Interface)

Constants

const (
	ADD_TRIGGER requestType = iota
	DELETE_TRIGGER
	GET_TRIGGER_SUBSCRIPTION
	UPDATE_TRIGGER_SUBSCRIPTION
)

Functions

func DecreaseInprocessCount

func DecreaseInprocessCount()

func DecreaseSubscriptionCount

func DecreaseSubscriptionCount()

func IncreaseInprocessCount

func IncreaseInprocessCount()

func IncreaseMessageCount

func IncreaseMessageCount(trigname, trignamespace string)

func IncreaseSubscriptionCount

func IncreaseSubscriptionCount()

func ResetTriggerStatus

func ResetTriggerStatus(trigname, trignamespace string)

func SetMessageLagCount

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

func SetTriggerStatus

func SetTriggerStatus(trigname, trignamespace string)

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 MessageQueueTriggerManager

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

func MakeMessageQueueTriggerManager

func MakeMessageQueueTriggerManager(logger *zap.Logger,
	fissionClient versioned.Interface,
	mqType fv1.MessageQueueType,
	finformerFactory map[string]genInformer.SharedInformerFactory,
	messageQueue messageQueue.MessageQueue) (*MessageQueueTriggerManager, error)

func (*MessageQueueTriggerManager) RegisterTrigger

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

func (*MessageQueueTriggerManager) Run

func (mqt *MessageQueueTriggerManager) Run(ctx context.Context, stopCh <-chan struct{}, mgr manager.Interface)