Documentation
¶
Index ¶
- func Count(ctx context.Context, queue Queue) (int, error)
- func Delete(ctx context.Context, queue Queue, id string) error
- func Dequeue[T interface{}](ctx context.Context, queue Queue, options ...types.DequeueOptions) ([]types.QueueMessage[T], error)
- func Enqueue[T interface{}](ctx context.Context, queue Queue, payload T, options ...types.EnqueueOptions) error
- type IMessageQueue
- type Queue
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Dequeue ¶
func Dequeue[T interface{}](ctx context.Context, queue Queue, options ...types.DequeueOptions) ([]types.QueueMessage[T], error)
Types ¶
type IMessageQueue ¶
type IMessageQueue interface {
Count(ctx context.Context, queue string) (int, error)
Enqueue(ctx context.Context, queue string, payload string, options ...types.EnqueueOptions) error
Dequeue(ctx context.Context, queue string, options ...types.DequeueOptions) ([]types.DequeuedMessage, error)
Delete(ctx context.Context, queue string, message string) error
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.