lib/flapjack/processor.rb in flapjack-2.0.0b1 vs lib/flapjack/processor.rb in flapjack-2.0.0rc1
- old
+ new
@@ -41,10 +41,15 @@
@repeat_failure_delay = @config['repeat_failure_delay']
if !@repeat_failure_delay.is_a?(Integer) || (@repeat_failure_delay < 0)
@repeat_failure_delay = nil
end
+ @initial_recovery_delay = @config['initial_recovery_delay']
+ if !@initial_recovery_delay.is_a?(Integer) || (@initial_recovery_delay < 0)
+ @initial_recovery_delay = nil
+ end
+
@notifier_queue = Flapjack::RecordQueue.new(@config['notifier_queue'] || 'notifications',
Flapjack::Data::Notification)
@archive_events = @config['archive_events'] || false
@events_archive_maxage = @config['events_archive_maxage']
@@ -263,12 +268,18 @@
repeat_fail_delay = (event_condition.nil? ? nil : event.repeat_failure_delay) ||
check.repeat_failure_delay ||
@repeat_failure_delay ||
Flapjack::DEFAULT_REPEAT_FAILURE_DELAY
+ init_recov_delay = (event_condition.nil? ? nil : event.initial_recovery_delay) ||
+ check.initial_recovery_delay ||
+ @initial_recovery_delay ||
+ Flapjack::DEFAULT_INITIAL_RECOVERY_DELAY
+
filter_opts = {
:initial_failure_delay => init_fail_delay,
:repeat_failure_delay => repeat_fail_delay,
+ :initial_recovery_delay => init_recov_delay,
:old_state => old_state, :new_state => new_state,
:timestamp => timestamp, :duration => event.duration
}
# acks only go into latest_notifications