Method
newInhibitedDispatch
(msg database.AcquireNotificationMessagesRow)
Source from the content-addressed store, hash-verified
| 355 | } |
| 356 | |
| 357 | func (n *notifier) newInhibitedDispatch(msg database.AcquireNotificationMessagesRow) dispatchResult { |
| 358 | return dispatchResult{ |
| 359 | notifier: n.id, |
| 360 | msg: msg.ID, |
| 361 | ts: dbtime.Time(n.clock.Now().UTC()), |
| 362 | retryable: false, |
| 363 | inhibited: true, |
| 364 | } |
| 365 | } |
| 366 | |
| 367 | // stop stops the notifier from processing any new notifications. |
| 368 | // This is a graceful stop, so any in-flight notifications will be completed before the notifier stops. |
Tested by
no test coverage detected