eventbus

type Event = internal.Event

type EventHandler = internal.EventHandler

type Eventbus interface {
	// Close 关闭事件总线
	Close() error
	// Publish 发布事件
	Publish(ctx context.Context, topic string, message any) error
	// Subscribe 订阅事件
	Subscribe(ctx context.Context, topic string, handler EventHandler, balance ...bool) (Subscription, error)
}

type Subscription interface {
	// Unsubscribe 取消订阅
	Unsubscribe(ctx context.Context) error
}