dynamodbqueue

type FifoQueue interface {
	Queue

	// PushMessagesWithGroup pushes messages to a specific message group.
	// Messages in the same group are delivered in strict FIFO order.
	// Only one message per group can be in-flight at a time.
	PushMessagesWithGroup(ctx context.Context, ttl time.Duration, messageGroup string, messages ...events.SQSMessage) ([]events.SQSMessage, error)
}

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

type Queue interface {
	// UseTable sets the DynamoDB table name for the queue.
	UseTable(table string) Queue

	// UseQueueName sets the queue name (part of the partition key).
	UseQueueName(queueName string) Queue

	// UseClientID sets the client ID (part of the partition key).
	UseClientID(clientID string) Queue

	// UseSigningKey sets a persistent HMAC signing key for receipt handle verification.
	// This allows receipt handles to survive instance restarts and be verified across
	// different queue instances sharing the same key.
	// The key must be at least MinSigningKeyLength (32) bytes; validation occurs at operation time.
	// If not called, a random key is generated per instance (default behavior).
	UseSigningKey(key []byte) Queue

	// SetLogging enables or disables logging for queue operations.
	SetLogging(enabled bool)

	// Logging returns true if logging is enabled.
	Logging() bool

	// Table returns the DynamoDB table name.
	Table() string

	// QueueName returns the queue name.
	QueueName() string

	// ClientID returns the client ID.
	ClientID() string

	// PartitionKey returns the combined partition key (queueName|clientID).
	PartitionKey() string

	// RandomDigits returns the number of random digits appended to SK.
	RandomDigits() int

	// PushMessages pushes one or more messages onto the queue.
	// Maximum of 25 messages allowed per call.
	// Returns any messages that failed to send along with an error.
	PushMessages(ctx context.Context, ttl time.Duration, messages ...events.SQSMessage) ([]events.SQSMessage, error)

	// PollMessages polls messages from the queue using SQS-compatible semantics.
	// timeout: Maximum time to wait for minMessages.
	// visibilityTimeout: How long messages are hidden after being returned.
	// minMessages: Minimum messages to collect before returning.
	// maxMessages: Maximum messages to return.
	PollMessages(ctx context.Context, timeout, visibilityTimeout time.Duration, minMessages, maxMessages int) ([]events.SQSMessage, error)

	// DeleteMessages deletes messages using their receipt handles.
	// Returns receipt handles that failed to delete.
	DeleteMessages(ctx context.Context, receiptHandles ...string) ([]string, error)

	// Count returns the number of messages in the queue.
	Count(ctx context.Context) (int32, error)

	// Purge deletes all messages from the queue.
	Purge(ctx context.Context) error

	// PurgeAll deletes all items from the DynamoDB table.
	PurgeAll(ctx context.Context) error

	// List returns all queue/clientID combinations in the table.
	List(ctx context.Context) ([]QueueAndClientID, error)

	// CreateQueueTable creates the DynamoDB table for the queue.
	// Returns true if created, false if it already exists.
	CreateQueueTable(ctx context.Context) (bool, error)

	// DropQueueTable drops the DynamoDB table.
	DropQueueTable(ctx context.Context) error

	// TableExists returns true if the table exists.
	TableExists(ctx context.Context) bool

	// Type returns the queue type (Standard or FIFO).
	Type() QueueType
}

type QueueAndClientID struct {
	QueueName string `json:"qn"`
	ClientID  string `json:"cid"`
}

type QueueType int

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