zook

Documentation

Index

• func NewZKDriver(servers []string, options ...DriverOption) driver.Driver
• type Driver
  • 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 WithACL(acl []zk.ACL) DriverOption
  • func WithRootDirectory(root string) DriverOption
  • func WithTimeout(timeout time.Duration) DriverOption

Functions

func NewZKDriver

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

NewZKDriver returns new zookeeper driver

Types

type Driver

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

Driver defines zookeeper driver for Albus

func (*Driver) Children

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

Children returns the children of the path

func (*Driver) Close

func (d *Driver) Close() error

Close shuts down connection for the driver

func (*Driver) Delete

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

Delete deletes the node and all its children

func (*Driver) IsConnected

func (d *Driver) IsConnected() bool

func (*Driver) Open

func (d *Driver) Open() error

Open initializes the driver

func (*Driver) Read

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

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

func (*Driver) State

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

func (*Driver) Watch

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

Watch watches for changes on node

func (*Driver) WatchChildren

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

func (*Driver) Write

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

Write writes the content to the path

type DriverOption

type DriverOption func(*Driver)

func WithACL

func WithACL(acl []zk.ACL) DriverOption

func WithRootDirectory

func WithRootDirectory(root string) DriverOption

func WithTimeout

func WithTimeout(timeout time.Duration) DriverOption