pub struct StreamFrame {
pub id: String,
pub fields: BTreeMap<String, String>,
}Expand description
A single frame read from an attempt-scoped stream.
Field set mirrors what ff_append_frame writes: frame_type, ts,
payload, encoding, source, and optionally correlation_id. Stored
as an ordered map so field order is deterministic across read calls.
Fields§
§id: StringValkey Stream entry ID, e.g. “1713100800150-0”.
fields: BTreeMap<String, String>Frame fields in sorted order.
Trait Implementations§
Source§impl Clone for StreamFrame
impl Clone for StreamFrame
Source§fn clone(&self) -> StreamFrame
fn clone(&self) -> StreamFrame
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for StreamFrame
impl Debug for StreamFrame
Source§impl<'de> Deserialize<'de> for StreamFrame
impl<'de> Deserialize<'de> for StreamFrame
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl PartialEq for StreamFrame
impl PartialEq for StreamFrame
Source§impl Serialize for StreamFrame
impl Serialize for StreamFrame
impl Eq for StreamFrame
impl StructuralPartialEq for StreamFrame
Auto Trait Implementations§
impl Freeze for StreamFrame
impl RefUnwindSafe for StreamFrame
impl Send for StreamFrame
impl Sync for StreamFrame
impl Unpin for StreamFrame
impl UnsafeUnpin for StreamFrame
impl UnwindSafe for StreamFrame
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more