Documentation
¶
Overview ¶
Package repository provides data persistence implementations for outbox entities.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OutboxEventRepository ¶
type OutboxEventRepository struct {
// contains filtered or unexported fields
}
OutboxEventRepository handles outbox event persistence
func NewOutboxEventRepository ¶
func NewOutboxEventRepository(db *sql.DB, driver string) *OutboxEventRepository
NewOutboxEventRepository creates a new OutboxEventRepository
func (*OutboxEventRepository) Create ¶
func (r *OutboxEventRepository) Create(ctx context.Context, event *domain.OutboxEvent) error
Create inserts a new outbox event
func (*OutboxEventRepository) GetPendingEvents ¶
func (r *OutboxEventRepository) GetPendingEvents(ctx context.Context, limit int) ([]*domain.OutboxEvent, error)
GetPendingEvents retrieves pending events with limit
func (*OutboxEventRepository) Update ¶
func (r *OutboxEventRepository) Update(ctx context.Context, event *domain.OutboxEvent) error
Update updates an outbox event
Source Files
Click to show internal directories.
Click to hide internal directories.