Expand description
Transport-neutral runtime stream primitives.
This module defines the envelope, routing key, and stream type used by the runtime stream abstraction. The design is inspired by the Socket.IO Adapter rules (room-based fanout, per-room ordering, best-effort live delivery), but it is not a Socket.IO implementation and carries no transport coupling.
RuntimeStreamAdapterperforms best-effort live fanout only.RuntimeEventStoreis the authoritative replay source.- Delivery is at-least-once; consumers deduplicate via
RuntimeEventIdorRuntimeEventEnvelope::seq. - Authorization is not modeled here; rooms express fanout routing only and must be gated by the transport/service layer before subscription.
Structs§
- Runtime
Event Envelope - Envelope wrapping an
AgentEventwith cross-instance routing metadata. - Runtime
Event Id - Globally unique identifier for a single runtime event.
Enums§
- Runtime
Room - Fanout routing key, inspired by a Socket.IO room but transport-neutral.
- Runtime
Stream Error - Errors raised by a
RuntimeStreamAdapter.
Type Aliases§
- BoxRuntime
Event Stream - Owned, type-erased stream of runtime event envelopes.