internal

package
v0.0.0-...-5160462 Latest Latest
Warning

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

Go to latest
Published: Apr 29, 2023 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DoWatch

func DoWatch(zkEvent zk.Event, watcher func(zk.Event))

Types

type ZK

type ZK struct {
	Conn *zk.Conn
	// contains filtered or unexported fields
}

func NewZK

func NewZK(servers []string, watcher func(zk.Event)) *ZK

func (*ZK) Create

func (zookeeper *ZK) Create(path string, data []byte, version int32) error

func (*ZK) Delete

func (zookeeper *ZK) Delete(path string, version int32) error

func (*ZK) Exists

func (zookeeper *ZK) Exists(path string) (bool, error)

func (*ZK) Get

func (zookeeper *ZK) Get(path string) (string, error)

func (*ZK) GetChildren

func (zookeeper *ZK) GetChildren(path string) ([]string, error)

func (*ZK) GetChildrenW

func (zookeeper *ZK) GetChildrenW(path string) ([]string, <-chan zk.Event, error)

func (*ZK) GetW

func (zookeeper *ZK) GetW(path string) (string, <-chan zk.Event, error)

func (*ZK) Set

func (zookeeper *ZK) Set(path string, data []byte, version int32) error

Jump to

Keyboard shortcuts

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