watcher

package

v0.0.19 Latest Latest Go to latest Published: Mar 20, 2021 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

View Source

var Name = "watcher"

View Source

var Prefix = "/watchers"

func KeyToDot(prefix string) string

/projectName/foo/bar --> projectName.foo.bar

func Register(name string, w Factory)

func Watch(name string, h CallBack)

type CallBack func(name string, event *Response) error

type Cfg struct {
	Prefix   string   `json:"prefix"`
	Driver   string   `json:"driver"`
	Projects []string `json:"projects"`
}

func GetDefaultCfg() Cfg

type Factory func(cfg typex.M) (Watcher, error)

type Opt func(*Opts)

type Opts struct{}

type Response struct {
	Event    string
	Key      string
	Value    []byte
	Revision int64
}

func (t *Response) Decode(val interface{}) (gErr error)

func (t *Response) OnDelete(fn func())

func (t *Response) OnPut(fn func())

type Watcher interface {
	Watch(ctx context.Context, key string, opts ...Opt) <-chan *Response
	Name() string
}

Watcher ...

Path	Synopsis
watchers