azurequeuestorage

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