storage

Jan 5, 2022

Changes in this version

type OutboxEntry

+ Namespace string

+ func (OutboxEntry) TableName() string

Jul 10, 2021

Changes in this version

+ func DatabaseFromContext(ctx context.Context) *gorm.DB

+ func WithDatabase(ctx context.Context, txn *gorm.DB) context.Context

type Storage

+ GetTxn func(ctx context.Context) *gorm.DB

+ func (s *Storage) Publish(ctx context.Context, messages ...outbox.Message) error

+ func (s *Storage) PublishWithTxn(ctx context.Context, txn *gorm.DB, messages ...outbox.Message) error

May 22, 2021

Changes in this version

+ type IDGenerator interface

+ GenerateID func(clock clockwork.Clock, message outbox.Message) string

+ type OutboxEntry struct

+ ID string

+ Key []byte

+ Payload []byte

+ ProcessingDeadline *time.Time

+ ProcessorID string

+ type Storage struct

+ Clock clockwork.Clock

+ IDGenerator IDGenerator

+ func New(db *gorm.DB) *Storage

+ func (s *Storage) AutoMigrate() error

+ func (s *Storage) ClaimEntries(ctx context.Context, processorID string, claimDeadline time.Time) error

+ func (s *Storage) DeleteEntries(ctx context.Context, entryIDs ...string) error

+ func (s *Storage) GetClaimedEntries(ctx context.Context, processorID string, batchSize int) ([]outbox.ClaimedEntry, error)

+ func (s *Storage) Queue(ctx context.Context, txn *gorm.DB, messages ...outbox.Message) error

+ type UUIDGenerator struct

+ func (u *UUIDGenerator) GenerateID(clockwork.Clock, outbox.Message) string