zookeeper

Documentation

Index

• func GetServers() ([]string, error)
• func RegisterAfterConnected(handler func())
• type Client
  • func MustNewZookeeperClient(servers ...string) *Client
  • func NewZookeeperClient(servers ...string) (*Client, error)
  • func (z *Client) ChildrenW(path string) ([]string, *zk.Stat, <-chan zk.Event, error)
  • func (z *Client) Close()
  • func (z *Client) Create(path string, data []byte, flag int32, acl []zk.ACL) (string, error)
  • func (z *Client) Delete(path string, version int32) error
  • func (z *Client) Exists(path string) (bool, *zk.Stat, error)
  • func (z *Client) Get(path string) ([]byte, *zk.Stat, error)
  • func (z *Client) GetC(k string) (string, error)
  • func (z *Client) GetChildC(key string) (map[string]string, error)
  • func (z *Client) GetChildKeyC(key string) ([]string, error)
  • func (z *Client) GetW(path string) ([]byte, *zk.Stat, <-chan zk.Event, error)
  • func (z *Client) State() zk.State

Functions

func GetServers

func GetServers() ([]string, error)

func RegisterAfterConnected

func RegisterAfterConnected(handler func())

Types

type Client

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

func MustNewZookeeperClient

func MustNewZookeeperClient(servers ...string) *Client

func NewZookeeperClient

func NewZookeeperClient(servers ...string) (*Client, error)

func (*Client) ChildrenW

func (z *Client) ChildrenW(path string) ([]string, *zk.Stat, <-chan zk.Event, error)

func (*Client) Close

func (z *Client) Close()

func (*Client) Create

func (z *Client) Create(path string, data []byte, flag int32, acl []zk.ACL) (string, error)

func (*Client) Delete

func (z *Client) Delete(path string, version int32) error

func (*Client) Exists

func (z *Client) Exists(path string) (bool, *zk.Stat, error)

func (*Client) Get

func (z *Client) Get(path string) ([]byte, *zk.Stat, error)

func (*Client) GetC

func (z *Client) GetC(k string) (string, error)

func (*Client) GetChildC

func (z *Client) GetChildC(key string) (map[string]string, error)

func (*Client) GetChildKeyC

func (z *Client) GetChildKeyC(key string) ([]string, error)

func (*Client) GetW

func (z *Client) GetW(path string) ([]byte, *zk.Stat, <-chan zk.Event, error)

func (*Client) State

func (z *Client) State() zk.State