zconf

README

ZConf

Usage

Installation

go get github.com/nenavizhuleto/zconf

In code

import "github.com/nenavizhuleto/zconf"

func main() {
	zc, _ := zconf.New([]string{"localhost:2182"})

    zc.WatchNode("/")
}

Subscribe for changes to ZooKeeper Nodes

c.OnNodeChanged(func(path string) {
    fmt.Println("path", path, "changed")
})

c.OnNodeDataChanged(func(path string, data []byte) {
    fmt.Println("path", path, "data", string(data))
})

c.WatchPath("/")

see examples for more.

Documentation

Index

• Variables
• type Config
  • func New(servers []string) (*Config, error)
  • func (c *Config) Dump(path string, value any) error
  • func (c *Config) Get(nodepath string) (node Node, err error)
  • func (c *Config) OnNodeChanged(callback NodeCallback)
  • func (c *Config) OnNodeDeleted(callback NodeCallback)
  • func (c *Config) WatchNode(ctx context.Context, nodepath string) error
  • func (c *Config) WatchPath(ctx context.Context, path string) error
• type Node
  • func (n *Node) Children() (nodes []Node, err error)
• type NodeCallback

Variables

var (
	DefaultSessionTimeout = time.Second
)

Types

type Config

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

func New

func New(servers []string) (*Config, error)

func (*Config) Dump

func (c *Config) Dump(path string, value any) error

func (*Config) Get

func (c *Config) Get(nodepath string) (node Node, err error)

func (*Config) OnNodeChanged

func (c *Config) OnNodeChanged(callback NodeCallback)

func (*Config) OnNodeDeleted

func (c *Config) OnNodeDeleted(callback NodeCallback)

func (*Config) WatchNode

func (c *Config) WatchNode(ctx context.Context, nodepath string) error

func (*Config) WatchPath

func (c *Config) WatchPath(ctx context.Context, path string) error

type Node

type Node struct {
	Path string
	Data []byte
	// contains filtered or unexported fields
}

func (*Node) Children

func (n *Node) Children() (nodes []Node, err error)

type NodeCallback

type NodeCallback func(path string, data []byte)