tm

Documentation

Index

• func InboxHandler(store InboxStore) am.MessageHandlerMiddleware
• func OutboxPublisher(store OutboxStore) am.MessagePublisherMiddleware
• type ErrDuplicateMessage
  • func (e ErrDuplicateMessage) Error() string
• type InboxStore
• type OutboxProcessor
  • func NewOutboxProcessor(publisher am.MessagePublisher, store OutboxStore) OutboxProcessor
• type OutboxStore

Functions

func InboxHandler

func InboxHandler(store InboxStore) am.MessageHandlerMiddleware

func OutboxPublisher

func OutboxPublisher(store OutboxStore) am.MessagePublisherMiddleware

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.IncomingMessage) error
}

type OutboxProcessor

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

func NewOutboxProcessor

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

type OutboxStore

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