eventbus

type Bus interface {
	BusController
	BusSubscriber
	BusPublisher
}

type BusController interface {
	HasCallback(topic string) bool // 检查是否有回调
	WaitAsync()                    // 等待异步回调完成
}

type BusPublisher interface {
	Publish(topic string, args ...interface{}) // 发布主题
}

type BusSubscriber interface {
	Subscribe(topic string, fn interface{}) error                          // 订阅主题
	SubscribeAsync(topic string, fn interface{}, transactional bool) error // 异步订阅主题
	SubscribeOnce(topic string, fn interface{}) error                      // 订阅一次主题
	SubscribeOnceAsync(topic string, fn interface{}) error                 // 异步订阅一次主题
	Unsubscribe(topic string, handler interface{}) error                   // 取消订阅
}

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

type ClientArg struct {
	Args  []interface{} // 参数
	Topic string        // 主题
}

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

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

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

type NetworkBus struct {
	Client *Client // 内嵌客户端
	Server *Server // 内嵌服务器
	// contains filtered or unexported fields
}

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

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

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

type SubscribeArg struct {
	ClientAddr    string        // 客户端地址
	ClientPath    string        // 客户端路径
	ServiceMethod string        // 服务方法名
	SubscribeType SubscribeType // 订阅类型
	Topic         string        // 主题名称
}

type SubscribeType int