sqs

Oct 26, 2026

Changes in this version

type Transport

+ func (t *Transport) DeadLetterQueueName(queue, suffix string) string

+ func (t *Transport) SettleNative(context.Context, *babelqueue.ReceivedMessage, string, string) error

Oct 20, 2026

Changes in this version

+ const MaxDelaySeconds

+ var ErrInvalidDelay = errors.New("babelqueue/sqs: delay not supported by this queue (§3.4)")

type Transport

+ func (t *Transport) PublishDelayed(ctx context.Context, queue, body string, delay time.Duration) error

Oct 10, 2026

Changes in this version

+ type OnSchemaVersionRejected func(version, queue string)

type Option

+ func WithOnSchemaVersionRejected(fn OnSchemaVersionRejected) Option

Oct 3, 2026

Changes in this version

+ const MaxVisibilityTimeoutSeconds

+ var ErrReleaseUnsupported = fmt.Errorf(...)

type Transport

+ func (t *Transport) Release(ctx context.Context, msg *babelqueue.ReceivedMessage, delay time.Duration) error

+ type VisibilityAPI interface

+ ChangeMessageVisibility func(ctx context.Context, in *awssqs.ChangeMessageVisibilityInput, ...) (*awssqs.ChangeMessageVisibilityOutput, error)

Jun 20, 2026

Changes in this version

type Transport

+ func (t *Transport) PublishWithHeaders(ctx context.Context, queue, body string, headers map[string]string) error

Jun 12, 2026

Changes in this version

+ type API interface

+ DeleteMessage func(ctx context.Context, in *awssqs.DeleteMessageInput, ...) (*awssqs.DeleteMessageOutput, error)

+ GetQueueUrl func(ctx context.Context, in *awssqs.GetQueueUrlInput, ...) (*awssqs.GetQueueUrlOutput, error)

+ ReceiveMessage func(ctx context.Context, in *awssqs.ReceiveMessageInput, ...) (*awssqs.ReceiveMessageOutput, error)

+ SendMessage func(ctx context.Context, in *awssqs.SendMessageInput, ...) (*awssqs.SendMessageOutput, error)

+ type Option func(*Transport)

+ func WithClient(client API) Option

+ func WithContentDedup(enabled bool) Option

+ func WithEndpoint(endpoint string) Option

+ func WithFIFO(enabled bool) Option

+ func WithMessageGroupID(id string) Option

+ func WithQueueURLPrefix(prefix string) Option

+ func WithRegion(region string) Option

+ func WithVisibilityTimeout(seconds int32) Option

+ func WithWaitTimeSeconds(seconds int32) Option

+ type Transport struct

+ func New(ctx context.Context, opts ...Option) (*Transport, error)

+ func NewWithClient(client API, opts ...Option) *Transport

+ func (t *Transport) Ack(ctx context.Context, msg *babelqueue.ReceivedMessage) error

+ func (t *Transport) Pop(ctx context.Context, queue string, timeout time.Duration) (*babelqueue.ReceivedMessage, error)

+ func (t *Transport) Publish(ctx context.Context, queue, body string) error