Method fetchStoredRevision

server/sync_watcher.go:304–315

fetchStoredRevision returns the revision number stored in the sync backend for a path. When it's a new in the backend, returns sync.RevisionCurrent.

(path string)

// fetchStoredRevision returns the revision number stored in the sync backend for a path.
// When it's a new in the backend, returns sync.RevisionCurrent.
func (watcher *SyncWatcher) fetchStoredRevision(path string) int64 { // TODO error?
	fromRevision := int64(gohan_sync.RevisionCurrent)
	lastSeen, err := watcher.sync.Fetch(SyncWatchRevisionPrefix + path)
	if err == nil {
		inStore, err := strconv.ParseInt(lastSeen.Value, 10, 64)
		if err == nil {
			log.Info("Using last seen revision `%d` for watching path `%s`", inStore, path)
			fromRevision = inStore
		}
	}
	return fromRevision
}

// storeRevision puts a reivision number for a path to the sync backend.
func (watcher *SyncWatcher) storeRevision(path string, revision int64) error {