client

Aug 18, 2019

Changes in this version

type EtcdFileWatcher

+ func (ecw *EtcdFileWatcher) SaveLocal(k, v string)

type EtcdUdsWatcher

+ func (euw *EtcdUdsWatcher) SaveLocal(k, v string)

type MemoryWatcher

+ func (emw *MemoryWatcher) SaveLocal(k, v string)

type Watcher

+ SaveLocal func(k, v string)

Aug 18, 2019

Changes in this version

+ type MemoryWatcher struct

+ Tc *cache.TimerCacheEtcd

+ func (emw *MemoryWatcher) Find(cmd []string) (string, error)

+ func (emw *MemoryWatcher) KeepEyesOnKey(key string)

+ func (emw *MemoryWatcher) KeepEyesOnKeyWithPrefix(prefix string)

Aug 17, 2019

Changes in this version

type EtcdFileWatcher

+ func (ecw *EtcdFileWatcher) Find(cmd []string) (string, error)

type Watcher

+ Find func(cmd []string) (string, error)

Aug 13, 2019

Changes in this version

+ type EtcdFileWatcher struct

+ RetrySeconds int

+ StoreDir string

+ Tc *cache.TimerCacheEtcd

+ func (ecw *EtcdFileWatcher) KeepEyesOnKey(key string)

+ func (ecw *EtcdFileWatcher) KeepEyesOnKeyWithPrefix(module string)

+ type EtcdMemoryWatcher struct

+ Tc *cache.TimerCacheEtcd

+ func (emw *EtcdMemoryWatcher) Find(cmd []string) (string, error)

+ func (emw *EtcdMemoryWatcher) KeepEyesOnKey(key string)

+ func (emw *EtcdMemoryWatcher) KeepEyesOnKeyWithPrefix(prefix string)

+ type EtcdUdsWatcher struct

+ Tc *cache.TimerCacheEtcd

+ func (euw *EtcdUdsWatcher) Find(cmd []string) (string, error)

+ func (euw *EtcdUdsWatcher) KeepEyesOnKey(key string)

+ func (euw *EtcdUdsWatcher) KeepEyesOnKeyWithPrefix(prefix string)

+ func (euw *EtcdUdsWatcher) ServeSocket(sockFile string)

+ type GeneralWatcher struct

+ func (gw *GeneralWatcher) GetTimerCache() *cache.TimerCacheEtcd

+ func (gw *GeneralWatcher) Init(tc *cache.TimerCacheEtcd, prefix string, callback func(k, v string))

+ func (gw *GeneralWatcher) KeepEyesOnKey(key string)

+ func (gw *GeneralWatcher) KeepEyesOnKeyWithPrefix(module string)

+ func (gw *GeneralWatcher) Watch(tc *cache.TimerCacheEtcd, key string, putCallback func(k, v string), ...)

+ type SyncFileWorker struct

+ func (sw *SyncFileWorker) RemoveOne(key interface{})

+ func (sw *SyncFileWorker) Retry()

+ func (sw *SyncFileWorker) SyncOne(key, value interface{})

+ type UnixSocket struct

+ Wch *EtcdMemoryWatcher

+ func (uxs *UnixSocket) Serve(sockFile string)

+ type Watcher interface

+ KeepEyesOnKey func(key string)

+ KeepEyesOnKeyWithPrefix func(module string)

+ type Worker interface

+ RemoveOne func(key interface{})

+ Retry func()

+ SyncOne func(key, value interface{})