class Dynflow::Executors::Abstract

Constants

Event

Attributes

logger[R]
world[R]

Public Class Methods

new(world) click to toggle source
# File lib/dynflow/executors/abstract.rb, line 14
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 25
def event(execution_plan_id, step_id, event, future = Concurrent.future)
  raise NotImplementedError
end
execute(execution_plan_id) click to toggle source

@return [Concurrent::Edge::Future] @raise when execution_plan_id is not accepted

# File lib/dynflow/executors/abstract.rb, line 21
def execute(execution_plan_id)
  raise NotImplementedError
end
initialized() click to toggle source

@return [Concurrent::Edge::Future]

# File lib/dynflow/executors/abstract.rb, line 34
def initialized
  raise NotImplementedError
end
terminate(future = Concurrent.future) click to toggle source
# File lib/dynflow/executors/abstract.rb, line 29
def terminate(future = Concurrent.future)
  raise NotImplementedError
end