zk

Documentation

Overview

zk provides with higher level commands over the lower level zookeeper connector

Index

• func Children(path string) ([]string, error)
• func ChildrenRecursive(path string) ([]string, error)
• func Create(path string, data []byte, force bool) (string, error)
• func Delete(path string) error
• func Exists(path string) (bool, error)
• func Get(path string) ([]byte, error)
• func Set(path string, data []byte) (*zk.Stat, error)
• func SetServers(serversArray []string)

Functions

func Children

func Children(path string) ([]string, error)

Children returns sub-paths of given path, optionally empty array, or error if path does not exist

func ChildrenRecursive

func ChildrenRecursive(path string) ([]string, error)

ChildrenRecursive returns list of all descendants of given path (optionally empty), or error if the path does not exist. Every element in result list is a relative subpath for the given path.

func Create

func Create(path string, data []byte, force bool) (string, error)

Create will create a new path, or exit with error should the path exist. The "force" param controls the behavior when path's parent directory does not exist. When "force" is false, the function returns with error/ When "force" is true, it recursively attempts to create required parent directories.

func Delete

func Delete(path string) error

Delete removes a path entry. It exits with error if the path does not exist, or has subdirectories.

func Exists

func Exists(path string) (bool, error)

Exists returns true when the given path exists

func Get

func Get(path string) ([]byte, error)

Get returns value associated with given path, or error if path does not exist

func Set

func Set(path string, data []byte) (*zk.Stat, error)

Set updates a value for a given path, or returns with error if the path does not exist

func SetServers

func SetServers(serversArray []string)

SetServers sets the list of servers for the zookeeper client to connect to. Each element in the array should be in either of following forms: - "servername" - "servername:port"