zkclient

Nov 18, 2019

Changes in this version

+ const PathSplit

+ func PathJoin(nodes ...string) string

Nov 6, 2019

Changes in this version

+ func ParentNode(path string) string

Oct 18, 2019

Changes in this version

type Watcher

+ func (w *Watcher) Alive() bool

+ func (w *Watcher) Done() <-chan struct{}

Oct 14, 2019

Changes in this version

type Client

+ func (cli *Client) CreateTempRawValue(path string, bytes []byte) error

+ func (cli *Client) Exists(path string) (bool, error)

+ func (cli *Client) GetChildren(path string) ([]string, error)

+ type ClientOption func(*ClientOptions)

+ func WithAlarmTrigger(trigger AlarmTrigger) ClientOption

+ func WithListenAsync() ClientOption

+ func WithTimeout(timeout time.Duration) ClientOption

+ type ClientOptions struct

Oct 14, 2019

Changes in this version

type ChildListener

+ Delete func(path, child string)

+ Update func(path, child string, obj interface{})

type Client

+ func (cli *Client) Watch(path string, obj interface{}, codec Codec, listener ValueListener) (*Watcher, error)

+ func (cli *Client) WatchJSON(path string, obj interface{}, listener ValueListener) (*Watcher, error)

+ func (cli *Client) WatchJSONMap(path string, m interface{}, syncChild bool, listener ChildListener) (*Watcher, error)

+ func (cli *Client) WatchMap(path string, m interface{}, valueCodec Codec, syncChild bool, ...) (*Watcher, error)

+ func (cli *Client) WatchString(path string, s *string, listener ValueListener) (*Watcher, error)

+ func (cli *Client) WatchStringMap(path string, m map[string]string, syncChild bool, listener ChildListener) (*Watcher, error)

type ValueListener

+ Delete func(path string)

+ Update func(path string, obj interface{})

Oct 12, 2019

Changes in this version

type Client

+ func (cli *Client) SetTempJSON(path string, obj interface{}) error

+ func (cli *Client) SetTempRawValue(path string, bytes []byte) error

+ func (cli *Client) SetTempString(path, s string) error

+ func (cli *Client) SetTempValue(path string, obj interface{}, codec Codec) error

type Watcher

+ func (w *Watcher) Close()

Oct 12, 2019

Changes in this version

type EventHandler

+ Path func() string

type MapHandler

+ func (h *MapHandler) Path() string

type ValueHandler

+ func (h *ValueHandler) Path() string

Oct 10, 2019

Changes in this version

+ func IsZKInvalidErr(err error) bool

+ func IsZKRecoverableErr(err error) bool

+ type ChildListener func(child string, obj interface{})

type Client

+ func (cli *Client) GetJSON(path string, typ reflect.Type) (interface{}, error)

+ func (cli *Client) GetString(path string) (string, error)

+ func (cli *Client) ParseJSON(path string, target interface{}) error

+ func (cli *Client) SetMapJSONValue(path, key string, obj interface{}) error

+ func (cli *Client) SetMapStringValue(path, key, s string) error

+ func (cli *Client) SyncWatch(path string, obj interface{}, codec Codec, listener ValueListener) (*Watcher, error)

+ func (cli *Client) SyncWatchJSON(path string, obj interface{}, listener ValueListener) (*Watcher, error)

+ func (cli *Client) SyncWatchJSONMap(path string, m interface{}, syncChild bool, listener ChildListener) error

+ func (cli *Client) SyncWatchMap(path string, m interface{}, valueCodec Codec, syncChild bool, ...) error

+ func (cli *Client) SyncWatchString(path string, s *string, listener ValueListener) (*Watcher, error)

+ func (cli *Client) SyncWatchStringMap(path string, m map[string]string, syncChild bool, listener ChildListener) error

type EventHandler

+ Handle func(*Watcher, *zk.Event) (<-chan zk.Event, error)

+ type MapHandler struct

+ func NewMapHandler(obj interface{}, syncChild bool, codec Codec, h ChildListener) (*MapHandler, error)

+ func (h *MapHandler) Decode(key string, data []byte) error

+ func (h *MapHandler) Delete(key string)

+ func (h *MapHandler) Encode(key string) ([]byte, error)

+ func (h *MapHandler) Handle(w *Watcher, evt *zk.Event) (<-chan zk.Event, error)

+ type ValueHandler struct

+ func NewValueHandler(obj interface{}, codec Codec, listener ValueListener) (*ValueHandler, error)

+ func StringValueHandler(s *string, listener ValueListener) *ValueHandler

+ func (h *ValueHandler) Decode(data []byte) error

+ func (h *ValueHandler) Encode() ([]byte, error)

+ func (h *ValueHandler) Handle(w *Watcher, evt *zk.Event) (<-chan zk.Event, error)

+ func (h *ValueHandler) SetTo(cli *Client, path string) error

+ type ValueListener func(interface{})

Oct 7, 2019

Changes in this version

+ func StateAlive(state zk.State) bool

+ type AlarmTrigger func(err error)

+ type Client struct

+ func NewClient(servers []string, timeout time.Duration) (*Client, error)

+ func (cli *Client) AppendDeadWatcher(watcher *Watcher)

+ func (cli *Client) Close()

+ func (cli *Client) Conn() *zk.Conn

+ func (cli *Client) ConnAlive() bool

+ func (cli *Client) Connecting() bool

+ func (cli *Client) Delete(path string) error

+ func (cli *Client) EnsurePath(path string) error

+ func (cli *Client) Get(path string, codec Codec, typ reflect.Type) (interface{}, error)

+ func (cli *Client) NewWatcher(path string, handler EventHandler) (*Watcher, error)

+ func (cli *Client) Reconnect() error

+ func (cli *Client) SetAlarmTrigger(f AlarmTrigger)

+ func (cli *Client) SetJSON(path string, obj interface{}) error

+ func (cli *Client) SetJSONMapValue(path, key string, obj interface{}) error

+ func (cli *Client) SetMapValue(path, key string, obj interface{}, codec Codec) error

+ func (cli *Client) SetPackValue(path string, pack *PackValue) error

+ func (cli *Client) SetRawValue(path string, bytes []byte) error

+ func (cli *Client) SetString(path, s string) error

+ func (cli *Client) SetStringMapValue(path, key, s string) error

+ func (cli *Client) SetValue(path string, obj interface{}, codec Codec) error

+ func (cli *Client) Sync(path string, obj interface{}, codec Codec) error

+ func (cli *Client) SyncJSON(path string, obj interface{}) error

+ func (cli *Client) SyncJSONMap(path string, obj interface{}) error

+ func (cli *Client) SyncMap(path string, m interface{}, valueCodec Codec, callback EventCallback, ...) error

+ func (cli *Client) SyncString(path, s string) error

+ func (cli *Client) SyncStringMap(path string, m map[string]string) error

+ type Codec interface

+ Decode func(data []byte, typ reflect.Type) (reflect.Value, error)

+ Encode func(obj interface{}) ([]byte, error)

+ type EventCallback func() error

+ type EventHandler func(*Client, *zk.Event) (<-chan zk.Event, error)

+ type JSONCodec struct

+ func (c *JSONCodec) Decode(data []byte, typ reflect.Type) (reflect.Value, error)

+ func (c *JSONCodec) Encode(obj interface{}) ([]byte, error)

+ type PackMap struct

+ func MapPack(obj interface{}, codec Codec) (*PackMap, error)

+ func (p *PackMap) Delete(key string)

+ func (p *PackMap) Get(key string) ([]byte, error)

+ func (p *PackMap) Set(key string, data []byte) error

+ type PackValue struct

+ func Pack(obj interface{}, codec Codec) (*PackValue, error)

+ func PackString(s *string) *PackValue

+ func (p *PackValue) Get() ([]byte, error)

+ func (p *PackValue) Set(data []byte) error

+ type StringCodec struct

+ func (c *StringCodec) Decode(data []byte, typ reflect.Type) (reflect.Value, error)

+ func (c *StringCodec) Encode(obj interface{}) ([]byte, error)

+ type Watcher struct

+ Path string

+ func (w *Watcher) Watch()