Documentation
¶
Index ¶
- type AzqueueQueueService
- func (s *AzqueueQueueService) Complete(ctx context.Context, req *queuespb.QueueCompleteRequest) (*queuespb.QueueCompleteResponse, error)
- func (s *AzqueueQueueService) Dequeue(ctx context.Context, req *queuespb.QueueDequeueRequest) (*queuespb.QueueDequeueResponse, error)
- func (s *AzqueueQueueService) Enqueue(ctx context.Context, req *queuespb.QueueEnqueueRequest) (*queuespb.QueueEnqueueResponse, error)
- type AzureQueueItemLease
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AzqueueQueueService ¶
type AzqueueQueueService struct {
// contains filtered or unexported fields
}
func New ¶
func New() (*AzqueueQueueService, error)
New - Constructs a new Azure Storage Queues client with defaults
func NewWithClient ¶
func NewWithClient(client azqueueserviceiface.AzqueueServiceUrlIface) *AzqueueQueueService
func (*AzqueueQueueService) Complete ¶
func (s *AzqueueQueueService) Complete(ctx context.Context, req *queuespb.QueueCompleteRequest) (*queuespb.QueueCompleteResponse, error)
Complete - Completes a previously popped queue item
func (*AzqueueQueueService) Dequeue ¶
func (s *AzqueueQueueService) Dequeue(ctx context.Context, req *queuespb.QueueDequeueRequest) (*queuespb.QueueDequeueResponse, error)
Receive - Receives a collection of tasks off a given queue.
func (*AzqueueQueueService) Enqueue ¶
func (s *AzqueueQueueService) Enqueue(ctx context.Context, req *queuespb.QueueEnqueueRequest) (*queuespb.QueueEnqueueResponse, 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
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.