event

type BaseEvent struct {
	ID                 string    `json:"id"`
	EventTypeValue     string    `json:"eventType"`
	OccurredAtValue    time.Time `json:"occurredAt"`
	AggregateTypeValue string    `json:"aggregateType"`
	AggregateIDValue   string    `json:"aggregateID"`
}

type DomainEvent interface {
	EventID() string
	EventType() string
	OccurredAt() time.Time
	AggregateType() string
	AggregateID() string
}

type Event[T any] struct {
	BaseEvent
	Data T `json:"data"`
}

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

type EventHandler func(ctx context.Context, event DomainEvent) error

type EventPublisher = Publisher

type EventRaiser interface {
	Events() []DomainEvent
	ClearEvents()
}

type EventStore interface {
	Save(ctx context.Context, events []DomainEvent) error
	Load(ctx context.Context, aggregateType, aggregateID string) ([]DomainEvent, error)
	LoadFrom(ctx context.Context, aggregateType, aggregateID string, fromVersion int64) ([]DomainEvent, error)
}

type EventSubscriber interface {
	Subscribe(eventType string, handler EventHandler) error
	Start(ctx context.Context) error
	Stop() error
}

type NopEventPublisher struct{}

type Publisher interface {
	Publish(ctx context.Context, event DomainEvent) error
	PublishAll(ctx context.Context, events []DomainEvent) error
}

type Stager interface {
	Stage(ctx context.Context, events ...DomainEvent) error
}