ocrd_network.runtime_data package

class ocrd_network.runtime_data.Deployer(config_path: str)[source]

Bases: object

deploy_workers(mongodb_url: str, rabbitmq_url: str) → None[source]
stop_workers() → None[source]
deploy_rabbitmq() → str[source]
stop_rabbitmq()[source]
deploy_mongodb() → str[source]
stop_mongodb()[source]
stop_all() → None[source]

The order of stopping is important to optimize graceful shutdown in the future. If RabbitMQ server is stopped before stopping Processing Workers that may have a bad outcome and leave Processing Workers in an unpredictable state.

start_uds_mets_server(ws_dir_path: str) → Path[source]
stop_uds_mets_server(mets_server_url: str, path_to_mets: str) → None[source]
class ocrd_network.runtime_data.DataHost(host: str, username: str, password: str, keypath: str, workers: List[Dict], servers: List[Dict])[source]

Bases: object

create_connection_client(client_type: str)[source]
deploy_workers(logger: Logger, mongodb_url: str, rabbitmq_url: str) → None[source]
stop_workers(logger: Logger)[source]
class ocrd_network.runtime_data.DataMongoDB(host: str, port: int, ssh_username: str | None, ssh_keypath: str | None, ssh_password: str | None, cred_username: str | None, cred_password: str | None, skip_deployment: bool, protocol: str = 'mongodb')[source]

Bases: DataNetworkService

deploy_mongodb(logger: Logger, image: str = 'mongo', detach: bool = True, remove: bool = True, env: List[str] | None = None, ports_mapping: Dict | None = None) → str[source]
stop_service_mongodb(logger: Logger) → None[source]
class ocrd_network.runtime_data.DataNetworkAgent(processor_name: str, deploy_type: DeployType, host: str, init_by_config: bool, pid: Any = None)[source]

Bases: object

class ocrd_network.runtime_data.DataRabbitMQ(host: str, port: int, ssh_username: str | None, ssh_keypath: str | None, ssh_password: str | None, cred_username: str | None, cred_password: str | None, skip_deployment: bool, protocol: str = 'amqp', vhost: str = '/')[source]

Bases: DataNetworkService

deploy_rabbitmq(logger: Logger, image: str = 'rabbitmq:4.2-management', detach: bool = True, remove: bool = True, env: List[str] | None = None, ports_mapping: Dict | None = None) → str[source]
stop_service_rabbitmq(logger: Logger) → None[source]
class ocrd_network.runtime_data.DataProcessingWorker(processor_name: str, deploy_type: DeployType, host: str, init_by_config: bool, pid: Any = None)[source]

Bases: DataNetworkAgent

deploy_network_agent(logger: Logger, connector_client, database_url: str, queue_url: str)[source]

Submodules