cobald.daemon package

cobald.daemon.runtime = <cobald.daemon.runners.service.ServiceRunner object>

The runner invoked on daemon startup

cobald.daemon.service(flavour: ModuleType) → Callable[[type[S]], type[S]]

Mark a class as implementing a Service

Each Service class must have a run method, which does not take any arguments. This method is adopt()ed after the daemon starts, unless the Service has been garbage collected

For each service instance, its ServiceUnit is available at service_instance.__service_unit__.

Subpackages

• cobald.daemon.config package
  • Submodules
    • cobald.daemon.config.mapping module
      • ConfigurationError
      • M
      • SectionPlugin
        • SectionPlugin.after
        • SectionPlugin.before
        • SectionPlugin.digest
        • SectionPlugin.load()
        • SectionPlugin.required
        • SectionPlugin.requirements
        • SectionPlugin.section
      • Translator
        • Translator.construct()
        • Translator.load_name()
        • Translator.translate_hierarchy()
      • configure_logging()
      • load_configuration()
    • cobald.daemon.config.python module
      • load_configuration()
    • cobald.daemon.config.yaml module
      • load_configuration()
      • yaml_constructor()
• cobald.daemon.core package
  • Submodules
    • cobald.daemon.core.cli module
    • cobald.daemon.core.config module
      • COBalDLoader
      • PipelineTranslator
        • PipelineTranslator.translate_hierarchy()
      • add_constructor_plugins()
      • load()
      • load_pipeline()
      • load_section_plugins()
    • cobald.daemon.core.logger module
      • create_handler()
      • initialise_logging()
    • cobald.daemon.core.main module
      • cli_run()
      • run()
• cobald.daemon.runners package
  • Submodules
    • cobald.daemon.runners.async_tools module
    • cobald.daemon.runners.asyncio_runner module
      • AsyncioRunner
        • AsyncioRunner.aclose()
        • AsyncioRunner.flavour
        • AsyncioRunner.manage_payloads()
        • AsyncioRunner.register_payload()
        • AsyncioRunner.run_payload()
    • cobald.daemon.runners.asyncio_watcher module
    • cobald.daemon.runners.base_runner module
      • BaseRunner
        • BaseRunner.aclose()
        • BaseRunner.flavour
        • BaseRunner.manage_payloads()
        • BaseRunner.ready()
        • BaseRunner.register_payload()
        • BaseRunner.run()
        • BaseRunner.run_payload()
        • BaseRunner.stop()
      • OrphanedReturn
    • cobald.daemon.runners.guard module
      • exclusive()
    • cobald.daemon.runners.meta_runner module
      • MetaRunner
        • MetaRunner.register_payload()
        • MetaRunner.run()
        • MetaRunner.run_payload()
        • MetaRunner.runner_types
        • MetaRunner.runners
        • MetaRunner.stop()
    • cobald.daemon.runners.service module
      • Service
        • Service.run()
      • ServiceRunner
        • ServiceRunner.accept()
        • ServiceRunner.adopt()
        • ServiceRunner.execute()
        • ServiceRunner.shutdown()
      • ServiceUnit
        • ServiceUnit.running
        • ServiceUnit.start()
        • ServiceUnit.units()
      • service()
    • cobald.daemon.runners.thread_runner module
      • ThreadRunner
        • ThreadRunner.aclose()
        • ThreadRunner.flavour
        • ThreadRunner.manage_payloads()
        • ThreadRunner.register_payload()
        • ThreadRunner.run_payload()
    • cobald.daemon.runners.trio_runner module
      • TrioRunner
        • TrioRunner.aclose()
        • TrioRunner.flavour
        • TrioRunner.manage_payloads()
        • TrioRunner.ready()
        • TrioRunner.register_payload()
        • TrioRunner.run_payload()

Submodules

• cobald.daemon.debug module
  • NameRepr
  • pretty_module()
  • pretty_partial()
  • pretty_ref()