cqrs

type Aggregate interface {
	AggregateContext

	// AggregateName returns the type name of the aggregate.
	AggregateName() string

	// Apply applies an event to the aggregate by setting its values.
	Apply(Event) error
}

type AggregateBuilder func(aggregateId uuid.UUID) (Aggregate, error)

type AggregateCommand interface {
	Command
	AggregateName() string
}

type AggregateCommandHandlerFunc func(aggregate Aggregate, command Command) error

type AggregateComposition interface {
	Context() AggregateContext
	Aggregate() Aggregate
}

type AggregateContext interface {
	// AggregateId returns the id of the aggregate.
	AggregateId() uuid.UUID

	// Version returns the version of the aggregate.
	Version() int

	// StoreEvent stores an event as uncommitted event.
	StoreEvent(Event)
	// contains filtered or unexported methods
}

type AggregateFactory interface {
	//MakeAggregate will return a clean Aggregate based on the type provided
	MakeAggregate(string, AggregateContext) Aggregate
}

type AggregateFactoryFunc func(AggregateContext) Aggregate

type AggregateHandlesCommands interface {
	Aggregate

	// HandleCommand handles a command and stores events.
	HandleCommand(Command) error
}

type AggregateRepository interface {
	//Loads an aggregate of the given type and ID
	Load(aggregateId uuid.UUID) (Aggregate, error)

	//Saves the aggregate.
	Save(aggregate Aggregate) error
}

type AggregateRepositoryManager interface {
	//RepositoryFor will return the repository for the specific named aggregate
	RepositoryFor(aggregateName string) AggregateRepository
}

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

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

type Command interface {
	commandbus.Command
	AggregateId() uuid.UUID
}

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

type ErrorAggregateCannotHandleCommand string

type ErrorAggregateFactoryAlreadyRegistered string

type ErrorAggregateNotFound string

type ErrorEventFactoryAlreadyRegistered string

type ErrorEventFactoryNotReturningPointer string

type ErrorNotAnAggregateCommand string

type Event interface {
	eventbus.Event
	EventBase
}

type EventBase interface {
	AggregateId() uuid.UUID
	Version() int
	OccurredAt() time.Time
}

type EventFactory interface {
	MakeEvent(string, uuid.UUID, int, time.Time) Event
}

type EventFactoryFunc func(uuid.UUID, int, time.Time) Event

type EventStore interface {
	LoadStream(aggregateName string, aggregateId uuid.UUID, version int) (EventStream, error)
	WriteEvent(string, ...Event) error
}

type EventStream interface {
	EventName() string
	AggregateId() uuid.UUID
	Version() int
	OccurredAt() time.Time

	Next() bool
	Error() error
	Scan(Event) error
}

type PublishEventFunc func(event Event)

type SnapshotStore interface {
	Load(aggregateId uuid.UUID, aggregate Aggregate) (int, error)
	Write(aggregate Aggregate) error
}

type Validate interface {
	Validate() error
}