Versions in this module Expand all Collapse all v0 v0.1.0 Nov 28, 2019 Changes in this version + func UpdateRouter(msg *clustermessage.ClusterMessage, notifier RouterNotifier) + type ClusterRouter struct + Childs map[string]string + Neighbor map[string]string + ParentNeighbor map[string]string + func Router() *ClusterRouter + func (cr *ClusterRouter) AddChild(clusterName, listen string, notifier RouterNotifier) error + func (cr *ClusterRouter) AddRoute(to, port string) error + func (cr *ClusterRouter) DelChild(clusterName string, notifier RouterNotifier) + func (cr *ClusterRouter) DelRoute(to, port string) + func (cr *ClusterRouter) Deserialize(b []byte) error + func (cr *ClusterRouter) HasChild(clusterName string) bool + func (cr *ClusterRouter) HasRoute(to, port string) bool + func (cr *ClusterRouter) NeighborRouterMessage() *clustermessage.ClusterMessage + func (cr *ClusterRouter) ParentNeighbors() map[string]string + func (cr *ClusterRouter) PortsToSubtreeClusters(clusters *[]string) map[string][]string + func (cr *ClusterRouter) Serialize() ([]byte, error) + func (cr *ClusterRouter) SubTreeClusters() []string + func (cr *ClusterRouter) SubTreeMessage() *clustermessage.ClusterMessage + func (cr *ClusterRouter) SubTreeOfPort(port string) []string + type RouterNotifier func(*clustermessage.ClusterMessage, ...string) + type SubTreeRouter map[string]string + func SubtreeFromClusterController(msg *clustermessage.ClusterMessage) SubTreeRouter + func (s *SubTreeRouter) Serialize() ([]byte, error)
Go to main page