messagequeue

package

v1.7.0 Latest Latest Go to latest Published: May 25, 2026 License: MIT Imports: 7 Imported by: 0

Details

Package messagequeue provides a portable message queue API with cross-cutting concerns.

This section is empty.

This section is empty.

This section is empty.

type MQ struct {
	// contains filtered or unexported fields
}

func NewMQ(d driver.MessageQueue, opts ...Option) *MQ

func (mq *MQ) ChangeVisibility(ctx context.Context, queueURL, receiptHandle string, timeout int) error

func (mq *MQ) CreateQueue(ctx context.Context, config driver.QueueConfig) (*driver.QueueInfo, error)

func (mq *MQ) DeleteMessage(ctx context.Context, queueURL, receiptHandle string) error

func (mq *MQ) DeleteMessageBatch(
	ctx context.Context, queue string, entries []driver.BatchDeleteEntry,
) (*driver.BatchDeleteResult, error)

func (mq *MQ) DeleteQueue(ctx context.Context, url string) error

func (mq *MQ) GetQueueAttributes(
	ctx context.Context, queue string,
) (*driver.QueueAttributes, error)

func (mq *MQ) GetQueueInfo(ctx context.Context, url string) (*driver.QueueInfo, error)

func (mq *MQ) ListQueues(ctx context.Context, prefix string) ([]driver.QueueInfo, error)

func (mq *MQ) PurgeQueue(ctx context.Context, queue string) error

func (mq *MQ) ReceiveMessages(ctx context.Context, input driver.ReceiveMessageInput) ([]driver.Message, error)

func (mq *MQ) ReceiveMessagesWithOptions(
	ctx context.Context, queue string, opts driver.ReceiveOptions,
) ([]driver.Message, error)

func (mq *MQ) SendMessage(ctx context.Context, input driver.SendMessageInput) (*driver.SendMessageOutput, error)

func (mq *MQ) SendMessageBatch(
	ctx context.Context, queue string, entries []driver.BatchSendEntry,
) (*driver.BatchSendResult, error)

func (mq *MQ) SetQueueAttributes(
	ctx context.Context, queue string, attrs map[string]int,
) error

type Option func(*MQ)

func WithErrorInjection(i *inject.Injector) Option

func WithLatency(d time.Duration) Option

func WithMetrics(m *metrics.Collector) Option

func WithRateLimiter(l *ratelimit.Limiter) Option

func WithRecorder(r *recorder.Recorder) Option

Path	Synopsis
driver Package driver defines the interface for message queue service implementations.	Package driver defines the interface for message queue service implementations.