framework

func AddCreateToTransaction(transaction curator.Transaction) curator.TransactionFinal

func AddDeleteToTransaction(transaction curator.Transaction) curator.TransactionFinal

func CheckExists(client curator.CuratorFramework, path string) (*zk.Stat, error)

func CommitTransaction(transaction curator.TransactionFinal) ([]curator.TransactionResult, error)

func Create(client curator.CuratorFramework, path string, payload []byte) (string, error)

func CreateEphemeral(client curator.CuratorFramework, path string, payload []byte) (string, error)

func CreateSimple(connString string) curator.CuratorFramework

func CreateTransaction(client curator.CuratorFramework) error

func CreateWithOptions(connString string, retryPolicy curator.RetryPolicy, connectionTimeout, sessionTimeout time.Duration) curator.CuratorFramework

func Delete(client curator.CuratorFramework, path string, version int32) error

func GetData(client curator.CuratorFramework, path string) ([]byte, error)

func SetData(client curator.CuratorFramework, path string, payload []byte) (*zk.Stat, error)

func SetDataAsync(client curator.CuratorFramework, path string, payload []byte) (*zk.Stat, error)

func SetDataAsyncWithCallback(client curator.CuratorFramework, callback curator.BackgroundCallback, path string, payload []byte) (*zk.Stat, error)

func StartTransaction(client curator.CuratorFramework) curator.Transaction

func UsingWatcherGetChildren(client curator.CuratorFramework, path string, watcher curator.Watcher) ([]string, error)

func WatchedGetChildren(client curator.CuratorFramework, path string) ([]string, error)