messagequeue

Documentation

Overview

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

Index

• type MQ
  • 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) DeleteQueue(ctx context.Context, url string) 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) ReceiveMessages(ctx context.Context, input driver.ReceiveMessageInput) ([]driver.Message, error)
  • func (mq *MQ) SendMessage(ctx context.Context, input driver.SendMessageInput) (*driver.SendMessageOutput, error)
• type Option
  • 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

Types

type MQ

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

func NewMQ

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

func (*MQ) ChangeVisibility

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

func (*MQ) CreateQueue

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

func (*MQ) DeleteMessage

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

func (*MQ) DeleteQueue

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

func (*MQ) GetQueueInfo

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

func (*MQ) ListQueues

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

func (*MQ) ReceiveMessages

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

func (*MQ) SendMessage

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

type Option

type Option func(*MQ)

func WithErrorInjection

func WithErrorInjection(i *inject.Injector) Option

func WithLatency

func WithLatency(d time.Duration) Option

func WithMetrics

func WithMetrics(m *metrics.Collector) Option

func WithRateLimiter

func WithRateLimiter(l *ratelimit.Limiter) Option

func WithRecorder

func WithRecorder(r *recorder.Recorder) Option