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
- func Init(config ...QueueConfig) error
- type IMessageQueue
- type Queue
- type QueueConfig
- type QueueDriver
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)
func Init ¶
func Init(config ...QueueConfig) 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
}
type QueueConfig ¶
type QueueConfig struct {
Driver QueueDriver
RedisDb *int
Region string
BaseUrl string
}
type QueueDriver ¶
type QueueDriver string
const ( QueueDriverRedis QueueDriver = "redis" QueueDriverSQS QueueDriver = "sqs" )
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.