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")
)

var (
	TopicNode        = SysTopic.Child("node")
	TopicGetAllNodes = TopicNode.Child("get_all_nodes/admin")
	TopicStopNode    = TopicNode.Child("stop_node/admin")
	TopicNodeStatus  = TopicNode.Child("status/admin")
)

var (
	TopicCluster = SysTopic.Child("cluster")
	// 三次同步过程建立节点连接
	// 交换id
	TopicClusterID = TopicCluster.Child("id")
	// 通知本身级别
	TopicClusterLevel = TopicCluster.Child("level")
	// 交换cluster节点信息
	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 (
	MessageTyp_name = map[int32]string{
		0: "Bytes",
		1: "String",
		2: "Int",
		3: "Bool",
		4: "JSON",
		6: "uint",
		5: "float",
	}
	MessageTyp_value = map[string]int32{
		"Bytes":  0,
		"String": 1,
		"Int":    2,
		"Bool":   3,
		"JSON":   4,
		"uint":   6,
		"float":  5,
	}
)

var File_msg_proto protoreflect.FileDescriptor

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

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