Versions in this module Expand all Collapse all v3 v3.1.2 Feb 5, 2024 Changes in this version + const ConnDelay + const MaxFailTimes + func HandleClientRestart(r ZkClientFacade) + func ValidateZookeeperClient(container ZkClientFacade, zkName string) error + type ZkClientFacade interface + Done func() chan struct{} + GetURL func() *common.URL + RestartCallBack func() bool + SetZkClient func(*gxzookeeper.ZookeeperClient) + WaitGroup func() *sync.WaitGroup + ZkClient func() *gxzookeeper.ZookeeperClient + ZkClientLock func() *sync.Mutex + type ZkEventListener struct + Client *gxzookeeper.ZookeeperClient + func NewZkEventListener(client *gxzookeeper.ZookeeperClient) *ZkEventListener + func (l *ZkEventListener) Close() + func (l *ZkEventListener) ListenConfigurationEvent(zkPath string, listener remoting.DataListener) + func (l *ZkEventListener) ListenServiceEvent(conf *common.URL, zkPath string, listener remoting.DataListener) + func (l *ZkEventListener) ListenServiceNodeEvent(zkPath string, listener remoting.DataListener)
Go to main page