discovery

Documentation

Index

• Constants
• type DogDiscovery
• type ZkDiscovery
  • func (z *ZkDiscovery) AddNode(node string, info *server.NodeInfo)
  • func (z *ZkDiscovery) Close() error
  • func (z *ZkDiscovery) DelNode(node string, key string)
  • func (z *ZkDiscovery) GetNodeInfo(node string) []server.NodeInfo
  • func (z *ZkDiscovery) NewDiscovery(dns []string)
  • func (z *ZkDiscovery) Run() error
  • func (z *ZkDiscovery) Watch(node string) error
  • func (z *ZkDiscovery) WatchMulti(nodes []string) error
• type ZkNode

Constants

const (
	MaxNodeNum = 128
)

Types

type DogDiscovery

type DogDiscovery interface {
	NewDiscovery(dns []string)
	Watch(node string) error
	WatchMulti(nodes []string) error
	AddNode(node string, info *server.NodeInfo)
	DelNode(node string, key string)
	GetNodeInfo(node string) (nodesInfo []server.NodeInfo)
	Run() error
	Close() error
}

type ZkDiscovery

type ZkDiscovery struct {
	// contains filtered or unexported fields
}

Encapsulates the zookeeper discovery

func (*ZkDiscovery) AddNode

func (z *ZkDiscovery) AddNode(node string, info *server.NodeInfo)

func (*ZkDiscovery) Close

func (z *ZkDiscovery) Close() error

func (*ZkDiscovery) DelNode

func (z *ZkDiscovery) DelNode(node string, key string)

func (*ZkDiscovery) GetNodeInfo

func (z *ZkDiscovery) GetNodeInfo(node string) []server.NodeInfo

func (*ZkDiscovery) NewDiscovery

func (z *ZkDiscovery) NewDiscovery(dns []string)

func (*ZkDiscovery) Run

func (z *ZkDiscovery) Run() error

func (*ZkDiscovery) Watch

func (z *ZkDiscovery) Watch(node string) error

func (*ZkDiscovery) WatchMulti

func (z *ZkDiscovery) WatchMulti(nodes []string) error

type ZkNode

type ZkNode struct {
	// contains filtered or unexported fields
}