topicmapnode

Documentation

Index

• Constants
• type TopicsMapNodeProvider
  • func NewTopicMapNodeProvider() TopicsMapNodeProvider

Constants

const (
	// MWC is the multi-level wildcard
	MWC = "#"

	// SWC is the single level wildcard
	SWC = "+"

	// SEP is the topic level separator
	SEP = "/"

	// SYS is the starting character of the system level topics
	//SYS是系统级主题的起始字符
	SYS = "$"
)

Types

type TopicsMapNodeProvider

type TopicsMapNodeProvider interface {
	Subscribe(topic []byte, shareName, node string) error
	Unsubscribe(topic []byte, shareName, node string) error
	Subscribers(topic []byte, shareNames, nodes *[]string) error // 获取此主题下不同共享组中选中的节点
	Close() error
}

TopicsMapNodeProvider 主题映射节点名称

func NewTopicMapNodeProvider

func NewTopicMapNodeProvider() TopicsMapNodeProvider