(msg database.AcquireNotificationMessagesRow)
| 322 | } |
| 323 | |
| 324 | func (n *notifier) newSuccessfulDispatch(msg database.AcquireNotificationMessagesRow) dispatchResult { |
| 325 | n.metrics.DispatchAttempts.WithLabelValues(string(msg.Method), msg.TemplateID.String(), ResultSuccess).Inc() |
| 326 | |
| 327 | return dispatchResult{ |
| 328 | notifier: n.id, |
| 329 | msg: msg.ID, |
| 330 | ts: dbtime.Time(n.clock.Now().UTC()), |
| 331 | } |
| 332 | } |
| 333 | |
| 334 | // revive:disable-next-line:flag-parameter // Not used for control flow, rather just choosing which metric to increment. |
| 335 | func (n *notifier) newFailedDispatch(msg database.AcquireNotificationMessagesRow, err error, retryable bool) dispatchResult { |
no test coverage detected