azqueue_service

Documentation

Index

• func New() (queue.QueueService, error)
• func NewWithClient(client azqueueserviceiface.AzqueueServiceUrlIface) queue.QueueService
• type AzqueueQueueService
  • func (s *AzqueueQueueService) Complete(ctx context.Context, queue string, leaseId string) error
  • func (s *AzqueueQueueService) Receive(ctx context.Context, options queue.ReceiveOptions) ([]queue.NitricTask, error)
  • func (s *AzqueueQueueService) Send(ctx context.Context, queue string, task queue.NitricTask) error
  • func (s *AzqueueQueueService) SendBatch(ctx context.Context, queueName string, tasks []queue.NitricTask) (*queue.SendBatchResponse, error)
• type AzureQueueItemLease
  • func (l *AzureQueueItemLease) String() (string, error)

Functions

func New

func New() (queue.QueueService, error)

New - Constructs a new Azure Storage Queues client with defaults

func NewWithClient

func NewWithClient(client azqueueserviceiface.AzqueueServiceUrlIface) queue.QueueService

Types

type AzqueueQueueService

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

func (*AzqueueQueueService) Complete

func (s *AzqueueQueueService) Complete(ctx context.Context, queue string, leaseId string) error

Complete - Completes a previously popped queue item

func (*AzqueueQueueService) Receive

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

Receive - Receives a collection of tasks off a given queue.

func (*AzqueueQueueService) Send

func (s *AzqueueQueueService) Send(ctx context.Context, queue string, task queue.NitricTask) error

func (*AzqueueQueueService) SendBatch

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

type AzureQueueItemLease

type AzureQueueItemLease struct {
	// The ID of the queue item
	// note: this is an id generated by Azure, it's not the user provided unique id.
	ID string
	// lease id, a new popReceipt is generated each time an item is dequeued.
	PopReceipt string
}

AzureQueueItemLease - Represents a lease of an Azure Storages Queues item Azure requires a combination of their unique reference for a queue item (id) and a pop receipt (lease id) to perform operations on the item, such as delete it from the queue.

func (*AzureQueueItemLease) String

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

String - convert the item lease struct to a string, to be returned as a NitricTask LeaseID