azqueue_service_iface

type AzqueueMessageIdUrlIface interface {
	Delete(ctx context.Context, popReceipt azqueue.PopReceipt) (*azqueue.MessageIDDeleteResponse, error)
}

type AzqueueMessageUrlIface interface {
	Enqueue(ctx context.Context, messageText string, visibilityTimeout time.Duration, timeToLive time.Duration) (*azqueue.EnqueueMessageResponse, error)
	Dequeue(ctx context.Context, maxMessages int32, visibilityTimeout time.Duration) (DequeueMessagesResponseIface, error)
	NewMessageIDURL(messageId azqueue.MessageID) AzqueueMessageIdUrlIface
}

type AzqueueQueueUrlIface interface {
	NewMessageURL() AzqueueMessageUrlIface
}

type AzqueueServiceUrlIface interface {
	NewQueueURL(string) AzqueueQueueUrlIface
}

type DequeueMessagesResponseIface interface {
	NumMessages() int32
	Message(index int32) *azqueue.DequeuedMessage
}