ddd

type Aggregate struct {
	Entity
	// contains filtered or unexported fields
}

type AggregateEvent interface {
	Event
	AggregateName() string
	AggregateID() string
	AggregateVersion() int
}

type AggregateNamer interface {
	AggregateName() string
}

type Command interface {
	IDer
	CommandName() string
	Payload() CommandPayload
	Metadata() Metadata
	OccurredAt() time.Time
}

type CommandHandler[T Command] interface {
	HandleCommand(ctx context.Context, cmd T) (Reply, error)
}

type CommandHandlerFunc[T Command] func(ctx context.Context, cmd T) (Reply, error)

type CommandOption interface {
	// contains filtered or unexported methods
}

type CommandPayload any

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

type EntityNamer interface {
	EntityName() string
}

type Event interface {
	IDer
	EventName() string
	Payload() EventPayload
	Metadata() Metadata
	OccurredAt() time.Time
}

type EventDispatcher[T Event] struct {
	// contains filtered or unexported fields
}

type EventHandler[T Event] interface {
	HandleEvent(ctx context.Context, event T) error
}

type EventHandlerFunc[T Event] func(ctx context.Context, event T) error

type EventOption interface {
	// contains filtered or unexported methods
}

type EventPayload interface{}

type EventPublisher[T Event] interface {
	Publish(ctx context.Context, events ...T) error
}

type EventSubscriber[T Event] interface {
	Subscribe(handler EventHandler[T], events ...string)
}

type Eventer interface {
	AddEvent(string, EventPayload, ...EventOption)
	Events() []AggregateEvent
	ClearEvents()
}

type EventsSetter interface {
	// contains filtered or unexported methods
}

type IDSetter interface {
	// contains filtered or unexported methods
}

type IDer interface {
	ID() string
}

type Metadata map[string]any

type NameSetter interface {
	// contains filtered or unexported methods
}

type Reply interface {
	ID() string
	ReplyName() string
	Payload() ReplyPayload
	Metadata() Metadata
	OccurredAt() time.Time
}

type ReplyHandler[T Reply] interface {
	HandleReply(ctx context.Context, reply T) error
}

type ReplyHandlerFunc[T Reply] func(ctx context.Context, reply T) error

type ReplyOption interface {
	// contains filtered or unexported methods
}

type ReplyPayload any