Class: Wakame::Actor::ServiceMonitor

Inherits:
Object
  • Object
show all
Includes:
Wakame::Actor
Defined in:
lib/wakame/actor/service_monitor.rb

Constant Summary

Constants included from Wakame::Actor

STATUS_CANCELED, STATUS_FAILED, STATUS_RUNNING, STATUS_SUCCESS

Instance Method Summary collapse

Methods included from Wakame::Actor

included

Instance Method Details

#check_status(svc_id) ⇒ Object

Immediate status check for the specified Service ID.



23
24
25
26
27
28
29
 
# File 'lib/wakame/actor/service_monitor.rb', line 23

def check_status(svc_id)
  self.return_value = EM.barrier {
    svcmon = agent.monitor_registry.find_monitor('/service')
    svcmon.check_status(svc_id)
  }
  self.return_value
end

#register(svc_id, type, *args) ⇒ Object 



6
7
8
9
10
11
12
 
# File 'lib/wakame/actor/service_monitor.rb', line 6

def register(svc_id, type, *args)
  EM.barrier {
    svcmon = agent.monitor_registry.find_monitor('/service')
    svcmon.register(svc_id, type, *args)
  }
  self.return_value = check_status(svc_id)
end

#unregister(svc_id) ⇒ Object 



15
16
17
18
19
20
 
# File 'lib/wakame/actor/service_monitor.rb', line 15

def unregister(svc_id)
  EM.barrier {
    svcmon = agent.monitor_registry.find_monitor('/service')
    svcmon.unregister(svc_id)
  }
end