Versions in this module Expand all Collapse all v1 v1.0.0 Feb 18, 2024 Changes in this version + type Repository struct + func New(txKey repository.TxKey, db *gorm.DB) *Repository + func (r *Repository) AcquireLock(dispatcherId uuid.UUID) (bool, error) + func (r *Repository) DeleteInBatches(batchSize int, records []uuid.UUID) error + func (r *Repository) FindInBatches(batchSize int, limit int, fc func([]*repository.OutboxRecord) error) error + func (r *Repository) ReleaseLock(dispatcherId uuid.UUID) error + func (r *Repository) Save(ctx context.Context, o *repository.OutboxRecord) error + func (r *Repository) SetLogger(l logger.Logger) + func (r *Repository) SubscribeDispatcher(dispatcherId uuid.UUID, maxDispatchers int) (bool, int, error) + func (r *Repository) UpdateSubscription(dispatcherId uuid.UUID) (bool, error)