Function cleanNotifyThreshold

service/compat/notify.go:272–283

(ctx *mgr.WorkerCtx)

}

func cleanNotifyThreshold(ctx *mgr.WorkerCtx) error {
	notifyThresholdsLock.Lock()
	defer notifyThresholdsLock.Unlock()

	for id, nt := range notifyThresholds {
		if nt.expired() {
			delete(notifyThresholds, id)
		}
	}

	return nil
}