zookeeper

Documentation

Index

• type ZkClient
  • func InitZookeeper(c *ZkConfig) (*ZkClient, error)
  • func (cli *ZkClient) Children(path string) ([]string, error)
  • func (cli *ZkClient) Close()
  • func (cli *ZkClient) Create(path string, flags int32, data []byte) error
  • func (cli *ZkClient) Delete(path string) error
  • func (cli *ZkClient) Exists(path string) (bool, error)
  • func (cli *ZkClient) Get(path string) ([]byte, error)
  • func (cli *ZkClient) Lock(path string) (*zk.Lock, error)
  • func (cli *ZkClient) Modify(path string, data []byte) error
  • func (cli *ZkClient) Unlock(lock *zk.Lock) error
• type ZkConfig

Types

type ZkClient

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

func InitZookeeper

func InitZookeeper(c *ZkConfig) (*ZkClient, error)

func (*ZkClient) Children

func (cli *ZkClient) Children(path string) ([]string, error)

func (*ZkClient) Close

func (cli *ZkClient) Close()

func (*ZkClient) Create

func (cli *ZkClient) Create(path string, flags int32, data []byte) error

func (*ZkClient) Delete

func (cli *ZkClient) Delete(path string) error

func (*ZkClient) Exists

func (cli *ZkClient) Exists(path string) (bool, error)

func (*ZkClient) Get

func (cli *ZkClient) Get(path string) ([]byte, error)

func (*ZkClient) Lock

func (cli *ZkClient) Lock(path string) (*zk.Lock, error)

分布式事务锁

func (*ZkClient) Modify

func (cli *ZkClient) Modify(path string, data []byte) error

func (*ZkClient) Unlock

func (cli *ZkClient) Unlock(lock *zk.Lock) error

type ZkConfig

type ZkConfig struct {
	Urls    []string
	Timeout time.Duration
}