event

type BaseDomainEvent[T any] struct {
	BaseEvent[T]
	AggID   string `json:"aggregate_id"`
	AggName string `json:"aggregate_name"`
}

type BaseEvent[T any] struct {
	Type      string    `json:"type"`
	Timestamp time.Time `json:"timestamp"`
	Data      T         `json:"data"`
}

type Bus interface {
	// PublishEvent 发布事件
	PublishEvent(ctx context.Context, event any) error
	// SubscribeHandler 订阅事件处理器
	SubscribeHandler(handler any) error
}

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

type DomainEvent[T any] interface {
	Event[T]
	// AggregateID 返回聚合根ID
	AggregateID() string
	// AggregateName 返回聚合根名称
	AggregateName() string
}

type DomainEventHandler[T any] struct{}

type Event[T any] interface {
	// EventType 返回事件类型
	EventType() string
	// OccurredAt 返回事件发生时间
	OccurredAt() time.Time
	// Payload 返回事件数据
	Payload() T
}

type Handler interface {
	// Handle 事件处理
	Handle(ctx context.Context, event any) error
	// InterestedEventTypes 返回感兴趣的事件类型列表
	InterestedEventTypes() []string
}

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