azqueue_service_iface

Documentation

Index

• type AzqueueMessageIdUrlIface
  • func AdaptMessageIdUrl(c azqueue.MessageIDURL) AzqueueMessageIdUrlIface
• type AzqueueMessageUrlIface
  • func AdaptMessageUrl(c azqueue.MessagesURL) AzqueueMessageUrlIface
• type AzqueueQueueUrlIface
  • func AdaptQueueUrl(c azqueue.QueueURL) AzqueueQueueUrlIface
• type AzqueueServiceUrlIface
  • func AdaptServiceUrl(c azqueue.ServiceURL) AzqueueServiceUrlIface
• type DequeueMessagesResponseIface
  • func AdaptDequeueMessagesResponse(c azqueue.DequeuedMessagesResponse) DequeueMessagesResponseIface

Types

type AzqueueMessageIdUrlIface

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

func AdaptMessageIdUrl

func AdaptMessageIdUrl(c azqueue.MessageIDURL) AzqueueMessageIdUrlIface

type AzqueueMessageUrlIface

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
}

func AdaptMessageUrl

func AdaptMessageUrl(c azqueue.MessagesURL) AzqueueMessageUrlIface

type AzqueueQueueUrlIface

type AzqueueQueueUrlIface interface {
	NewMessageURL() AzqueueMessageUrlIface
}

func AdaptQueueUrl

func AdaptQueueUrl(c azqueue.QueueURL) AzqueueQueueUrlIface

type AzqueueServiceUrlIface

type AzqueueServiceUrlIface interface {
	NewQueueURL(string) AzqueueQueueUrlIface
}

func AdaptServiceUrl

func AdaptServiceUrl(c azqueue.ServiceURL) AzqueueServiceUrlIface

type DequeueMessagesResponseIface

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

func AdaptDequeueMessagesResponse

func AdaptDequeueMessagesResponse(c azqueue.DequeuedMessagesResponse) DequeueMessagesResponseIface