Module session
Expand description
Session state storage.
The SessionState trait abstracts the state that must survive across
connections (§4.1). With alloc, InMemorySession provides a
heap-backed implementation; journal::JournaledSession wraps it with
an append-only operation log for durable persistence.
Modules§
- in_
memory 🔒alloc - journal
alloc - Append-only session operation log and its CRC-framed encoding.
- ops
- Serializable operations for mutating session state.
Structs§
- Filter
Entry - A single filter entry: its topic filter and lifecycle state.
- InMemory
Session alloc - In-memory implementation of
SessionState. - Outbox
Entry - A stored outgoing publish awaiting acknowledgement.
- Pending
Meta - The next pending SUBSCRIBE/UNSUBSCRIBE group to send, returned by
first_pending_group. - Restored
Subscription - The subscription a rejected UNSUBACK reverts to.
- Subscription
- A stored subscription, passed to the iteration callback.
Enums§
- Applied
- Outcome of
SessionState::apply: whether the mutation took effect. - Drain
Action - What a
drain_outbox/drain_pubrelvisitor decides for the entry it was handed. - Filter
State - Lifecycle state of a single topic filter.
- Pending
Kind - Whether a pending group is a SUBSCRIBE or an UNSUBSCRIBE, returned as part
of
PendingMeta. - Resolution
- What a
resolve_pendingclosure decides for one pending filter entry.
Traits§
- Session
State - Persistent session state that must survive across network connections.