zkclient

package
v0.0.0-...-d3e924d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 6, 2019 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var DefaultLogfunc = func(format string, v ...interface{}) {
	log.Info("zookeeper - " + fmt.Sprintf(format, v...))
}
View Source
var ErrClosedClient = errors.New("use of closed zk client")

Functions

This section is empty.

Types

type Client

type Client struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New

func New(addrlist string, auth string, timeout time.Duration) (*Client, error)

func NewWithLogfunc

func NewWithLogfunc(addrlist string, auth string, timeout time.Duration, logfunc func(foramt string, v ...interface{})) (*Client, error)

func (*Client) Close

func (c *Client) Close() error

func (*Client) Create

func (c *Client) Create(path string, data []byte) error

func (*Client) CreateEphemeral

func (c *Client) CreateEphemeral(path string, data []byte) (<-chan struct{}, error)

func (*Client) CreateEphemeralInOrder

func (c *Client) CreateEphemeralInOrder(path string, data []byte) (<-chan struct{}, string, error)

func (*Client) Delete

func (c *Client) Delete(path string) error

func (*Client) Do

func (c *Client) Do(fn func(conn *zk.Conn) error) error

func (*Client) List

func (c *Client) List(path string, must bool) ([]string, error)

func (*Client) Mkdir

func (c *Client) Mkdir(path string) error

func (*Client) Read

func (c *Client) Read(path string, must bool) ([]byte, error)

func (*Client) Update

func (c *Client) Update(path string, data []byte) error

func (*Client) WatchInOrder

func (c *Client) WatchInOrder(path string) (<-chan struct{}, []string, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL