Enum ParsedPayload 

pub enum ParsedPayload {
    Json(Value),
    MsgPack(Value),
}

Available on crate feature transport only.

A parsed payload, retaining its native value representation.

JSON stays a sonic_rs::Value (so the SIMD parse is not thrown away) and MsgPack stays an rmpv::Value (native, no JSON bridge). A consumer that only needs a routing field should reach for ParsedPayload::field_str / ParsedPayload::field rather than matching the variant – that is the whole point of the unified accessor.

Variants

Json(Value)

JSON value parsed by sonic_rs (SIMD).

MsgPack(Value)

MsgPack value parsed natively by rmpv (no serde_json bridge).

Implementations

impl ParsedPayload

pub fn is_json(&self) -> bool

Whether the payload was decoded from JSON.

pub fn is_msgpack(&self) -> bool

Whether the payload was decoded from MsgPack.

pub fn field_str(&self, name: &str) -> Option<&str>

Read a top-level string field, format-agnostic.

The common routing case: a router keys off one string field and does not care about wire format. Returns None if the value is not a top-level object, the key is absent, or the field is not a string. Borrows from the parsed value (zero-copy).

Top-level lookup only – see the module docs.

pub fn field(&self, name: &str) -> Option<FieldRef<'_>>

Read a top-level field as a format-agnostic FieldRef.

Returns None only when the value is not a top-level object or the key is absent. A present-but-non-scalar field yields FieldRef::Other (routers never key off containers). Borrows from the parsed value.

Top-level lookup only – see the module docs.

pub fn to_bytes(&self) -> Result<Bytes, CodecError>

Serialise back to the payload’s OWN wire format (Task 0.3b).

Json -> JSON bytes (via to_json_bytes), MsgPack -> MsgPack bytes (via to_msgpack_bytes). Same format in, same format out – no cross-format conversion, no bridge.

Pass-through contract – DO NOT round-trip untouched records

This is the egress face of a parse-on-demand spine. The governing principle is “serde is the enemy / zero re-representation”: a record that a transform did NOT change must re-use its original Record.payload (the Bytes it arrived as) directly on egress. to_bytes is ONLY for a record a transform actually mutated.

Calling to_bytes on an unmodified record is a correctness and performance bug: it pays a full parse + re-serialise for nothing AND can alter the wire bytes (key order, number formatting, whitespace) even though the logical value is identical. Reuse the original Bytes; only reach for to_bytes once the value has been edited.

There is deliberately NO to_bytes_as cross-format egress. JSON and MsgPack have distinct value models (sonic_rs::Value vs rmpv::Value) with no native conversion between them; bridging would mean either a hand-rolled recursive value walker or a serde_json hop – the exact double-representation this spine exists to avoid. Cross-format egress, if a consumer ever needs it, is a separate, explicit concern (YAGNI).

Errors

Returns CodecError::Json (JSON serialise) or CodecError::Encode (MsgPack serialise) on encoder failure.

Trait Implementations

impl Clone for ParsedPayload

fn clone(&self) -> ParsedPayload

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ParsedPayload

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.