kv

type DataHandler func(fullPath string, rowID string, value []byte) bool

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

type EventType int32

type KV interface {
	Close() error
	PutObject(key string, value interface{}) (revision int64, err error)
	Put(key, val string) (revision int64, err error)
	GetOne(key string) (value []byte, err error)
	GetObject(key string, obj interface{}) (err error)
	GetWithPrefix(key string, handler DataHandler) (err error)
	GetWithPrefixLimit(key string, limit int64, handler DataHandler) (err error)
	DeleteOne(key string) (deleted bool, err error)
	DeleteWithPrefix(key string) (deleted int64, err error)
	Watch(key string, handler func(eventType EventType, fullPath string, rowID string, value []byte)) *Watcher
	WatchWithPrefix(key string, handler func(eventType EventType, fullPath string, rowID string, value []byte)) *Watcher
}

type Watcher struct {
	Key string
	// contains filtered or unexported fields
}