Documentation
¶
Index ¶
- func HandleCompleted(bus eventbus.Bus, uow repository.UnitOfWork, logger *slog.Logger) func(ctx context.Context, e events.Event) error
- func HandleCurrencyConverted(bus eventbus.Bus, uow repository.UnitOfWork, logger *slog.Logger) func(ctx context.Context, e events.Event) error
- func HandleRequested(bus eventbus.Bus, uow repository.UnitOfWork, logger *slog.Logger) func(ctx context.Context, e events.Event) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func HandleCompleted ¶
func HandleCompleted( bus eventbus.Bus, uow repository.UnitOfWork, logger *slog.Logger, ) func( ctx context.Context, e events.Event, ) error
HandleCompleted handles the final, atomic persistence of a transfer.
func HandleCurrencyConverted ¶
func HandleCurrencyConverted( bus eventbus.Bus, uow repository.UnitOfWork, logger *slog.Logger, ) func( ctx context.Context, e events.Event, ) error
HandleCurrencyConverted performs domain validation after currency conversion for transfers. Emits TransferBusinessValidated event to trigger final persistence.
func HandleRequested ¶
func HandleRequested( bus eventbus.Bus, uow repository.UnitOfWork, logger *slog.Logger, ) func( ctx context.Context, e events.Event, ) error
HandleRequested handles TransferValidatedEvent, creates an initial 'pending' transaction, and triggers conversion.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.