messageQueue

Documentation

Index

• Constants
• func IsTopicValid(mqType string, topic string) bool
• type AzureHTTPClient
• type AzureMessage
• type AzureQueue
• type AzureQueueService
• type AzureQueueSubscription
• type AzureStorageConnection
• type Kafka
• type MessageQueue
• type MessageQueueConfig
• type MessageQueueTriggerManager
  • func MakeMessageQueueTriggerManager(logger *zap.Logger, fissionClient *crd.FissionClient, routerUrl string, ...) *MessageQueueTriggerManager
• type Nats

Constants

const (
	// AzureQueuePollingInterval is the polling interval (default is 1 minute).
	AzureQueuePollingInterval = time.Minute
	// AzureQueueRetryLimit is the limit for attempts to retry invoking a function.
	AzureQueueRetryLimit = 3
	// AzureMessageFetchCount is the number of messages to fetch at a time.
	AzureMessageFetchCount = 10
	// AzureMessageVisibilityTimeout is the visibility timeout for dequeued messages.
	AzureMessageVisibilityTimeout = time.Minute
	// AzurePoisonQueueSuffix is the suffix used for poison queues.
	AzurePoisonQueueSuffix = "-poison"
	// AzureFunctionInvocationTimeout is the amount of time to wait for a triggered function to execute.
	AzureFunctionInvocationTimeout = 10 * time.Minute
)

TODO: some of these constants should probably be environment variables

const (
	ADD_TRIGGER requestType = iota
	DELETE_TRIGGER
	GET_ALL_TRIGGERS
)

Functions

func IsTopicValid

func IsTopicValid(mqType string, topic string) bool

Types

type AzureHTTPClient

type AzureHTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

AzureHTTPClient is the interface that abstract HTTP requests made by the trigger. This exists to enable unit testing.

type AzureMessage

type AzureMessage interface {
	Bytes() []byte
	Put(options *storage.PutMessageOptions) error
	Delete(options *storage.QueueServiceOptions) error
}

AzureMessage is the interface that abstracts Azure storage messages. This exists to enable unit testing.

type AzureQueue

type AzureQueue interface {
	Create(options *storage.QueueServiceOptions) error
	NewMessage(text string) AzureMessage
	GetMessages(options *storage.GetMessagesOptions) ([]AzureMessage, error)
}

AzureQueue is the interface that abstracts Azure storage queues. This exists to enable unit testing.

type AzureQueueService

type AzureQueueService interface {
	GetQueue(name string) AzureQueue
}

AzureQueueService is the interface that abstracts the Azure storage service. This exists to enable unit testing.

type AzureQueueSubscription

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

AzureQueueSubscription represents an Azure storage message queue subscription.

type AzureStorageConnection

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

AzureStorageConnection represents an Azure storage connection.

type Kafka

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

type MessageQueue

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

type MessageQueueConfig

type MessageQueueConfig struct {
	MQType  string
	Url     string
	Secrets map[string][]byte
}

type MessageQueueTriggerManager

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

func MakeMessageQueueTriggerManager

func MakeMessageQueueTriggerManager(logger *zap.Logger, fissionClient *crd.FissionClient, routerUrl string, mqConfig MessageQueueConfig) *MessageQueueTriggerManager

type Nats

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