discovery

Documentation

Index

• Constants
• type DogDiscovery
• type EtcdDiscovery
  • func (e *EtcdDiscovery) AddNode(node string, info *server.NodeInfo)
  • func (e *EtcdDiscovery) Close() error
  • func (e *EtcdDiscovery) DelNode(node string, key string)
  • func (e *EtcdDiscovery) GetNodeInfo(node string) []server.NodeInfo
  • func (e *EtcdDiscovery) NewDiscovery(dns []string)
  • func (e *EtcdDiscovery) Run() error
  • func (e *EtcdDiscovery) Watch(node string) error
  • func (e *EtcdDiscovery) WatchMulti(nodes []string) error
• type EtcdNode
• 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 EtcdDiscovery

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

Encapsulates the etcd discovery

func (*EtcdDiscovery) AddNode

func (e *EtcdDiscovery) AddNode(node string, info *server.NodeInfo)

func (*EtcdDiscovery) Close

func (e *EtcdDiscovery) Close() error

func (*EtcdDiscovery) DelNode

func (e *EtcdDiscovery) DelNode(node string, key string)

func (*EtcdDiscovery) GetNodeInfo

func (e *EtcdDiscovery) GetNodeInfo(node string) []server.NodeInfo

func (*EtcdDiscovery) NewDiscovery

func (e *EtcdDiscovery) NewDiscovery(dns []string)

func (*EtcdDiscovery) Run

func (e *EtcdDiscovery) Run() error

func (*EtcdDiscovery) Watch

func (e *EtcdDiscovery) Watch(node string) error

func (*EtcdDiscovery) WatchMulti

func (e *EtcdDiscovery) WatchMulti(nodes []string) error

type EtcdNode

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

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
}