bus

type EventBus interface {
	// Publish 发布事件
	Publish(ctx context.Context, event domainEvent.DomainEvent) error
	// Subscribe 订阅事件
	Subscribe(handler EventHandler)
	// Unsubscribe 取消订阅事件
	Unsubscribe(handler EventHandler)
}

type EventHandler interface {
	// Handle 事件处理器
	Handle(ctx context.Context, event domainEvent.DomainEvent) error
	// CanHandle 判断是否可以处理该事件
	CanHandle(eventType string) bool
}

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