testhelper

Documentation

Index

• type OutboxHelpers
  • func (oh *OutboxHelpers) WaitUntilBusEmpty(ctx context.Context, timeout time.Duration, interval time.Duration, ...) error
  • func (oh *OutboxHelpers) WaitUntilEventProcessed(ctx context.Context, timeout time.Duration, interval time.Duration, ...) error
  • func (oh *OutboxHelpers) WaitUntilOutboxEmpty(ctx context.Context, timeout time.Duration, interval time.Duration, ...) error
• type TestHelper
  • func (th *TestHelper) Outbox() (*OutboxHelpers, error)

Types

type OutboxHelpers

type OutboxHelpers struct {
	// contains filtered or unexported fields
}

func (*OutboxHelpers) WaitUntilBusEmpty

func (oh *OutboxHelpers) WaitUntilBusEmpty(ctx context.Context, timeout time.Duration, interval time.Duration, streamName string, consumerName string) error

func (*OutboxHelpers) WaitUntilEventProcessed

func (oh *OutboxHelpers) WaitUntilEventProcessed(ctx context.Context, timeout time.Duration, interval time.Duration, outboxTableName string, streamName string, consumerName string) error

func (*OutboxHelpers) WaitUntilOutboxEmpty

func (oh *OutboxHelpers) WaitUntilOutboxEmpty(ctx context.Context, timeout time.Duration, interval time.Duration, outboxTableName string) error

type TestHelper

type TestHelper struct {
	DB  db.DB
	Bus bus.Bus
}

func (*TestHelper) Outbox

func (th *TestHelper) Outbox() (*OutboxHelpers, error)