zookeeper

Documentation

Index

• Constants
• type ZKRegistry
  • func (r *ZKRegistry) DoSubscribe() error
  • func (r *ZKRegistry) DoUnsubscribe() error
  • func (r *ZKRegistry) GetClient() *zk.ZooKeeperClient

Constants

const (
	// RegistryZkClient zk client name
	RegistryZkClient = "zk registry"
	MaxFailTimes     = 2
	ConnDelay        = 3 * time.Second
)

Types

type ZKRegistry

type ZKRegistry struct {
	*baseRegistry.BaseRegistry
	// contains filtered or unexported fields
}

func (*ZKRegistry) DoSubscribe

func (r *ZKRegistry) DoSubscribe() error

DoSubscribe is the implementation of subscription on the target registry.

func (*ZKRegistry) DoUnsubscribe

func (r *ZKRegistry) DoUnsubscribe() error

DoUnsubscribe stops monitoring the target registry.

func (*ZKRegistry) GetClient

func (r *ZKRegistry) GetClient() *zk.ZooKeeperClient