mqtrigger

Documentation

Index

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

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