class Dynflow::Testing::DummyWorld

Attributes

action[RW]
clock[R]
coordinator[R]
delayed_executor[R]
executor[R]
middleware[R]

Public Class Methods

new(_config = nil) click to toggle source
# File lib/dynflow/testing/dummy_world.rb, line 12
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 20
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 36
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 24
def logger
  @logger_adapter.dynflow_logger
end
persistence() click to toggle source
# File lib/dynflow/testing/dummy_world.rb, line 48
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 40
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 28
def silence_logger!
  action_logger.level = 4
end
subscribed_actions(klass) click to toggle source
# File lib/dynflow/testing/dummy_world.rb, line 32
def subscribed_actions(klass)
  []
end