(response *gohan_sync.Event)
| 288 | } |
| 289 | |
| 290 | func (watcher *SyncWatcher) watchExtensionHandler(response *gohan_sync.Event) { |
| 291 | defer l.Panic(log) |
| 292 | for _, event := range watcher.watchEvents { |
| 293 | //match extensions |
| 294 | if strings.HasPrefix(response.Key, "/"+event) { |
| 295 | env := watcher.watchExtensions[event] |
| 296 | watcher.runExtensionOnSync(response, env.Clone()) |
| 297 | return |
| 298 | } |
| 299 | } |
| 300 | } |
| 301 | |
| 302 | // fetchStoredRevision returns the revision number stored in the sync backend for a path. |
| 303 | // When it's a new in the backend, returns sync.RevisionCurrent. |
no test coverage detected