Bases: RuntimeError
Bases: RuntimeError
dataclass ¶
dataclass ¶
async ¶
authenticate_resume(
session_id: str,
*,
resume_token: str,
last_received_server_event_seq: int,
) -> None
Validate transport credentials before any engine resume control.
async ¶
create(
session_id: str,
*,
send: Callable[[dict[str, object]], Awaitable[None]],
close: Callable[[str], Awaitable[None]],
) -> DuplexSessionAttachmentCreated
async ¶
Drop the current transport; the engine lease owns the disconnect grace.
attachment_generation names the connection asking to detach, so a socket that already lost a takeover cannot detach the winner. None means "whichever connection is attached right now" and is for callers that only know the session (the outbound pump, whose send just failed).
Returns whether this call is the one that detached: an already-detached session answers False so a second disconnect signal for the same socket cannot restart the engine's disconnect grace window.
async ¶
Whether some connection is attached right now, whoever it is.
A resume that failed to activate has no generation of its own, so it cannot ask is_current_attachment. What it needs to know before rolling the engine lease back into its disconnect grace is only whether it would be rolling back somebody else's live attachment.
async ¶
async ¶
resume(
session_id: str,
*,
resume_token: str,
last_received_server_event_seq: int,
send: Callable[[dict[str, object]], Awaitable[None]],
close: Callable[[str], Awaitable[None]],
activation_payload_factory: Callable[
[ResumeToken, int], Mapping[str, object]
]
| None = None,
) -> DuplexSessionResumeResult
async ¶
send_event(
session_id: str,
payload: Mapping[str, object],
*,
journal: bool = True,
on_accepted: Callable[[], None] | None = None,
) -> JournalEntry | None
Sequence and dispatch one event to the current attachment.
The per-session lock keeps wire order equal to journal order without serializing unrelated sessions. A detached session still records replayable events, but has no transport side effect.
on_accepted runs synchronously once the event is journaled, or after a successful transport send when journaling is disabled. A later send failure cannot undo acceptance into the journal. Detached, non-journaled events do not invoke it. The callback must not raise.
dataclass ¶
class-attribute instance-attribute ¶
replaced_attachment: DuplexTransportAttachment | None = None
dataclass ¶
Bases: RuntimeError