watcher

type Cfg struct {
	Driver    string                 `json:"driver"`
	DriverCfg map[string]interface{} `json:"driver_config"`
	SkipNull  bool                   `json:"skip_null"`

	// Projects 需要watcher的项目
	Projects []string `json:"projects"`
}

type Factory = func(cfg config.CfgMap) (Watcher, error)

type Opt func(*options)

type Response struct {
	Type    string
	Event   event.EventType
	Key     string
	Value   []byte
	Version int64
}

type WatchHandler = func(name string, r *Response) error

type Watcher interface {
	Init()
	Close()
	Get(ctx context.Context, key string, opts ...Opt) ([]*Response, error)
	GetCallback(ctx context.Context, key string, fn func(resp *Response), opts ...Opt) error
	Watch(ctx context.Context, key string, opts ...Opt) <-chan *Response
	WatchCallback(ctx context.Context, key string, fn func(resp *Response), opts ...Opt)
}