zookeeper

Documentation

Index

• type IZkClient
• type WatchCallback
• type ZkClient
  • func NewZkClient(servers []string, root string, timeout int64) (*ZkClient, error)
  • func (z *ZkClient) Close()
  • func (z *ZkClient) GetNodes(srvType string) ([]*ZkNode, error)
  • func (z *ZkClient) Register(node *ZkNode, srvType string) (string, error)
  • func (z *ZkClient) WatchChildrenOnce(srvType string, callback WatchCallback) error
• type ZkNode

Types

type IZkClient

type IZkClient interface {
	Close()
	Register(node *ZkNode, srvType string) (string, error)
	GetNodes(srvType string) ([]*ZkNode, error)
	WatchChildrenOnce(srvType string, callback WatchCallback) error
}

type WatchCallback

type WatchCallback func(node *ZkNode, event zk.Event)

type ZkClient

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

func NewZkClient

func NewZkClient(servers []string, root string, timeout int64) (*ZkClient, error)

func (*ZkClient) Close

func (z *ZkClient) Close()

func (*ZkClient) GetNodes

func (z *ZkClient) GetNodes(srvType string) ([]*ZkNode, error)

func (*ZkClient) Register

func (z *ZkClient) Register(node *ZkNode, srvType string) (string, error)

func (*ZkClient) WatchChildrenOnce

func (z *ZkClient) WatchChildrenOnce(srvType string, callback WatchCallback) error

type ZkNode

type ZkNode struct {
	Host string `json:"host"`
	Port int32  `json:"port"`
	Path string `json:"-"`
}