azqueue_service

Oct 28, 2021

Changes in this version

+ func New() (queue.QueueService, error)

+ func NewWithClient(client azqueueserviceiface.AzqueueServiceUrlIface) queue.QueueService

+ type AzqueueQueueService struct

+ func (s *AzqueueQueueService) Complete(queue string, leaseId string) error

+ func (s *AzqueueQueueService) Receive(options queue.ReceiveOptions) ([]queue.NitricTask, error)

+ func (s *AzqueueQueueService) Send(queue string, task queue.NitricTask) error

+ func (s *AzqueueQueueService) SendBatch(queueName string, tasks []queue.NitricTask) (*queue.SendBatchResponse, error)

+ type AzureQueueItemLease struct

+ ID string

+ PopReceipt string

+ func (l *AzureQueueItemLease) String() (string, error)