eventbus

Documentation

Index

• Constants
• Variables
• func Once(ctx context.Context, bus cqrs.EventBus, typ cqrs.EventType, opts ...OnceOption) (<-chan cqrs.Event, error)
• func TestPublish(ctx context.Context, t *testing.T, bus cqrs.EventBus)
• type OnceOption
  • func OnceMatch(matchers ...cqrs.EventMatcher) OnceOption
  • func OnceTimeout(d time.Duration) OnceOption
• type TestEventData

Constants

const (
	// TestEventType is the EventType used for testing.
	TestEventType = cqrs.EventType("test.event")
	// TestAggregateType is the AggregateType used for testing.
	TestAggregateType = cqrs.AggregateType("test.aggregate")
)

Variables

var (
	// TestEventConfig is the EventConfig used for testing.
	TestEventConfig = event.Config()
)

Functions

func Once

func Once(ctx context.Context, bus cqrs.EventBus, typ cqrs.EventType, opts ...OnceOption) (<-chan cqrs.Event, error)

Once ...

func TestPublish

func TestPublish(ctx context.Context, t *testing.T, bus cqrs.EventBus)

TestPublish tests the Publish function of an EventBus implementation.

Types

type OnceOption

type OnceOption func(*onceConfig)

OnceOption ...

func OnceMatch

func OnceMatch(matchers ...cqrs.EventMatcher) OnceOption

OnceMatch ...

func OnceTimeout

func OnceTimeout(d time.Duration) OnceOption

OnceTimeout ...

type TestEventData

type TestEventData struct {
	A int
	B string
	C bool
}

TestEventData is used for testing EventBus implementations.