Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DeliveryService ¶
type DeliveryService interface {
Deliver(ctx context.Context, message *repositories.OutboxMessage) error
}
func NewInProcessDeliveryService ¶
func NewInProcessDeliveryService() DeliveryService
func NewNoopDeliveryService ¶
func NewNoopDeliveryService() DeliveryService
type MessageBroker ¶
type MessageBroker interface {
Distribute(ctx context.Context, message *repositories.OutboxMessage) error
}
func NewMessageBroker ¶
func NewMessageBroker() MessageBroker
Click to show internal directories.
Click to hide internal directories.