class Dynflow::Testing::DummyWorld
Attributes
action[RW]
clock[R]
coordinator[R]
executor[R]
middleware[R]
Public Class Methods
new(_config = nil)
click to toggle source
# File lib/dynflow/testing/dummy_world.rb, line 11 def initialize(_config = nil) @logger_adapter = Testing.logger_adapter @clock = ManagedClock.new @executor = DummyExecutor.new(self) @middleware = Middleware::World.new @coordinator = DummyCoordinator.new end
Public Instance Methods
action_logger()
click to toggle source
# File lib/dynflow/testing/dummy_world.rb, line 19 def action_logger @logger_adapter.action_logger end
event(execution_plan_id, step_id, event, future = Concurrent::Promises.resolvable_future)
click to toggle source
# File lib/dynflow/testing/dummy_world.rb, line 35 def event(execution_plan_id, step_id, event, future = Concurrent::Promises.resolvable_future) executor.event execution_plan_id, step_id, event, future end
logger()
click to toggle source
# File lib/dynflow/testing/dummy_world.rb, line 23 def logger @logger_adapter.dynflow_logger end
persistence()
click to toggle source
# File lib/dynflow/testing/dummy_world.rb, line 47 def persistence nil end
plan_event(execution_plan_id, step_id, event, time, accepted = Concurrent::Promises.resolvable_future)
click to toggle source
# File lib/dynflow/testing/dummy_world.rb, line 39 def plan_event(execution_plan_id, step_id, event, time, accepted = Concurrent::Promises.resolvable_future) if time.nil? || time < Time.now event(execution_plan_id, step_id, event, accepted) else clock.ping(executor, time, Director::Event[SecureRandom.uuid, execution_plan_id, step_id, event, accepted], :delayed_event) end end
silence_logger!()
click to toggle source
# File lib/dynflow/testing/dummy_world.rb, line 27 def silence_logger! action_logger.level = 4 end
subscribed_actions(klass)
click to toggle source
# File lib/dynflow/testing/dummy_world.rb, line 31 def subscribed_actions(klass) [] end