tm

Documentation

Index

• func NewInboxHandlerMiddleware(store InboxStore) am.RawMessageHandlerMiddleware
• func NewOutboxStreamMiddleware(store OutboxStore) am.RawMessageStreamMiddleware
• type ErrDuplicateMessage
  • func (e ErrDuplicateMessage) Error() string
• type InboxStore
• type OutboxProcessor
  • func NewOutboxProcessor(publisher am.RawMessagePublisher, store OutboxStore) OutboxProcessor
• type OutboxStore

Functions

func NewInboxHandlerMiddleware

func NewInboxHandlerMiddleware(store InboxStore) am.RawMessageHandlerMiddleware

func NewOutboxStreamMiddleware

func NewOutboxStreamMiddleware(store OutboxStore) am.RawMessageStreamMiddleware

Types

type ErrDuplicateMessage

type ErrDuplicateMessage string

func (ErrDuplicateMessage) Error

func (e ErrDuplicateMessage) Error() string

type InboxStore

type InboxStore interface {
	Save(ctx context.Context, msg am.RawMessage) error
}

type OutboxProcessor

type OutboxProcessor interface {
	Start(ctx context.Context) error
}

func NewOutboxProcessor

func NewOutboxProcessor(publisher am.RawMessagePublisher, store OutboxStore) OutboxProcessor

type OutboxStore

type OutboxStore interface {
	Save(ctx context.Context, msg am.RawMessage) error
	FindUnpublished(ctx context.Context, limit int) ([]am.RawMessage, error)
	MarkPublished(ctx context.Context, ids ...string) error
}