Documentation ¶
Index ¶
- Variables
- type Event
- type Stat
- type State
- type ZkClient
- func (z *ZkClient) CheckMulNode(path string, data []byte) error
- func (z *ZkClient) CheckNode(path string, data []byte) error
- func (z *ZkClient) ChildrenW(path string) ([]string, *zk.Stat, <-chan zk.Event, error)
- func (z *ZkClient) Close()
- func (z *ZkClient) Connect() error
- func (z *ZkClient) ConnectEx(sessionTimeOut time.Duration) error
- func (z *ZkClient) Create(path string, data []byte) error
- func (z *ZkClient) CreateDeepNode(path string, data []byte) error
- func (z *ZkClient) CreateEphAndSeq(path string, data []byte) error
- func (z *ZkClient) CreateEphAndSeqEx(path string, data []byte) (string, error)
- func (z *ZkClient) CreateNode(path string, data []byte) error
- func (z *ZkClient) Del(path string, version int32) error
- func (z *ZkClient) Exist(path string) (bool, error)
- func (z *ZkClient) ExistEx(path string) (bool, *zk.Stat, error)
- func (z *ZkClient) ExistW(path string) (bool, *zk.Stat, <-chan zk.Event, error)
- func (z *ZkClient) Get(path string) (string, error)
- func (z *ZkClient) GetAll2Json(path string) (string, error)
- func (z *ZkClient) GetChildren(path string) ([]string, error)
- func (z *ZkClient) GetChildrenEx(path string) ([]string, *zk.Stat, error)
- func (z *ZkClient) GetEx(path string) ([]byte, *zk.Stat, error)
- func (z *ZkClient) GetW(path string) ([]byte, *zk.Stat, <-chan zk.Event, error)
- func (z *ZkClient) Set(path, data string, version int32) error
- func (z *ZkClient) State() zk.State
- func (z *ZkClient) Update(path, data string) error
- func (z *ZkClient) WatchChildren(path string) ([]string, <-chan zk.Event, error)
- type ZkLock
Constants ¶
This section is empty.
Variables ¶
View Source
var ( //ErrNoNode error for node not found ErrNoNode = zk.ErrNoNode EventNodeCreated = zk.EventNodeCreated EventNodeDeleted = zk.EventNodeDeleted EventNodeDataChanged = zk.EventNodeDataChanged EventNodeChildrenChanged = zk.EventNodeChildrenChanged )
View Source
var ( AUTH_USER = static.ZookeeperClientUser AUTH_PWD = static.ZookeeperClientPwd )
Functions ¶
This section is empty.
Types ¶
type ZkClient ¶
func NewZkClient ¶
func (*ZkClient) CreateEphAndSeq ¶
CreateEphemeral create ephemeral node
func (*ZkClient) CreateEphAndSeqEx ¶
func (*ZkClient) GetChildrenEx ¶
Click to show internal directories.
Click to hide internal directories.