cluster

Documentation

Index

• Variables
• type Node
• type NodeDiscover
  • func NewStaticNodeDiscover(nodes map[string]Node) NodeDiscover
• type ShareTopicMapNode
  • func NewShareMap() ShareTopicMapNode

Variables

var (
	NodeNoExist = errors.New("node no exist")
)

Types

type Node

type Node struct {
	NNA  string // 节点名称
	Addr string // 节点addr
}

type NodeDiscover

type NodeDiscover interface {
	GetNodes() ([]Node, error)
	GetNodeMap() map[string]Node
	GetNode(name string) (Node, error)
	RegisterMe(node Node) error
	RemoveNode(name string) error
}

NodeDiscover 集群节点发现

func NewStaticNodeDiscover

func NewStaticNodeDiscover(nodes map[string]Node) NodeDiscover

type ShareTopicMapNode

type ShareTopicMapNode interface {
	GetShareNames(topic []byte) (map[string]string, error)
	AddTopicMapNode(topic []byte, shareName, nodeName string) error
	RemoveTopicMapNode(topic []byte, shareName, nodeName string) error
}

func NewShareMap

func NewShareMap() ShareTopicMapNode