zook

Nov 30, 2023

Changes in this version

+ func NewZKDriver(servers []string, options ...DriverOption) driver.Driver

+ type Driver struct

+ func (d *Driver) Children(path string) ([]string, error)

+ func (d *Driver) Close() error

+ func (d *Driver) Delete(path string) error

+ func (d *Driver) IsConnected() bool

+ func (d *Driver) Open() error

+ func (d *Driver) Read(path string) ([]byte, error)

+ func (d *Driver) State() zk.State

+ func (d *Driver) Watch(path string) ([]byte, <-chan *driver.Event, error)

+ func (d *Driver) WatchChildren(path string) ([]string, <-chan *driver.Event, error)

+ func (d *Driver) Write(path string, data []byte) error

+ type DriverOption func(*Driver)

+ func WithACL(acl []zk.ACL) DriverOption

+ func WithRootDirectory(root string) DriverOption

+ func WithTimeout(timeout time.Duration) DriverOption