emulator_engine package

Emulator engine for the SKA Mid.CBF system.

• emulator_engine.features package
  • emulator_engine.features.controller package
    • EmulatorController
      • EmulatorController.await_api_cleanup()
      • EmulatorController.flush_all()
      • EmulatorController.start()
      • EmulatorController.stop()
      • EmulatorController.terminate()
  • emulator_engine.features.signal_generator package
    • SignalGeneratorEventHandler
      • SignalGeneratorEventHandler.handle_manual_event()
      • SignalGeneratorEventHandler.handle_pulse_event()
      • SignalGeneratorEventHandler.handle_signal_update_events()
      • SignalGeneratorEventHandler.subcontroller
    • SignalGeneratorSubcontroller
      • SignalGeneratorSubcontroller.subcontroller_init()
• emulator_engine.models package
  • ControllerCommand
    • ControllerCommand.START
    • ControllerCommand.STOP
    • ControllerCommand.TERMINATE
  • ControllerCommandEvent
    • ControllerCommandEvent.command
    • ControllerCommandEvent.value
    • ControllerCommandEvent.severity
    • ControllerCommandEvent.source_timestamp
    • ControllerCommandEvent.update_timestamp
    • ControllerCommandEvent.command
    • ControllerCommandEvent.decode()
    • ControllerCommandEvent.encode()
• emulator_engine.services package
  • emulator_engine.services.api package
    • RouterClient
      • RouterClient.get_rpc_response()
      • RouterClient.router
    • RouterImpl
      • RouterImpl.call()
      • RouterImpl.error_catcher()
    • SubcontrollerRouterImpl
  • emulator_engine.services.controller package
    • ControllerRouterClient
    • ControllerRouterImpl
    • ControllerState
      • ControllerState.ERROR
      • ControllerState.IDLE
      • ControllerState.INITIALIZING
      • ControllerState.RUNNING
      • ControllerState.STARTING
      • ControllerState.STOPPING
      • ControllerState.TERMINATED
      • ControllerState.TERMINATING
    • ControllerStateMachine
    • ControllerTransitionTrigger
      • ControllerTransitionTrigger.ERROR
      • ControllerTransitionTrigger.FINISH_INITIALIZING
      • ControllerTransitionTrigger.FINISH_STARTING
      • ControllerTransitionTrigger.FINISH_STOPPING
      • ControllerTransitionTrigger.FINISH_TERMINATING
      • ControllerTransitionTrigger.START
      • ControllerTransitionTrigger.STOP
      • ControllerTransitionTrigger.TERMINATE
  • emulator_engine.services.ip_block_emulator package
    • IPBlockEmulatorFactory
      • IPBlockEmulatorFactory.create()
      • IPBlockEmulatorFactory.create_many()
    • IPBlockEmulatorValidator
      • IPBlockEmulatorValidator.validate()
      • IPBlockEmulatorValidator.validate_and_get_components()
    • IPBlockEmulatorValidatorResult
      • IPBlockEmulatorValidatorResult.overall_status
      • IPBlockEmulatorValidatorResult.result
      • IPBlockEmulatorValidatorResult.API_KEY
      • IPBlockEmulatorValidatorResult.EVENT_HANDLER_KEY
      • IPBlockEmulatorValidatorResult.IP_BLOCK_KEY
      • IPBlockEmulatorValidatorResult.STATE_MACHINE_KEY
      • IPBlockEmulatorValidatorResult.insert_msg()
      • IPBlockEmulatorValidatorResult.json_dict
    • RequestValidator
      • RequestValidator.validate()
    • RequestValidatorResult
      • RequestValidatorResult.overall_status
      • RequestValidatorResult.result
      • RequestValidatorResult.combined_args
      • RequestValidatorResult.PATH_KEY
      • RequestValidatorResult.QUERY_KEY
      • RequestValidatorResult.BODY_KEY
      • RequestValidatorResult.OTHER_KEY
      • RequestValidatorResult.BODY_KEY
      • RequestValidatorResult.OTHER_KEY
      • RequestValidatorResult.PATH_KEY
      • RequestValidatorResult.QUERY_KEY
      • RequestValidatorResult.insert_arg()
      • RequestValidatorResult.insert_msg()
      • RequestValidatorResult.insert_other()
      • RequestValidatorResult.json_dict
    • RouterFactory
      • RouterFactory.create()
  • emulator_engine.services.messaging package
    • ApiQueueService
      • ApiQueueService.flush()
      • ApiQueueService.force_stop()
      • ApiQueueService.get_rpc_response()
      • ApiQueueService.init_for_subcontroller()
      • ApiQueueService.publish()
      • ApiQueueService.subscribe()
      • ApiQueueService.unsubscribe()
    • EventQueueService
      • EventQueueService.flush()
      • EventQueueService.publish()
      • EventQueueService.publish_pulse_with_signal_event_group()
      • EventQueueService.subscribe()
      • EventQueueService.unsubscribe()