Class: Wakame::Trigger

Inherits:
Object
  • Object
show all
Includes:
AttributeHelper, FilterChain
Defined in:
lib/wakame/trigger.rb

Constant Summary

Constants included from AttributeHelper

AttributeHelper::CONVERT_CLASSES, AttributeHelper::PRIMITIVE_CLASSES

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from AttributeHelper

#dump_attrs

Methods included from FilterChain

included, #run_filter

Instance Attribute Details

#rule_engine ⇒ Object (readonly)

Returns the value of attribute rule_engine.



8
9
10
 
# File 'lib/wakame/trigger.rb', line 8

def rule_engine
  @rule_engine
end

Instance Method Details

#agent_monitor ⇒ Object 



21
22
23
 
# File 'lib/wakame/trigger.rb', line 21

def agent_monitor
  @rule_engine.agent_monitor
end

#bind_engine(rule_engine) ⇒ Object 



25
26
27
 
# File 'lib/wakame/trigger.rb', line 25

def bind_engine(rule_engine)
  @rule_engine = rule_engine
end

#cleanup ⇒ Object 



40
41
 
# File 'lib/wakame/trigger.rb', line 40

def cleanup
end

#command_queue ⇒ Object 



9
10
11
 
# File 'lib/wakame/trigger.rb', line 9

def command_queue
  @rule_engine.command_queue
end

#master ⇒ Object 



17
18
19
 
# File 'lib/wakame/trigger.rb', line 17

def master
  @rule_engine.master
end

#register_hooks ⇒ Object 



37
38
 
# File 'lib/wakame/trigger.rb', line 37

def register_hooks
end

#service_cluster ⇒ Object 



13
14
15
 
# File 'lib/wakame/trigger.rb', line 13

def service_cluster
  @rule_engine.service_cluster
end

#trigger_action(action) ⇒ Object 



29
30
31
32
33
34
35
 
# File 'lib/wakame/trigger.rb', line 29

def trigger_action(action)
  rule_engine.create_job_context(self, action)
  action.bind_trigger(self)
  
  rule_engine.run_action(action)
  action.job_id
end