fake

Jan 5, 2022

Changes in this version

+ type PublishedMessage struct

+ Namespace string

May 22, 2021

Changes in this version

+ type Clock interface

+ Now func() time.Time

+ type EntryStorage struct

+ Clock Clock

+ func (e *EntryStorage) ClaimEntries(_ context.Context, processorID string, claimDeadline time.Time) error

+ func (e *EntryStorage) CountEntries() int

+ func (e *EntryStorage) DeleteEntries(_ context.Context, entryIDs ...string) error

+ func (e *EntryStorage) GetClaimedEntries(_ context.Context, processorID string, batchSize int) ([]outbox.ClaimedEntry, error)

+ func (e *EntryStorage) Publish(_ context.Context, messages ...outbox.Message) error

+ type Publisher struct

+ Logger logr.Logger

+ func (p *Publisher) Clear() []outbox.Message

+ func (p *Publisher) GetPublished() []outbox.Message

+ func (p *Publisher) GetPublishedCount() int

+ func (p *Publisher) Publish(_ context.Context, messages ...outbox.Message) error