messageQueue

Documentation

Index

• Constants
• func IsTopicValid(mqType string, topic string) bool
• type MessageQueue
• type MessageQueueConfig
• type MessageQueueTriggerManager
  • func MakeMessageQueueTriggerManager(fissionClient *tpr.FissionClient, routerUrl string, ...) *MessageQueueTriggerManager
• type Nats

Constants

const (
	ADD_TRIGGER requestType = iota
	DELETE_TRIGGER
	GET_ALL_TRIGGERS
)

const (
	NATS string = "nats-streaming"
)

Functions

func IsTopicValid

func IsTopicValid(mqType string, topic string) bool

Types

type MessageQueue

type MessageQueue interface {
	// contains filtered or unexported methods
}

type MessageQueueConfig

type MessageQueueConfig struct {
	MQType string
	Url    string
}

type MessageQueueTriggerManager

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

func MakeMessageQueueTriggerManager

func MakeMessageQueueTriggerManager(fissionClient *tpr.FissionClient, routerUrl string, mqConfig MessageQueueConfig) *MessageQueueTriggerManager

type Nats

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