oc_orchestrator
Loading...
Searching...
No Matches
hub_manage.py File Reference

Go to the source code of this file.

Classes

class  oc_orchestrator.hub_manage._HubDispatchHooks

Namespaces

namespace  oc_orchestrator
namespace  oc_orchestrator.hub_manage

Functions

Any oc_orchestrator.hub_manage._build_log (argparse.Namespace args, "Callable[[argparse.Namespace], Any] | None" log_factory=None)
Path|None oc_orchestrator.hub_manage._comms_root (argparse.Namespace args)
Hub oc_orchestrator.hub_manage._build_hub (argparse.Namespace args, Any log)
Provenance oc_orchestrator.hub_manage._actor_provenance ()
str oc_orchestrator.hub_manage._process_user ()
str oc_orchestrator.hub_manage._describe (HubEntry entry)
str oc_orchestrator.hub_manage.format_entries (tuple[HubEntry,...] entries, *, str empty)
str oc_orchestrator.hub_manage._age (str at, *, datetime|None now=None)
list[str] oc_orchestrator.hub_manage._card_body (Any message, *, bool full)
str oc_orchestrator.hub_manage.format_cards (tuple[HubEntry,...] entries, *, str title, str empty, str source, bool full=False, datetime|None now=None)
str oc_orchestrator.hub_manage.entries_as_json (tuple[HubEntry,...] entries, *, str command, str source)
str oc_orchestrator.hub_manage._source_label (argparse.Namespace args)
None oc_orchestrator.hub_manage._emit (argparse.Namespace args, tuple[HubEntry,...] entries, *, str command, str title, str empty)
str oc_orchestrator.hub_manage.format_fleet_report (list[Any] instances, tuple[HubEntry,...] entries)
int oc_orchestrator.hub_manage._ingest (argparse.Namespace args, Any log)
int oc_orchestrator.hub_manage._cmd_send (argparse.Namespace args, Any log)
int oc_orchestrator.hub_manage._cmd_ask (argparse.Namespace args, Any log)
int oc_orchestrator.hub_manage._cmd_rule (argparse.Namespace args, Any log)
int oc_orchestrator.hub_manage._cmd_inbox (argparse.Namespace args, Any log)
int oc_orchestrator.hub_manage._cmd_asks (argparse.Namespace args, Any log)
int oc_orchestrator.hub_manage._cmd_fleet (argparse.Namespace args, Any log)
int oc_orchestrator.hub_manage._cmd_ingest (argparse.Namespace args, Any log)
int oc_orchestrator.hub_manage._cmd_history (argparse.Namespace args, Any log)
int oc_orchestrator.hub_manage._cmd_relay_check (argparse.Namespace args, Any log)
None oc_orchestrator.hub_manage._deliver (Hub hub, Any message)
tuple[HubEntry,...] oc_orchestrator.hub_manage._unread (Any log, str address)
None oc_orchestrator.hub_manage._advance (Any log, str address, int seq)
tuple[str, Provenance, str] oc_orchestrator.hub_manage._reply_from_inbox (argparse.Namespace args)
None oc_orchestrator.hub_manage._consume_inbound (argparse.Namespace args, str message_id, str decision)
Any oc_orchestrator.hub_manage.default_hooks (*, Any log, Any|None queue=None, Path|None comms_root=None)
Any oc_orchestrator.hub_manage.hooks_for_dispatch (*, Path queue_dir, Path|None comms_root=None)
None oc_orchestrator.hub_manage._listing_flags (argparse.ArgumentParser parser)
argparse.ArgumentParser oc_orchestrator.hub_manage.build_parser (str prog=DEFAULT_PROG)
int oc_orchestrator.hub_manage.main (list[str]|None argv=None, *, str prog=DEFAULT_PROG, "Callable[[argparse.Namespace], Any] | None" log_factory=None)

Variables

int oc_orchestrator.hub_manage.EXIT_OK = 0
int oc_orchestrator.hub_manage.EXIT_REFUSED = 1
int oc_orchestrator.hub_manage.EXIT_BACKEND = 2
str oc_orchestrator.hub_manage.RELAY_LINE = "python -m oc_connect relay hub"
str oc_orchestrator.hub_manage.DEQUEUE_REASON_DISPATCHED = "dispatched"
tuple oc_orchestrator.hub_manage.NO_LOG_FACTORY
tuple oc_orchestrator.hub_manage.NO_TELEGRAM_EXTRA
str oc_orchestrator.hub_manage.RULE_HINT = "To answer: hub_manage rule <id> --answer YES|NO|ACK|HOLD [--body \"...\"]"
dict oc_orchestrator.hub_manage._COMMANDS
str oc_orchestrator.hub_manage.DEFAULT_PROG = "python -m oc_orchestrator.hub_manage"