Enum NetworkSend 

pub enum NetworkSend {
    Custom {
        serialize_fn: Option<DebugExpr>,
    },
    Embedded {
        tag: Option<DebugType>,
        element_type: DebugType,
    },
}

How a network channel’s sender prepares each message before it is handed to the transport.

A channel’s serialization is split into a send half (NetworkSend) and a receive half (NetworkRecv) so that the multi-version simulation merge can reason about each side independently (the sender fork and the receiver are separate IR nodes).

Variants

Custom

Serialization is performed within the Hydro dataflow using the provided serialize expression. This is how channels using crate::networking::Bincode are lowered.

Fields

serialize_fn: Option<DebugExpr>

Embedded

Serialization is left to code outside of Hydro (see crate::networking::Embedded). The raw element_type is passed through unserialized; the only transformation is converting a routing crate::location::MemberId (the destination cluster tag, when demuxing) into the raw TaglessMemberId used by the transport. Only supported by the embedded backend.

Stored as structured info (rather than a pre-baked expression) so that the code can be synthesized in a post-IR codegen pass.

Fields

tag: Option<DebugType>

element_type: DebugType

Trait Implementations

impl Clone for NetworkSend

fn clone(&self) -> NetworkSend

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NetworkSend

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

Formats the value using the given formatter.

impl Hash for NetworkSend

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl Serialize for NetworkSend

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.