queue

type DDBQueueItem struct {
	ID       string
	Data     QueueItem
	Locked   bool
	LockTime int64
	// contains filtered or unexported fields
}

type DynamoDBQueue struct {
	TableName string
	QueueName string
	// contains filtered or unexported fields
}

type Queue interface {
	// AddItem adds an item to the queue.
	AddItem(item QueueItem) error
	// GetNextItem returns the next item in the queue.
	GetNextItem() (QueueItem, error)
	// Done( QueueItem ) marks the item as done.
	Done(item QueueItem) error
}

type QueueItem struct {
	ID        string         `json:"id"`
	Data      map[string]any `json:"data"`
	CreatedAt int64          `json:"created_at"`
}