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