libmuscle.manager.mmp_server module
- class libmuscle.manager.mmp_server.MMPRequestHandler(logger: Logger, profile_store: ProfileStore, configuration: PartialConfiguration, instance_registry: InstanceRegistry, topology_store: TopologyStore, snapshot_registry: SnapshotRegistry, run_dir: RunDir | None)[source]
Bases:
RequestHandler
Handles Manager requests.
- class libmuscle.manager.mmp_server.MMPServer(logger: Logger, profile_store: ProfileStore, configuration: PartialConfiguration, instance_registry: InstanceRegistry, topology_store: TopologyStore, snapshot_registry: SnapshotRegistry, run_dir: RunDir | None)[source]
Bases:
object
The MUSCLE Manager Protocol server.
This class accepts connections from the instances comprising the multiscale model to be executed, and services them using an MMPRequestHandler.
- libmuscle.manager.mmp_server.decode_operator(data: str) Operator [source]
Create an Operator from a MsgPack-compatible value.
- libmuscle.manager.mmp_server.decode_port(data: List[str]) Port [source]
Create a Port from a MsgPack-compatible value.
- libmuscle.manager.mmp_server.encode_checkpoint_rule(rule: CheckpointRule) Dict[str, Any] [source]
Convert a CheckpointRule to a MsgPack-compatible value.