watcher

type ChangeEvent struct {
	Old any
	New any
}

type Event struct {
	// Event *clientv3.Event
	Data interface{}
}

type EventType byte

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

type Option func(*Options)

type Options struct {
	Key string
}

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

type Watcher interface {
	// Watch(ctx context.Context, key string) (chan model.Model, error)
	// WtachList(ctx context.Context, key string) (chan model.Model, error)
	WatchPipelinBind(ctx context.Context) chan model.PipelineBind
	WatchNode(ctx context.Context) chan node.Node
}

type WatcherEvent struct {
	EventType EventType
	Data      model.Model
}