class Bosh::Director::Jobs::ScheduledEventsCleanup

Public Class Methods

has_work(params = {}) click to toggle source
# File lib/bosh/director/jobs/scheduled_events_cleanup.rb, line 10
def self.has_work(params = {})
  max_events = params.first['max_events']
  Models::Event.count > max_events
end
job_type() click to toggle source
# File lib/bosh/director/jobs/scheduled_events_cleanup.rb, line 6
def self.job_type
  :scheduled_events_cleanup
end
new(params = {}) click to toggle source
# File lib/bosh/director/jobs/scheduled_events_cleanup.rb, line 19
def initialize(params = {})
  logger.debug("ScheduledEventsCleanup initialized with params: #{params.inspect}")
  @max_events = params['max_events']
end
schedule_message() click to toggle source
# File lib/bosh/director/jobs/scheduled_events_cleanup.rb, line 15
def self.schedule_message
  "clean up events"
end

Public Instance Methods

perform() click to toggle source
# File lib/bosh/director/jobs/scheduled_events_cleanup.rb, line 24
def perform
  logger.info("Started cleanup of events")
  event_manager.remove_old_events(@max_events)
  "Old events were deleted"
end