Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DiscoverEvent ¶
DiscoverEvent if servers chenged, will create a discover event
type RegDiscover ¶
type RegDiscover struct {
// contains filtered or unexported fields
}
RegDiscover is data struct of register-discover
func NewRegDiscover ¶
func NewRegDiscover(client *zk.ZkClient, timeout time.Duration) *RegDiscover
NewRegDiscover used to create a object of RegDiscover
func NewRegDiscoverEx ¶
func NewRegDiscoverEx(client *zk.ZkClient) *RegDiscover
NewRegDiscoverEx used to create a object of RegDiscover
func (*RegDiscover) DiscoverService ¶
func (rd *RegDiscover) DiscoverService(key string) (<-chan *DiscoverEvent, error)
DiscoverService used to discover the service that registered in `key`
func (*RegDiscover) GetServNodes ¶
func (rd *RegDiscover) GetServNodes(key string) ([]string, error)
func (*RegDiscover) RegisterAndWatchService ¶
func (rd *RegDiscover) RegisterAndWatchService(key string, data []byte) error
RegisterAndWatchService register service info into register-discover platform and then watch the service info, if not exist, then register again key is the index of registered service data is the service information
type RegDiscvServer ¶
type RegDiscvServer interface {
// Ping to ping server
Ping() error
// RegisterAndWatch register server info into register-discover service platform,
// and watch the info, if not exist, then register again
RegisterAndWatch(key string, data []byte) error
// GetServNodes get server nodes
GetServNodes(key string) ([]string, error)
// discover server from the register-discover service platform
Discover(key string) (<-chan *DiscoverEvent, error)
}
RegDiscvServer define the register and discover function interface
type ZkRegDiscv ¶
type ZkRegDiscv struct {
// contains filtered or unexported fields
}
ZkRegDiscv do register and discover by zookeeper
func NewZkRegDiscv ¶
func NewZkRegDiscv(client *zk.ZkClient) *ZkRegDiscv
NewZkRegDiscv create a object of ZkRegDiscv
func (*ZkRegDiscv) Discover ¶
func (zkRD *ZkRegDiscv) Discover(path string) (<-chan *DiscoverEvent, error)
Discover watch the children
func (*ZkRegDiscv) GetServNodes ¶
func (zkRD *ZkRegDiscv) GetServNodes(path string) ([]string, error)
GetServNodes get server nodes by path
func (*ZkRegDiscv) RegisterAndWatch ¶
func (zkRD *ZkRegDiscv) RegisterAndWatch(path string, data []byte) error
RegisterAndWatch create ephemeral node for the service and watch it. if it exit, register again
Source Files