pub enum Decoded<E: AppEvent> {
Filter,
Permitted {
request_seq: u64,
event: E,
},
PermissionDenied(&'static str),
DecodeError(&'static str),
}Expand description
Outcome of a single RequestDecoder::decode call. The runtime
branches on this and never needs to know the underlying wire enum.
Variants§
Filter
Drop the frame silently. Used for transport-level messages (heartbeats, post-auth handshakes, subscription control) that the runtime never publishes to the pipeline.
Permitted
Frame OK and authorized. Caller publishes event with the
per-key sequence request_seq. Whether the event needs a
timestamp is derived by the runtime from AppEvent::is_query
— query events bypass the journal and skip the wall-clock
stamp.
Fields
event: EDecoded application event.
PermissionDenied(&'static str)
Authenticated connection lacks the permission level for this operation. The static string is logged at debug level on the reader thread; the runtime drops the frame.
DecodeError(&'static str)
Wire-level decode failure (malformed length, unknown variant tag, invalid field). The runtime logs at debug level and drops the frame; the connection is not closed (a misbehaving client drops itself on the next read timeout).