Documentation
¶
Index ¶
- Constants
- func CompareEvents(e1, e2 eh.Event) error
- func ContextOne(ctx context.Context) (string, bool)
- func WithContextOne(ctx context.Context, val string) context.Context
- type Aggregate
- type AggregateStore
- type Command
- type CommandHandler
- type CommandOther
- type CommandOther2
- type EmptyAggregate
- type EventBus
- type EventData
- type EventHandler
- type EventObserver
- type EventPublisher
- type EventStore
- type Model
- type Repo
- type SimpleModel
Constants ¶
const ( // AggregateType is the type for Aggregate. AggregateType eh.AggregateType = "Aggregate" // EventType is a the type for Event. EventType eh.EventType = "Event" // EventOtherType is the type for EventOther. EventOtherType eh.EventType = "EventOther" // CommandType is the type for Command. CommandType eh.CommandType = "Command" // CommandOtherType is the type for CommandOther. CommandOtherType eh.CommandType = "CommandOther" // CommandOther2Type is the type for CommandOther2. CommandOther2Type eh.CommandType = "CommandOther2" )
Variables ¶
This section is empty.
Functions ¶
func CompareEvents ¶
CompareEvents compares two events, ignoring their version and timestamp.
func ContextOne ¶
ContextOne returns a value for One from the context.
Types ¶
type Aggregate ¶
type Aggregate struct {
ID eh.UUID
Commands []eh.Command
Context context.Context
// Used to simulate errors in HandleCommand.
Err error
}
Aggregate is a mocked eventhorizon.Aggregate, useful in testing.
func (*Aggregate) AggregateType ¶
func (a *Aggregate) AggregateType() eh.AggregateType
AggregateType implements the AggregateType method of the eventhorizon.Aggregate interface.
type AggregateStore ¶
type AggregateStore struct {
Aggregates map[eh.UUID]eh.Aggregate
Context context.Context
// Used to simulate errors in HandleCommand.
Err error
}
AggregateStore is a mocked AggregateStore, useful in testing.
type Command ¶
Command is a mocked eventhorizon.Command, useful in testing.
func (Command) AggregateID ¶
func (Command) AggregateType ¶
func (t Command) AggregateType() eh.AggregateType
func (Command) CommandType ¶
func (t Command) CommandType() eh.CommandType
type CommandHandler ¶
type CommandHandler struct {
Commands []eh.Command
Context context.Context
// Used to simulate errors when handling.
Err error
}
CommandHandler is a mocked eventhorizon.CommandHandler, useful in testing.
func (*CommandHandler) HandleCommand ¶
HandleCommand implements the HandleCommand method of the eventhorizon.CommandHandler interface.
type CommandOther ¶
CommandOther is a mocked eventhorizon.Command, useful in testing.
func (CommandOther) AggregateID ¶
func (t CommandOther) AggregateID() eh.UUID
func (CommandOther) AggregateType ¶
func (t CommandOther) AggregateType() eh.AggregateType
func (CommandOther) CommandType ¶
func (t CommandOther) CommandType() eh.CommandType
type CommandOther2 ¶
CommandOther2 is a mocked eventhorizon.Command, useful in testing.
func (CommandOther2) AggregateID ¶
func (t CommandOther2) AggregateID() eh.UUID
func (CommandOther2) AggregateType ¶
func (t CommandOther2) AggregateType() eh.AggregateType
func (CommandOther2) CommandType ¶
func (t CommandOther2) CommandType() eh.CommandType
type EventBus ¶
type EventBus struct {
Events []eh.Event
Context context.Context
// Used to simulate errors in HandleCommand.
Err error
}
EventBus is a mocked eventhorizon.EventBus, useful in testing.
func (*EventBus) AddHandler ¶
func (b *EventBus) AddHandler(m eh.EventMatcher, h eh.EventHandler)
AddHandler implements the AddHandler method of the eventhorizon.EventBus interface.
type EventData ¶
type EventData struct {
Content string
}
EventData is a mocked event data, useful in testing.
type EventHandler ¶
type EventHandler struct {
Events []eh.Event
Context context.Context
Time time.Time
Recv chan eh.Event
// Used to simulate errors when publishing.
Err error
}
EventHandler is a mocked eventhorizon.EventHandler, useful in testing.
func NewEventHandler ¶
func NewEventHandler() *EventHandler
NewEventHandler creates a new EventHandler.
func (*EventHandler) HandleEvent ¶
HandleEvent implements the HandleEvent method of the eventhorizon.EventHandler interface.
func (*EventHandler) WaitForEvent ¶
func (m *EventHandler) WaitForEvent() error
WaitForEvent is a helper to wait until an event has been handled, it timeouts after 1 second.
type EventObserver ¶
EventObserver is a mocked eventhorizon.EventObserver, useful in testing.
func NewEventObserver ¶
func NewEventObserver() *EventObserver
NewEventObserver creates a new EventObserver.
func (*EventObserver) Notify ¶
func (m *EventObserver) Notify(ctx context.Context, event eh.Event)
Notify implements the Notify method of the eventhorizon.EventHandler interface.
func (*EventObserver) WaitForEvent ¶
func (m *EventObserver) WaitForEvent() error
WaitForEvent is a helper to wait until an event has been notified, it timeouts after 1 second.
type EventPublisher ¶
type EventPublisher struct {
Events []eh.Event
Context context.Context
Recv chan eh.Event
Observers []eh.EventObserver
// Used to simulate errors when publishing.
Err error
}
EventPublisher is a mocked eventhorizon.EventPublisher, useful in testing.
func NewEventPublisher ¶
func NewEventPublisher() *EventPublisher
NewEventPublisher creates a new EventPublisher.
func (*EventPublisher) AddObserver ¶
func (m *EventPublisher) AddObserver(o eh.EventObserver)
AddObserver implements the AddObserver method of the eventhorizon.EventPublisher interface.
func (*EventPublisher) HandleEvent ¶
HandleEvent implements the HandleEvent method of the eventhorizon.EventPublisher interface.
func (*EventPublisher) WaitForEvent ¶
func (m *EventPublisher) WaitForEvent() error
WaitForEvent is a helper to wait until an event has been notified, it timeouts after 1 second.
type EventStore ¶
type EventStore struct {
Events []eh.Event
Loaded eh.UUID
Context context.Context
// Used to simulate errors in the store.
Err error
}
EventStore is a mocked eventhorizon.EventStore, useful in testing.
type Model ¶
type Model struct {
ID eh.UUID `json:"id" bson:"_id"`
Version int `json:"version" bson:"version"`
Content string `json:"content" bson:"content"`
CreatedAt time.Time `json:"created_at" bson:"created_at"`
}
Model is a mocked read model, useful in testing.
func (*Model) AggregateVersion ¶
AggregateVersion implements the AggregateVersion method of the eventhorizon.Versionable interface.
type Repo ¶
type Repo struct {
ParentRepo eh.ReadWriteRepo
Entity eh.Entity
Entities []eh.Entity
// Used to simulate errors in the store.
LoadErr, SaveErr error
FindCalled, FindAllCalled, SaveCalled, RemoveCalled bool
}
Repo is a mocked eventhorizon.ReadRepo, useful in testing.
func (*Repo) FindAll ¶
FindAll implements the FindAll method of the eventhorizon.ReadRepo interface.
type SimpleModel ¶
type SimpleModel struct {
ID eh.UUID `json:"id" bson:"_id"`
Content string `json:"content" bson:"content"`
}
SimpleModel is a mocked read model, useful in testing, without a version.
func (*SimpleModel) EntityID ¶
func (m *SimpleModel) EntityID() eh.UUID
EntityID implements the EntityID method of the eventhorizon.Entity interface.
Source Files