eventsource

type AggregateCommand interface {
	AggregateID() string
}

type AggregateHandler interface {
	command.Handler
}

type AggregateRepository struct {
	Marshaler EventMarshaler
	// contains filtered or unexported fields
}

type AggregateRoot interface {
	AggregateRootID() string
	GetVersion() int
	StreamSize() int
	On(e Event) error
	Apply(aggr AggregateRoot, e Event, isNew bool) error
	LoadFromHistory(aggr AggregateRoot, history []Event) error
	GetUncommitedEvents() []Event
	CommitEvents()
}

type AggregateRootBase struct {
	ID string

	Version int
	// contains filtered or unexported fields
}

type AggregateRootRepository interface {
	New() interface{}
	Save(ctx context.Context, agr AggregateRoot) error
	GetByID(ctx context.Context, aggregateRootID string) (AggregateRoot, error)
}

type AggregateRootSnapshotRepository interface {
	Save(ctx context.Context, snap Snapshot) error
	GetByID(ctx context.Context, aggregateRootID string, version int) (Snapshot, error)
}

type Command struct {
	ID string
}

type Constructor interface {
	New() bool
}

type EpochMillis int64

type Event interface {
	// AggregateID returns the aggregate id of the event
	AggregateID() string

	// Version contains version number of aggregate
	EventVersion() int

	// At indicates when the event took place
	EventAt() time.Time
}

type EventMarshaler interface {
	Bind(e ...Event) error
	Marshal(e Event) (EventModel, error)
	Unmarshal(e EventModel) (Event, error)
}

type EventModel struct {
	// Version is the event version the Data represents
	Version int

	// At indicates when the event happened; provided as a utility for the store
	At EpochMillis

	// Data contains the Serializer encoded version of the data
	Data []byte
}

type EventSkeleton struct {
	// ID contains the AggregateID
	ID string

	// Version holds the event version
	Version int

	// At contains the event time
	At time.Time
}

type EventStore interface {
	SaveEvents(ctx context.Context, aggrID string, models History, version int) error
	GetEventsForAggregate(ctx context.Context, aggrID string, version int) (History, error)
}

type History []EventModel

type JsonEventMarshaler struct {
	// contains filtered or unexported fields
}

type JsonSnapshotMarshaler struct {
	// contains filtered or unexported fields
}

type Option func(r *AggregateRepository)

type Snapshot interface {
	CurrentVersion() int
	GetState() interface{}
	AggregateRootID() string
}

type SnapshotMarshaler interface {
	Bind(v ...interface{}) error
	Marshal(s Snapshot) (SnapshotModel, error)
	Unmarshal(m SnapshotModel) (Snapshot, error)
}

type SnapshotModel struct {
	ID      string
	Version int
	Data    []byte
}

type SnapshotRepository struct {
	// contains filtered or unexported fields
}

type SnapshotSkeleton struct {
	ID      string
	Version int
	State   interface{}
}

type SnapshotStore interface {
	SaveSnapshot(ctx context.Context, agrID string, model SnapshotModel, version int) error
	GetSnapshotForAggregate(ctx context.Context, agrID string, version int) (SnapshotModel, error)
}

type SnapshottingBehaviour interface {
	AggregateRoot
	SnapshotInterval() int
	GetState() interface{}
	ApplyState(s Snapshot)
	SnapshottingEnable() bool
}