class Dynflow::Executors::Abstract
Attributes
logger[R]
world[R]
Public Class Methods
new(world)
click to toggle source
# File lib/dynflow/executors/abstract.rb, line 7 def initialize(world) @world = Type! world, World @logger = world.logger end
Public Instance Methods
event(execution_plan_id, step_id, event, future = Concurrent.future)
click to toggle source
# File lib/dynflow/executors/abstract.rb, line 22 def event(execution_plan_id, step_id, event, future = Concurrent.future) raise NotImplementedError end
execute(execution_plan_id, finished = Concurrent.future, wait_for_acceptance = true)
click to toggle source
@param execution_plan_id [String] id of execution plan @param finished [Concurrent::Edge::Future] @param wait_for_acceptance [TrueClass|FalseClass] should the executor confirm receiving the event, disable if calling executor from within executor @return [Concurrent::Edge::Future] @raise when execution_plan_id is not accepted
# File lib/dynflow/executors/abstract.rb, line 18 def execute(execution_plan_id, finished = Concurrent.future, wait_for_acceptance = true) raise NotImplementedError end
execution_status(execution_plan_id = nil)
click to toggle source
# File lib/dynflow/executors/abstract.rb, line 30 def execution_status(execution_plan_id = nil) raise NotImplementedError end
initialized()
click to toggle source
@return [Concurrent::Edge::Future]
# File lib/dynflow/executors/abstract.rb, line 35 def initialized raise NotImplementedError end
terminate(future = Concurrent.future)
click to toggle source
# File lib/dynflow/executors/abstract.rb, line 26 def terminate(future = Concurrent.future) raise NotImplementedError end