Versions in this module Expand all Collapse all v0 v0.0.2 Sep 13, 2021 Changes in this version + var NodeNoExist = errors.New("node no exist") + type Node struct + Addr string + NNA string + type NodeDiscover interface + GetNode func(name string) (Node, error) + GetNodeMap func() map[string]Node + GetNodes func() ([]Node, error) + RegisterMe func(node Node) error + RemoveNode func(name string) error + func NewStaticNodeDiscover(nodes map[string]Node) NodeDiscover + type ShareTopicMapNode interface + AddTopicMapNode func(topic []byte, shareName, nodeName string) error + GetShareNames func(topic []byte) (map[string]string, error) + RemoveTopicMapNode func(topic []byte, shareName, nodeName string) error + func NewShareMap() ShareTopicMapNode
Go to main page