message

var (
	PublicTopic = NewTopic("")
	// 用户保留主题 不会进行广播
	InnerTopic = NewTopic("inner")
	// 系统保留主题 不会触发任何注册的回调函数
	SysTopic = NewTopic("sys")
)

var (
	TopicBase = SysTopic.Child("base")
	// 日志
	TopicSysLog = TopicBase.Child("log")
	// 连接权限验证
	TopicAuth = TopicBase.Child("auth")
)

var (
	TopicTopic = SysTopic.Child("topic")
	// 订阅指令
	TopicSubscribe = TopicTopic.Child("subscribe")
	// 取消订阅指令
	TopicCancel = TopicTopic.Child("cancel")
	// 取消所有订阅指令
	TopicCancelAll = TopicTopic.Child("cancel_all")
	// 敏感操作 需要通过判定
	TopicSubscribeAll = TopicTopic.Child("subscribe_all/admin")
	TopicGetAllTopics = TopicTopic.Child("get_all_topics/admin")
	TopicGetAllNodes  = TopicTopic.Child("get_all_nodes/admin")
	TopicStopNode     = TopicTopic.Child("stop_node/admin")
)

var (
	TopicCluster = SysTopic.Child("cluster")
	// 三次同步过程建立节点连接
	TopicClusterLateral  = TopicCluster.Child("lateral")
	TopicClusterSuperior = TopicCluster.Child("superior")
	TopicClusterInfo     = TopicCluster.Child("info")
	TopicClusterRedirect = TopicCluster.Child("redirect")
)

var (
	ErrNotAllowedTopic = errors.New("this topic is not allowed to subscribe or publish")
	ErrUnformedMsg     = errors.New("unformed Msg")
)

var DefaultMsgPrefix = []byte("ws")

var InvalidMessage = errors.New("invalid message")

var InvalidTopic = errors.New("invalid topic")