Documentation
¶
Overview ¶
Code generated by go generate
Index ¶
- func BindEvents(binder rangedb.EventBinder)
- func NewCountSubscriber() *countSubscriber
- func NewFailingDeserializer() *failingDeserializer
- func NewFailingEventStore() *failingEventStore
- func NewFailingSerializer() *failingSerializer
- func NewTotalEventsSubscriber() *totalEventsSubscriber
- func VerifyRecordIoStream(t *testing.T, newIoStream func() rangedb.RecordIoStream)
- func VerifyRecordSerializer(t *testing.T, newSerializer func() rangedb.RecordSerializer)
- func VerifyStore(t *testing.T, newStore func(t *testing.T, clock clock.Clock) rangedb.Store)
- type AnotherWasComplete
- type EventSaver
- type ThatWasDone
- type ThingWasDone
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BindEvents ¶ added in v0.2.1
func BindEvents(binder rangedb.EventBinder)
func NewCountSubscriber ¶
func NewCountSubscriber() *countSubscriber
func NewFailingDeserializer ¶ added in v0.2.0
func NewFailingDeserializer() *failingDeserializer
func NewFailingEventStore ¶ added in v0.2.5
func NewFailingEventStore() *failingEventStore
func NewFailingSerializer ¶ added in v0.2.0
func NewFailingSerializer() *failingSerializer
func NewTotalEventsSubscriber ¶ added in v0.3.0
func NewTotalEventsSubscriber() *totalEventsSubscriber
func VerifyRecordIoStream ¶
func VerifyRecordIoStream(t *testing.T, newIoStream func() rangedb.RecordIoStream)
VerifyRecordIoStream verifies the RecordIoStream interface.
func VerifyRecordSerializer ¶
func VerifyRecordSerializer(t *testing.T, newSerializer func() rangedb.RecordSerializer)
VerifyRecordSerializer verifies the RecordSerializer interface.
Types ¶
type AnotherWasComplete ¶
type AnotherWasComplete struct {
ID string `json:"id"`
}
AnotherWasComplete is an event used for testing.
func (AnotherWasComplete) AggregateID ¶
func (t AnotherWasComplete) AggregateID() string
AggregateID returns the aggregate id.
func (AnotherWasComplete) AggregateType ¶
func (t AnotherWasComplete) AggregateType() string
AggregateType returns the aggregate type.
func (AnotherWasComplete) EventType ¶
func (t AnotherWasComplete) EventType() string
EventType returns the event type. This will always be the struct name.
type EventSaver ¶ added in v0.2.6
type ThatWasDone ¶
type ThatWasDone struct {
ID string
}
ThatWasDone is an event used for testing.
func (ThatWasDone) AggregateID ¶
func (t ThatWasDone) AggregateID() string
AggregateID returns the aggregate id.
func (ThatWasDone) AggregateType ¶
func (t ThatWasDone) AggregateType() string
AggregateType returns the aggregate type.
func (ThatWasDone) EventType ¶
func (t ThatWasDone) EventType() string
EventType returns the event type. This will always be the struct name.
type ThingWasDone ¶
ThingWasDone is an event used for testing.
func (ThingWasDone) AggregateID ¶
func (t ThingWasDone) AggregateID() string
AggregateID returns the aggregate id.
func (ThingWasDone) AggregateType ¶
func (t ThingWasDone) AggregateType() string
AggregateType returns the aggregate type.
func (ThingWasDone) EventType ¶
func (t ThingWasDone) EventType() string
EventType returns the event type. This will always be the struct name.
Source Files