libmuscle.manager package

Subpackages

• libmuscle.manager.test package
  • Submodules
    • libmuscle.manager.test.conftest module
    • libmuscle.manager.test.test_instance_registry module
    • libmuscle.manager.test.test_logger module
      • test_create_logger()
      • test_log_level()
      • test_log_message()
    • libmuscle.manager.test.test_mmp_request_handler module
      • test_create_servicer()
      • test_deregister_instance()
      • test_double_register_instance()
      • test_get_checkpoint_info()
      • test_get_checkpoint_info2()
      • test_get_peers_pending()
      • test_get_settings()
      • test_log_message()
      • test_register_instance()
      • test_register_instance_no_version()
      • test_register_instance_version_mismatch()
      • test_request_peers_bidir()
      • test_request_peers_fanin()
      • test_request_peers_fanout()
      • test_request_peers_own_conduits()
      • test_request_peers_unknown()
      • test_submit_snapshot()
    • libmuscle.manager.test.test_profile_database module
    • libmuscle.manager.test.test_profile_store module
      • test_add_events()
      • test_create_profile_store()
    • libmuscle.manager.test.test_snapshot_registry module
    • libmuscle.manager.test.test_topology_store module

Submodules

• libmuscle.manager.instance_manager module
  • InstanceManager
    • InstanceManager.get_resources()
    • InstanceManager.set_manager_location()
    • InstanceManager.shutdown()
    • InstanceManager.start_all()
    • InstanceManager.wait()
  • LogHandlingThread
    • LogHandlingThread.run()
    • LogHandlingThread.shutdown()
• libmuscle.manager.instance_registry module
  • AlreadyRegistered
  • InstanceRegistry
    • InstanceRegistry.add()
    • InstanceRegistry.did_register()
    • InstanceRegistry.get_locations()
    • InstanceRegistry.get_ports()
    • InstanceRegistry.remove()
    • InstanceRegistry.wait()
• libmuscle.manager.instantiator module
  • CancelAllRequest
  • CrashedResult
  • InstantiationRequest
    • InstantiationRequest.instance
    • InstantiationRequest.implementation
    • InstantiationRequest.resources
  • InstantiatorRequest
  • Process
    • Process.instance
    • Process.resources
    • Process.status
    • Process.exit_code
    • Process.error_msg
  • ProcessStatus
    • ProcessStatus.CANCELED
    • ProcessStatus.ERROR
    • ProcessStatus.RUNNING
    • ProcessStatus.STARTED
    • ProcessStatus.SUCCESS
    • ProcessStatus.is_finished()
  • QueueingLogHandler
    • QueueingLogHandler.emit()
  • ShutdownRequest
• libmuscle.manager.logger module
  • Formatter
    • Formatter.formatMessage()
    • Formatter.usesTime()
  • Logger
    • Logger.close()
    • Logger.log_message()
  • last_lines()
• libmuscle.manager.manager module
  • Manager
    • Manager.get_server_location()
    • Manager.start_instances()
    • Manager.stop()
    • Manager.wait()
• libmuscle.manager.mmp_server module
  • MMPRequestHandler
    • MMPRequestHandler.close()
    • MMPRequestHandler.handle_request()
  • MMPServer
    • MMPServer.get_location()
    • MMPServer.stop()
  • decode_operator()
  • decode_port()
  • encode_checkpoint_rule()
  • encode_checkpoints()
  • encode_conduit()
• libmuscle.manager.profile_database module
  • ProfileDatabase
    • ProfileDatabase.close()
    • ProfileDatabase.instance_stats()
    • ProfileDatabase.resource_stats()
    • ProfileDatabase.time_taken()
• libmuscle.manager.profile_store module
  • ProfileStore
    • ProfileStore.add_events()
    • ProfileStore.shutdown()
    • ProfileStore.store_instances()
    • ProfileStore.store_resources()
• libmuscle.manager.qcgpj_instantiator module
  • QCGPJInstantiator
    • QCGPJInstantiator.run()
  • StateTracker
    • StateTracker.processes
    • StateTracker.job_executing()
    • StateTracker.job_finished()
• libmuscle.manager.run_dir module
  • RunDir
    • RunDir.add_instance_dir()
    • RunDir.instance_dir()
    • RunDir.snapshot_dir()
• libmuscle.manager.snapshot_registry module
  • SnapshotNode
    • SnapshotNode.num
    • SnapshotNode.instance
    • SnapshotNode.snapshot
    • SnapshotNode.peers
    • SnapshotNode.consistent_peers
    • SnapshotNode.consistent
    • SnapshotNode.consistent_peers
    • SnapshotNode.do_consistency_check()
    • SnapshotNode.instance
    • SnapshotNode.num
    • SnapshotNode.peers
    • SnapshotNode.snapshot
  • SnapshotRegistry
    • SnapshotRegistry.register_snapshot()
    • SnapshotRegistry.run()
    • SnapshotRegistry.shutdown()
  • calc_consistency()
  • calc_consistency_list()
  • safe_get()
• libmuscle.manager.topology_store module
  • TopologyStore
    • TopologyStore.conduits
    • TopologyStore.get_conduits()
    • TopologyStore.get_peer_dimensions()
    • TopologyStore.get_peer_instances()
    • TopologyStore.has_kernel()