dynamodbqueue

package

Go to main page

Versions in this module

v0

v0.11.0

Feb 18, 2026

Changes in this version

+ const MinSigningKeyLength

+ var ErrSigningKeyTooShort = errors.New("signing key too short: minimum 32 bytes required for HMAC-SHA256")

type FifoQueueImpl

+ func (fq *FifoQueueImpl) UseSigningKey(key []byte) Queue

type Queue

+ UseSigningKey func(key []byte) Queue

type StandardQueue

+ func (sq *StandardQueue) UseSigningKey(key []byte) Queue

v0.10.2

Jan 31, 2026

Changes in this version

+ const MaxMessageBodySize

+ var ErrAttributeNotFound = errors.New("attribute not found")

+ var ErrAttributeNotNumber = errors.New("attribute is not a number")

+ var ErrAttributeNotString = errors.New("attribute is not a string")

+ var ErrBatchWriteRetries = errors.New("batch write failed after max retries")

+ var ErrClientIDNotSet = errors.New("client ID not set")

+ var ErrExpressionBuild = errors.New("failed to build DynamoDB expression")

+ var ErrInvalidClientID = errors.New("invalid client ID: must be 1-64 chars without | or & separators")

+ var ErrInvalidQueueName = errors.New("invalid queue name: must be 1-64 chars without | or & separators")

+ var ErrMessageTooLarge = errors.New("message body exceeds maximum size")

+ var ErrQueueNameNotSet = errors.New("queue name not set")

+ var ErrTableNameNotSet = errors.New("table name not set")

+ var ErrTooManyMessages = errors.New("maximum of 25 messages allowed")

+ type QueueAndClientID struct

+ ClientID string

+ QueueName string

v0.10.0

Jan 30, 2026

Changes in this version

+ const ColumnMessageGroup

+ const DefaultMessageGroup

+ const MinRandomDigits

+ type FifoQueue interface

+ PushMessagesWithGroup func(ctx context.Context, ttl time.Duration, messageGroup string, ...) ([]events.SQSMessage, error)

+ type FifoQueueImpl struct

+ func NewFifoQueue(client *dynamodb.Client, ttl time.Duration) *FifoQueueImpl

+ func (bq FifoQueueImpl) Client() *dynamodb.Client

+ func (bq FifoQueueImpl) ClientID() string

+ func (bq FifoQueueImpl) DefaultTTL() time.Duration

+ func (bq FifoQueueImpl) Logging() bool

+ func (bq FifoQueueImpl) PartitionKey() string

+ func (bq FifoQueueImpl) QueueName() string

+ func (bq FifoQueueImpl) RandomDigits() int

+ func (bq FifoQueueImpl) SetLogging(enabled bool)

+ func (bq FifoQueueImpl) Table() string

+ func (bq FifoQueueImpl) Type() QueueType

+ func (fq *FifoQueueImpl) Count(ctx context.Context) (int32, error)

+ func (fq *FifoQueueImpl) CreateQueueTable(ctx context.Context) (bool, error)

+ func (fq *FifoQueueImpl) DeleteMessages(ctx context.Context, receiptHandles ...string) ([]string, error)

+ func (fq *FifoQueueImpl) DropQueueTable(ctx context.Context) error

+ func (fq *FifoQueueImpl) List(ctx context.Context) ([]QueueAndClientId, error)

+ func (fq *FifoQueueImpl) PollMessages(ctx context.Context, timeout, visibilityTimeout time.Duration, ...) ([]events.SQSMessage, error)

+ func (fq *FifoQueueImpl) Purge(ctx context.Context) error

+ func (fq *FifoQueueImpl) PurgeAll(ctx context.Context) error

+ func (fq *FifoQueueImpl) PushMessages(ctx context.Context, ttl time.Duration, messages ...events.SQSMessage) ([]events.SQSMessage, error)

+ func (fq *FifoQueueImpl) PushMessagesWithGroup(ctx context.Context, ttl time.Duration, messageGroup string, ...) ([]events.SQSMessage, error)

+ func (fq *FifoQueueImpl) TableExists(ctx context.Context) bool

+ func (fq *FifoQueueImpl) UseClientID(clientID string) Queue

+ func (fq *FifoQueueImpl) UseQueueName(queueName string) Queue

+ func (fq *FifoQueueImpl) UseTable(table string) Queue

+ type Queue interface

+ ClientID func() string

+ Count func(ctx context.Context) (int32, error)

+ CreateQueueTable func(ctx context.Context) (bool, error)

+ DeleteMessages func(ctx context.Context, receiptHandles ...string) ([]string, error)

+ DropQueueTable func(ctx context.Context) error

+ List func(ctx context.Context) ([]QueueAndClientId, error)

+ Logging func() bool

+ PartitionKey func() string

+ PollMessages func(ctx context.Context, timeout, visibilityTimeout time.Duration, ...) ([]events.SQSMessage, error)

+ Purge func(ctx context.Context) error

+ PurgeAll func(ctx context.Context) error

+ PushMessages func(ctx context.Context, ttl time.Duration, messages ...events.SQSMessage) ([]events.SQSMessage, error)

+ QueueName func() string

+ RandomDigits func() int

+ SetLogging func(enabled bool)

+ Table func() string

+ TableExists func(ctx context.Context) bool

+ Type func() QueueType

+ UseClientID func(clientID string) Queue

+ UseQueueName func(queueName string) Queue

+ UseTable func(table string) Queue

+ func NewWithClient(client *dynamodb.Client, ttl time.Duration, queueType ...QueueType) Queue

type QueueType

+ const QueueFIFO

+ const QueueStandard

+ type StandardQueue struct

+ func NewStandardQueue(client *dynamodb.Client, ttl time.Duration) *StandardQueue

+ func (bq StandardQueue) Client() *dynamodb.Client

+ func (bq StandardQueue) ClientID() string

+ func (bq StandardQueue) DefaultTTL() time.Duration

+ func (bq StandardQueue) Logging() bool

+ func (bq StandardQueue) PartitionKey() string

+ func (bq StandardQueue) QueueName() string

+ func (bq StandardQueue) RandomDigits() int

+ func (bq StandardQueue) SetLogging(enabled bool)

+ func (bq StandardQueue) Table() string

+ func (bq StandardQueue) Type() QueueType

+ func (sq *StandardQueue) Count(ctx context.Context) (int32, error)

+ func (sq *StandardQueue) CreateQueueTable(ctx context.Context) (bool, error)

+ func (sq *StandardQueue) DeleteMessages(ctx context.Context, receiptHandles ...string) ([]string, error)

+ func (sq *StandardQueue) DropQueueTable(ctx context.Context) error

+ func (sq *StandardQueue) List(ctx context.Context) ([]QueueAndClientId, error)

+ func (sq *StandardQueue) PollMessages(ctx context.Context, timeout, visibilityTimeout time.Duration, ...) ([]events.SQSMessage, error)

+ func (sq *StandardQueue) Purge(ctx context.Context) error

+ func (sq *StandardQueue) PurgeAll(ctx context.Context) error

+ func (sq *StandardQueue) PushMessages(ctx context.Context, ttl time.Duration, messages ...events.SQSMessage) ([]events.SQSMessage, error)

+ func (sq *StandardQueue) TableExists(ctx context.Context) bool

+ func (sq *StandardQueue) UseClientID(clientID string) Queue

+ func (sq *StandardQueue) UseQueueName(queueName string) Queue

+ func (sq *StandardQueue) UseTable(table string) Queue

v0.9.0

Oct 5, 2023

Changes in this version

type DynamoDBQueue

+ func (dq *DynamoDBQueue) Logging() bool

+ func (dq *DynamoDBQueue) SetLogging(enabled bool)

v0.8.0

Oct 5, 2023

v0.7.0

Oct 5, 2023

Changes in this version

+ const RecipientHandleSeparator

v0.6.0

Oct 4, 2023

Changes in this version

+ const PartitionKeySeparator

v0.5.0

Oct 4, 2023

v0.4.0

Oct 3, 2023

Changes in this version

type DynamoDBQueue

+ func New(cfg aws.Config, ttl time.Duration) *DynamoDBQueue

v0.3.0

Oct 3, 2023

Changes in this version

type DynamoDBQueue

+ func (dq *DynamoDBQueue) List(ctx context.Context) ([]QueueAndClientId, error)

+ type QueueAndClientId struct

+ ClientID string

+ QueueName string

v0.2.0

Oct 3, 2023

Changes in this version

type DynamoDBQueue

+ func (dq *DynamoDBQueue) TableExists(ctx context.Context) bool

v0.1.0

Oct 3, 2023

Changes in this version

+ const AttrSentTimestamp

+ const ClientIDNotSet

+ const ColumnEvent

+ const ColumnHiddenUntil

+ const ColumnOwner

+ const ColumnPK

+ const ColumnSK

+ const ColumnTTL

+ const QueueNameNotSet

+ const TableNameNotSet

+ func RandomInt(min, max int) int

+ func RandomPostfix(name string) string

+ func RandomString(n int) string

+ func ToBatches(items []T, batchSize int) [][]T

+ func ToReceiptHandles(msgs []events.SQSMessage) []string

+ type DynamoDBQueue struct

+ func NewDynamoDBQueue(ctx context.Context, cfg aws.Config, ttl time.Duration) *DynamoDBQueue

+ func (dp *DynamoDBQueue) AsQueueType(queueType QueueType) *DynamoDBQueue

+ func (dp *DynamoDBQueue) ClientID() string

+ func (dp *DynamoDBQueue) QueueName() string

+ func (dp *DynamoDBQueue) SetRandomDigits(digits int) *DynamoDBQueue

+ func (dp *DynamoDBQueue) Table() string

+ func (dq *DynamoDBQueue) Count(ctx context.Context) (int32, error)

+ func (dq *DynamoDBQueue) CreateQueueTable(ctx context.Context) (bool, error)

+ func (dq *DynamoDBQueue) DeleteMessages(ctx context.Context, receiptHandles ...string) ([]string, error)

+ func (dq *DynamoDBQueue) DropQueueTable(ctx context.Context) error

+ func (dq *DynamoDBQueue) PartitionKey() string

+ func (dq *DynamoDBQueue) PollMessages(ctx context.Context, timeout, visibilityTimeout time.Duration, maxMessages int) ([]events.SQSMessage, error)

+ func (dq *DynamoDBQueue) Purge(ctx context.Context) error

+ func (dq *DynamoDBQueue) PurgeAll(ctx context.Context) error

+ func (dq *DynamoDBQueue) PushMessages(ctx context.Context, ttl time.Duration, messages ...events.SQSMessage) ([]events.SQSMessage, error)

+ func (dq *DynamoDBQueue) RandomDigits() int

+ func (dq *DynamoDBQueue) UseClientID(clientID string) *DynamoDBQueue

+ func (dq *DynamoDBQueue) UseQueueName(queueName string) *DynamoDBQueue

+ func (dq *DynamoDBQueue) UseTable(table string) *DynamoDBQueue

+ type QueueType int

+ const QueueTypeFIFO

+ const QueueTypeLIFO

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL