event

type BaseEvent struct {
	ID                 string
	EventTypeValue     string
	OccurredAtValue    time.Time
	AggregateTypeValue string
	AggregateIDValue   string
}

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

type Event[T any] struct {
	BaseEvent
	Data T
}

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
}