hub_file.py File Reference

Go to the source code of this file.

Classes
class	oc_orchestrator.hub_file.CorruptHubLogError
class	oc_orchestrator.hub_file.HubPaths
class	oc_orchestrator.hub_file.FileHubLog
class	oc_orchestrator.hub_file.FileLaneCarrier

Namespaces
namespace	oc_orchestrator
namespace	oc_orchestrator.hub_file

Functions
tuple[HubEntry,...]	oc_orchestrator.hub_file.read_entries (Path ops_path)
HubEntry	oc_orchestrator.hub_file._decode_entry (str line, Path path, int number)
str	oc_orchestrator.hub_file._encode_entry (HubEntry entry)
None	oc_orchestrator.hub_file.append_entry (Path ops_path, HubEntry entry)
Path	oc_orchestrator.hub_file.find_comms_root (Path start)
str	oc_orchestrator.hub_file._utc_timestamp (datetime now)
str	oc_orchestrator.hub_file.utc_stamp (datetime now)
dict[str, object]	oc_orchestrator.hub_file.hub_lane_event (HubMessage message, *, datetime now)
Path	oc_orchestrator.hub_file.write_hub_lane_event (Path comms_root, dict[str, object] event, *, datetime now)
list[dict[str, Any]]	oc_orchestrator.hub_file._lane_events (Path lane_dir)
HubMessage|None	oc_orchestrator.hub_file._message_from_worker_report (dict[str, Any] event)
HubMessage	oc_orchestrator.hub_file._message_from_session_alert (dict[str, Any] event)
tuple[HubEntry,...]	oc_orchestrator.hub_file.ingest_lanes (Path comms_root, Any log)

Variables
str	oc_orchestrator.hub_file.HUB_OPS_FILENAME = "hub.ops.jsonl"
str	oc_orchestrator.hub_file.HUB_CURSORS_FILENAME = "hub.cursors.json"
str	oc_orchestrator.hub_file.HUB_LANE = "hub"
str	oc_orchestrator.hub_file.HUB_LANE_SOURCE = "hub"
str	oc_orchestrator.hub_file.HUB_LANE_SCHEMA_VERSION = "1.0"
str	oc_orchestrator.hub_file.HUB_LANE_DIRECTION = "outbound"
str	oc_orchestrator.hub_file.HUB_LANE_RISK_CLASS = "low"
str	oc_orchestrator.hub_file.WORKER_REPORT_LANE = "worker-reports"
str	oc_orchestrator.hub_file.SESSION_ALERT_LANE = "session-alerts"
str	oc_orchestrator.hub_file.WORKSPACE_MARKER = ".option_c_workspace.json"
str	oc_orchestrator.hub_file.PROJECT_MARKER = ".option_c"
str	oc_orchestrator.hub_file.COMMS_ANCHOR = "oc_chat"
tuple	oc_orchestrator.hub_file.COMMS_SUBPATH = (".option_c", "comms")