Versions in this module Expand all Collapse all v0 v0.1.4 Nov 16, 2023 v0.1.3 Nov 16, 2023 Changes in this version + func InboxHandler(store InboxStore) async.MessageHandlerMiddleware + func OutboxPublisher(store OutboxStore) async.MessagePublisherMiddleware + type ErrDuplicateMessage string + func (e ErrDuplicateMessage) Error() string + type InboxStore interface + Save func(context.Context, async.IncomingMessage) error + type OutboxProcessor interface + Start func(ctx context.Context) error + func NewOutboxProcessor(publisher async.MessagePublisher, store OutboxStore) OutboxProcessor + type OutboxStore interface + FindUnpublished func(context.Context, int) ([]async.Message, error) + MarkPublished func(context.Context, ...string) error + Save func(context.Context, async.Message) error
Go to main page