# Functions
NewDequeueConfig returns new queue config for StartDequeuer().
NewMessage creates Message.
NewMockClient creates a new mock instance.
StartDequeuer starts a dequeuer to consume the message from the queue and return the output channel.
WithDequeueInterval sets dequeueing interval.
# Constants
JSONContentType represents the json content type of queue message.
# Variables
ErrDequeuedMessage represents the error when message has already been dequeued.
ErrEmptyMessage represents nil or empty Message.
ErrInvalidMessage represents the error when the message has already been requeued.
ErrMessageNotFound represents the error when queue is empty or all messages are leased by clients.
ErrUnsupportedContentType represents the error when the content type is unsupported.
# Structs
Message represents message managed by queue.
Metadata represents the metadata of queue message.
MockClient is a mock of Client interface.
MockClientDequeueCall wrap *gomock.Call.
MockClientEnqueueCall wrap *gomock.Call.
MockClientExtendMessageCall wrap *gomock.Call.
MockClientFinishMessageCall wrap *gomock.Call.
MockClientMockRecorder is the mock recorder for MockClient.
QueueClientConfig is a configuration for queue client APIs.
# Interfaces
Client is an interface to implement queue operations.
No description provided by the author
No description provided by the author