Documentation
¶
Index ¶
Constants ¶
View Source
const ( StateOk uint32 = iota StateBreak )
View Source
const WatcherNotifyValueSize = 1024
Variables ¶
View Source
var (
ErrStateBreak = errors.New("state break")
)
Functions ¶
func DisableStrictMode ¶
func DisableStrictMode()
func EnableStrictMode ¶
func EnableStrictMode()
func WatchKey ¶
WatchKey from: https://en.wikipedia.org/wiki/Jenkins_hash_function (Jenkins' One-At-A-Time hashing)
Types ¶
type Watcher ¶
func (*Watcher) Namespace ¶
func (w *Watcher) Namespace(namespace string) *WatcherChild
type WatcherChannel ¶
type WatcherChannel struct {
Seq uint64
LastUpdate int64
Value *[]byte
Notify sync.Map // map[string]*WatcherNotify
// contains filtered or unexported fields
}
func (*WatcherChannel) AddNotify ¶
func (c *WatcherChannel) AddNotify(dest *WatcherNotify)
func (*WatcherChannel) UpdateValue ¶
func (c *WatcherChannel) UpdateValue(val *[]byte)
type WatcherChild ¶
func (*WatcherChild) Update ¶
func (c *WatcherChild) Update(key, value []byte)
func (*WatcherChild) Watch ¶
func (c *WatcherChild) Watch(key []byte) *WatcherNotify
type WatcherNotify ¶
type WatcherNotify struct {
Values chan *store.WatchValue
UUID string
// contains filtered or unexported fields
}
func (*WatcherNotify) Close ¶
func (n *WatcherNotify) Close() error
func (*WatcherNotify) Notify ¶
func (n *WatcherNotify) Notify() chan *store.WatchValue
Click to show internal directories.
Click to hide internal directories.