module Mamiya::Master::AgentMonitorHandlers
XXX: TODO:
Public Instance Methods
pkg__remove(status, payload, event)
click to toggle source
# File lib/mamiya/master/agent_monitor_handlers.rb, line 85 def pkg__remove(status, payload, event) status['packages'] ||= {} packages = status['packages'][payload['application']] packages.delete(payload['package']) if packages end
prerelease__remove(status, payload, event)
click to toggle source
# File lib/mamiya/master/agent_monitor_handlers.rb, line 91 def prerelease__remove(status, payload, event) status['prereleases'] ||= {} prereleases = status['prereleases'][payload['app']] prereleases.delete(payload['pkg']) if prereleases end
release__remove(status, payload, event)
click to toggle source
# File lib/mamiya/master/agent_monitor_handlers.rb, line 97 def release__remove(status, payload, event) status['releases'] ||= {} releases = status['releases'][payload['app']] releases.delete(payload['pkg']) if releases end
task___fetch__finish(status, task)
click to toggle source
XXX: move task finish handlers into tasks/
# File lib/mamiya/master/agent_monitor_handlers.rb, line 57 def task___fetch__finish(status, task) status['packages'] ||= {} status['packages'][task['app']] ||= [] unless status['packages'][task['app']].include?(task['pkg']) status['packages'][task['app']] << task['pkg'] end end
task___prepare__finish(status, task)
click to toggle source
# File lib/mamiya/master/agent_monitor_handlers.rb, line 66 def task___prepare__finish(status, task) status['prereleases'] ||= {} status['prereleases'][task['app']] ||= [] unless status['prereleases'][task['app']].include?(task['pkg']) status['prereleases'][task['app']] << task['pkg'] end end
task___switch__finish(status, task)
click to toggle source
# File lib/mamiya/master/agent_monitor_handlers.rb, line 75 def task___switch__finish(status, task) status['currents'] ||= {} status['currents'][task['app']] = task['pkg'] status['releases'] ||= {} status['releases'][task['app']] ||= [] status['releases'][task['app']].push task['pkg'] status['releases'][task['app']].uniq! end
task__error(status, payload, event)
click to toggle source
# File lib/mamiya/master/agent_monitor_handlers.rb, line 42 def task__error(status, payload, event) task = payload['task'] logger.error "#{status['name']} has failed task #{task['task'].inspect}: #{payload['error']}" task__finalize(status, payload, event) method_name = "task___#{task['task']}__error" if self.respond_to?(method_name) __send__ method_name, status, task, error end end
task__finalize(status, payload, event)
click to toggle source
# File lib/mamiya/master/agent_monitor_handlers.rb, line 17 def task__finalize(status, payload, event) task = payload['task'] status['queues'] ||= {} status['queues'][task['task']] ||= {'queue' => [], 'working' => nil} s = status['queues'][task['task']] if s['working'] == task s['working'] = nil end status['queues'][task['task']]['queue'].delete task end
task__finish(status, payload, event)
click to toggle source
# File lib/mamiya/master/agent_monitor_handlers.rb, line 30 def task__finish(status, payload, event) task = payload['task'] logger.info "#{status['name']} has finished task #{task['task'].inspect}" task__finalize(status, payload, event) method_name = "task___#{task['task']}__finish" if self.respond_to?(method_name) __send__ method_name, status, task end end
task__start(status, payload, event)
click to toggle source
# File lib/mamiya/master/agent_monitor_handlers.rb, line 7 def task__start(status, payload, event) task = payload['task'] status['queues'] ||= {} status['queues'][task['task']] ||= {'queue' => [], 'working' => nil} status['queues'][task['task']]['working'] = task status['queues'][task['task']]['queue'].delete task end