fake

type Clock ¶

type Clock interface {
	Now() time.Time
}

Clock abstracts the time package

type EntryStorage ¶

type EntryStorage struct {
	// Clock abstracts the time package
	Clock Clock
	// contains filtered or unexported fields
}

EntryStorage is a simple fake implementation of two outbox interfaces:

• outbox.ProcessorStorage: for use directly by the outbox.Outbox to process Outbox ClaimedEntry objects
• outbox.Publisher: for applications to treat as the outbox.Outbox that records their messages during a transaction

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(ctx context.Context, _ interface{}, messages ...outbox.Message) error

type PublishedMessage ¶

type PublishedMessage struct {
	outbox.Message

	Namespace string
}

type Publisher ¶

type Publisher struct {
	// Logger can be provided to receive log output
	Logger logr.Logger
	// contains filtered or unexported fields
}

Publisher is a simple in-memory fake for publishing messages. As it doesn't actually deliver messages anywhere, even in-memory particularly, it's almost a mock instead of a fake, but it does function without configuration from the caller's point of view.

func (p *Publisher) Clear() []PublishedMessage

func (p *Publisher) GetPublished() []PublishedMessage

func (p *Publisher) GetPublishedCount() int

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