cobald.daemon package

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

The runner invoked on daemon startup

cobald.daemon.service(flavour)

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, or

• the ServiceUnit has been cancel()ed.

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
      • 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()