edri.abstract package

Subpackages

• edri.abstract.manager package
  • Submodules
  • edri.abstract.manager.async_manager_base module
    • AsyncManagerBase
      • AsyncManagerBase.resolve()
      • AsyncManagerBase.run_resolver()
  • edri.abstract.manager.manager_base module
    • ManagerBase
      • ManagerBase.additional_pipes
      • ManagerBase.after_start()
      • ManagerBase.close_failed_pipe()
      • ManagerBase.collect_custom_vitals()
      • ManagerBase.disable_additional_pipe()
      • ManagerBase.execute_event_resolver()
      • ManagerBase.get_event_resolver()
      • ManagerBase.get_pipes()
      • ManagerBase.get_resolver_cache_state()
      • ManagerBase.handle_additional_pipe_receive_error()
      • ManagerBase.handle_pipe_receive_error()
      • ManagerBase.handle_resolver_exception()
      • ManagerBase.handle_router_pipe_receive_error()
      • ManagerBase.handle_worker_pipe_receive_error()
      • ManagerBase.health()
      • ManagerBase.health_check()
      • ManagerBase.is_not_modified_request()
      • ManagerBase.is_router_pipe()
      • ManagerBase.max_workers
      • ManagerBase.name
      • ManagerBase.on_resolver_idle()
      • ManagerBase.prepare_cache_response()
      • ManagerBase.prepare_outgoing_event()
      • ManagerBase.prepare_resolved_event()
      • ManagerBase.quit()
      • ManagerBase.receive_pipe_event()
      • ManagerBase.record_resolved_event()
      • ManagerBase.resolve()
      • ManagerBase.resolve_active_pipe()
      • ManagerBase.resolve_callback_pipe()
      • ManagerBase.resolve_callback_worker()
      • ManagerBase.resolve_non_router_event()
      • ManagerBase.resolve_non_router_pipe()
      • ManagerBase.resolve_not_modified()
      • ManagerBase.resolve_router_event()
      • ManagerBase.resolve_router_pipe()
      • ManagerBase.resolve_unknown()
      • ManagerBase.resolve_worker_control_event()
      • ManagerBase.resolve_worker_event()
      • ManagerBase.resolver_idle_delay
      • ManagerBase.resolver_wait_timeout
      • ManagerBase.run()
      • ManagerBase.run_resolver()
      • ManagerBase.run_resolver_cycle()
      • ManagerBase.send_to_router()
      • ManagerBase.should_send_resolved_event()
      • ManagerBase.start()
      • ManagerBase.start_worker()
      • ManagerBase.stop_resolver()
      • ManagerBase.store_get()
      • ManagerBase.wait_for_active_pipes()
  • edri.abstract.manager.manager_priority_base module
    • ManagerPriorityBase
      • ManagerPriorityBase.additional_pipes
      • ManagerPriorityBase.command_handler()
      • ManagerPriorityBase.get_priority()
      • ManagerPriorityBase.run_resolver()
  • edri.abstract.manager.worker module
    • Worker
    • WorkerFactoryProtocol
    • WorkerNotFoundError
    • WorkerRuntimeProtocol
      • WorkerRuntimeProtocol.is_alive()
      • WorkerRuntimeProtocol.start()
  • edri.abstract.manager.worker_controller module
    • WorkerController
      • WorkerController.cancel()
      • WorkerController.cancel_all()
      • WorkerController.find_by_pipe()
      • WorkerController.finish_from_quit()
      • WorkerController.finish_lost()
      • WorkerController.pending
      • WorkerController.pipes()
      • WorkerController.running
      • WorkerController.start()
      • WorkerController.started()
      • WorkerController.stopping
    • WorkerView
  • Module contents
• edri.abstract.worker package
  • Submodules
  • edri.abstract.worker.worker module
    • Worker
      • Worker.cancel_requested
      • Worker.do()
      • Worker.event_receive()
      • Worker.event_send()
      • Worker.raise_if_cancelled()
      • Worker.run()
      • Worker.setup()
      • Worker.wait_cancelled()
    • WorkerCancelled
  • edri.abstract.worker.worker_process module
    • WorkerProcess
  • edri.abstract.worker.worker_thread module
    • WorkerThread
  • Module contents

Module contents

edri.abstract.request(func: _F, /, *, cache: str | None = None) → _F

edri.abstract.request(func: None = None, /, *, cache: str | None = None) → Callable[[_F], _F]

edri.abstract.response(func: _F) → _F