Versions in this module Expand all Collapse all v1 v1.8.1 Mar 10, 2020 Changes in this version + const AzureFunctionInvocationTimeout + const AzureMessageFetchCount + const AzureMessageVisibilityTimeout + const AzurePoisonQueueSuffix + const AzureQueuePollingInterval + const AzureQueueRetryLimit + func IsTopicValid(topic string) bool + func New(logger *zap.Logger, mqCfg messageQueue.Config, routerUrl string) (messageQueue.MessageQueue, error) + type AzureHTTPClient interface + Do func(req *http.Request) (*http.Response, error) + type AzureMessage interface + Bytes func() []byte + Delete func(options *storage.QueueServiceOptions) error + Put func(options *storage.PutMessageOptions) error + type AzureQueue interface + Create func(options *storage.QueueServiceOptions) error + GetMessages func(options *storage.GetMessagesOptions) ([]AzureMessage, error) + NewMessage func(text string) AzureMessage + type AzureQueueService interface + GetQueue func(name string) AzureQueue + type AzureQueueSubscription struct + type AzureStorageConnection struct + func (asc AzureStorageConnection) Subscribe(trigger *fv1.MessageQueueTrigger) (messageQueue.Subscription, error) + func (asc AzureStorageConnection) Unsubscribe(subscription messageQueue.Subscription) error + type Factory struct + func (factory *Factory) Create(logger *zap.Logger, mqCfg messageQueue.Config, routerUrl string) (messageQueue.MessageQueue, error)