Versions in this module Expand all Collapse all v1 v1.0.2 Nov 14, 2023 v1.0.1 Nov 1, 2023 Changes in this version + var ErrSequenceNotMatched = errors.New("sequence of aggregate did not match") + var MultiToken = Subject(multiToken{}) + var SingleToken = Subject(singleToken{}) + func FilterBenchTests(ctx context.Context, b *testing.B, store TestEventstore) + func FilterComplianceTests(ctx context.Context, t *testing.T, store TestEventstore) + func PushComplianceTests(ctx context.Context, t *testing.T, store TestEventstore) + func PushParallelOnDifferentAggregates(ctx context.Context, b *testing.B, store TestEventstore) + func PushParallelOnSameAggregate(ctx context.Context, b *testing.B, store TestEventstore) + type Action interface + Action func() TextSubjects + Revision func() uint16 + type Aggregate interface + Commands func() []Command + ID func() TextSubjects + type AggregatePredefinedSequence interface + CurrentSequence func() uint32 + type Command interface + Payload func() any + SetCreationDate func(creationDate time.Time) + SetSequence func(sequence uint32) + type CreatedAtFilter struct + From time.Time + To time.Time + type Event interface + Aggregate func() TextSubjects + CreationDate func() time.Time + Sequence func() uint32 + UnmarshalPayload func(object any) error + type Eventstore interface + Filter func(ctx context.Context, filter *Filter, reducer Reducer) error + Push func(ctx context.Context, aggregates ...Aggregate) error + Ready func(ctx context.Context) error + type Filter struct + Limit uint64 + Queries []*FilterQuery + type FilterQuery struct + CreatedAt CreatedAtFilter + Sequence SequenceFilter + Subjects []Subject + type Reducer interface + Reduce func(events ...Event) error + type SequenceFilter struct + From uint32 + To uint32 + type Subject interface + type TestEventstore interface + After func(ctx context.Context, t testing.TB) error + Before func(ctx context.Context, t testing.TB) error + type TextSubject string + type TextSubjects []TextSubject + func (ts TextSubjects) Compare(comp ...Subject) bool + func (ts TextSubjects) Join(sep string) string Other modules containing this package github.com/adlerhurst/eventstore/v2