oc_connect
Loading...
Searching...
No Matches
oc_connect.outbox Namespace Reference

Classes

class  OutboxItem
class  OutboxFileError
class  Outbox

Functions

Path default_outbox_path (str|Path|None root=None)

Variables

 OutboxState = Literal["queued", "sent", "failed"]

Detailed Description

Durable at-most-once outbox with retry, backoff, and destination caps.

Dependencies
------------
- oc_connect.audit (AuditStore, content_hash, timestamp - audits every queue and delivery outcome)
- oc_connect.workspace (comms_root - locates the outbox in the comms bus outbound lane)
- oc_diagnostics (_dbg structured logger)
- option_c_connector_contracts (DeliveryReceipt, LaneId, MessageDirection, RiskClass - receipts and lane fields)
- pydantic (BaseModel, ConfigDict - the frozen strict OutboxItem model)

Function Documentation

◆ default_outbox_path()

Path oc_connect.outbox.default_outbox_path ( str | Path | None root = None)
Return the durable outbox inside the comms bus outbound lane (ยง3).

Definition at line 37 of file outbox.py.

Variable Documentation

◆ OutboxState

oc_connect.outbox.OutboxState = Literal["queued", "sent", "failed"]

Definition at line 34 of file outbox.py.