zook

package

v2.0.6 Latest Latest Go to latest Published: Jan 21, 2024 License: MIT Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

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

NewZKDriver returns new zookeeper driver

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

Driver defines zookeeper driver for Albus

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

Children returns the children of the path

func (d *Driver) Close() error

Close shuts down connection for the driver

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

Delete deletes the node and all its children

func (d *Driver) IsConnected() bool

func (d *Driver) Open() error

Open initializes the driver

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

Read reads the content from the path and returns the value in bytes

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

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

Watch watches for changes on node

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

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

Write writes the content to the path

type DriverOption func(*Driver)

func WithACL(acl []zk.ACL) DriverOption

func WithRootDirectory(root string) DriverOption

func WithTimeout(timeout time.Duration) DriverOption