()
| 33 | func (notif *NotifBase) LastNotifTime() int64 { return notif.lastNotified.Load() } |
| 34 | func (notif *NotifBase) SetLastNotified(now int64) { notif.lastNotified.Store(now) } |
| 35 | func (notif *NotifBase) NotifyInterval() time.Duration { |
| 36 | if notif.Interval == 0 { |
| 37 | return cmn.GCO.Get().Periodic.NotifTime.D() |
| 38 | } |
| 39 | return notif.Interval |
| 40 | } |
| 41 | |
| 42 | func shouldNotify(n cluster.Notif) bool { |
| 43 | lastTime := n.LastNotifTime() |