(historyID string)
| 252 | } |
| 253 | |
| 254 | func (p *Processor) logStaleNotification(historyID string) { |
| 255 | if historyID == "" { |
| 256 | return |
| 257 | } |
| 258 | |
| 259 | state := p.Repository.Get() |
| 260 | |
| 261 | stale, err := IsStaleHistoryID(state.HistoryID, historyID) |
| 262 | if err != nil { |
| 263 | p.warnf("watch: history id compare failed: %v", err) |
| 264 | |
| 265 | return |
| 266 | } |
| 267 | |
| 268 | if stale { |
| 269 | p.logf("watch: ignoring stale push historyId=%s (stored=%s)", historyID, state.HistoryID) |
| 270 | } |
| 271 | } |
| 272 | |
| 273 | func (p *Processor) sleepForFetch(ctx context.Context) error { |
| 274 | if p.Config.FetchDelay <= 0 { |
no test coverage detected