Method storeRevision

server/sync_watcher.go:318–324

storeRevision puts a reivision number for a path to the sync backend.

(path string, revision int64)

// storeRevision puts a reivision number for a path to the sync backend.
func (watcher *SyncWatcher) storeRevision(path string, revision int64) error {
	err := watcher.sync.Update(SyncWatchRevisionPrefix+path, strconv.FormatInt(revision, 10))
	if err != nil {
		return fmt.Errorf("Failed to update revision number for watch path `%s` in sync storage", path)
	}
	return nil
}

func (watcher *SyncWatcher) measureSyncTime(timeStarted time.Time, action string) {
	metrics.UpdateTimer(timeStarted, "sync.%s", action)