Versions in this module Expand all Collapse all v1 v1.0.0 Jul 17, 2018 Changes in this version + type Sync struct + func NewSync(etcdServers []string, timeout time.Duration) (*Sync, error) + func (s *Sync) Close() + func (s *Sync) Delete(key string, prefix bool) error + func (s *Sync) Fetch(key string) (*sync.Node, error) + func (s *Sync) GetProcessID() string + func (s *Sync) HasLock(path string) bool + func (s *Sync) Lock(path string, block bool) (chan struct{}, error) + func (s *Sync) Unlock(path string) error + func (s *Sync) Update(key, jsonString string) error + func (s *Sync) Watch(path string, responseChan chan *sync.Event, stopChan chan bool, revision int64) error + func (s *Sync) WatchContext(ctx context.Context, path string, revision int64) <-chan *sync.Event
Go to main page