eventstore

type EventStore interface {
	Save(ctx context.Context, groupId string, aggregateId string, events []event.Event) (concurrencyException bool, err error)
	SaveSnapshot(ctx context.Context, groupId string, aggregateId string, event event.Event) (concurrencyException bool, err error)
	LoadUpToVersion(ctx context.Context, queries []VersionQuery, eventHandler event.Handler) error
	LoadFromVersion(ctx context.Context, queries []VersionQuery, eventHandler event.Handler) error
	LoadFromSnapshot(ctx context.Context, queries []SnapshotQuery, eventHandler event.Handler) error
	RemoveUpToVersion(ctx context.Context, queries []VersionQuery) error
}

type FactoryModelFunc func(ctx context.Context) (Model, error)

type GoroutinePoolGoFunc func(func()) error

type LogDebugfFunc func(fmt string, args ...interface{})

type Model interface {
	event.Handler
	SnapshotEventType() string
}

type Projection struct {
	LogDebugfFunc LogDebugfFunc
	// contains filtered or unexported fields
}

type SnapshotQuery struct {
	GroupId           string //filter by group Id and it is used only when aggreagateId is empty
	AggregateId       string //filter to certain aggregateId
	SnapshotEventType string //required
}

type VersionQuery struct {
	AggregateId string //required
	Version     uint64 //required
}