event

type AGG interface{ ApplyEvent(...Event) }

type Aggregate interface {
	// ApplyEvent  applies the event to the aggrigate state
	ApplyEvent(...Event)

	AggregateRoot
}

type AggregateRoot interface {
	// Events returns the aggregate events
	// pass true for only uncommitted events
	Events(bool) Events
	// StreamID returns aggregate stream ID
	StreamID() string
	// SetStreamID sets aggregate stream ID
	SetStreamID(streamID string)
	// StreamVersion returns last commit events
	StreamVersion() uint64
	// Version returns the current aggrigate version. (committed + uncommitted)
	Version() uint64

	Commit()
	// contains filtered or unexported methods
}

type Event interface {
	EventMeta() Meta
	SetEventMeta(Meta)
}

type EventPtr struct {
	StreamID string `json:"stream_id"`
	Pos      uint64 `json:"pos"`

	IsEvent
}

type Events []Event

type FeedTruncated struct {
	IsEvent
}

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

type IsEvent = property[Meta]

type Meta struct {
	EventID        ulid.ULID
	StreamID       string
	Position       uint64
	ActualStreamID string
	ActualPosition uint64
}

type UnknownEvent struct {
	IsEvent
	// contains filtered or unexported fields
}