Struct EmbeddedInstantiateEnv 

pub struct EmbeddedInstantiateEnv {
    pub inputs: SparseSecondaryMap<LocationKey, Vec<(Ident, Type)>>,
    pub singleton_inputs: SparseSecondaryMap<LocationKey, Vec<(Ident, Type)>>,
    pub outputs: SparseSecondaryMap<LocationKey, Vec<(Ident, Type)>>,
    pub network_outputs: SparseSecondaryMap<LocationKey, Vec<(String, bool, Option<Type>)>>,
    pub network_inputs: SparseSecondaryMap<LocationKey, Vec<(String, bool, Option<Type>)>>,
    pub membership_streams: SparseSecondaryMap<LocationKey, Vec<LocationKey>>,
}

Available on crate feature build only.

Collected embedded input/output registrations, keyed by location.

During compile_network, each HydroSource::Embedded and HydroRoot::EmbeddedOutput IR node registers its ident, element type, and location key here. generate_embedded then uses this to add the appropriate parameters to each generated function.

Fields

inputs: SparseSecondaryMap<LocationKey, Vec<(Ident, Type)>>

(ident name, element type) pairs per location key, for inputs.

singleton_inputs: SparseSecondaryMap<LocationKey, Vec<(Ident, Type)>>

(ident name, element type) pairs per location key, for singleton inputs.

outputs: SparseSecondaryMap<LocationKey, Vec<(Ident, Type)>>

(ident name, element type) pairs per location key, for outputs.

network_outputs: SparseSecondaryMap<LocationKey, Vec<(String, bool, Option<Type>)>>

Network output port names per location key (sender side of channels). Each entry is (port_name, is_tagged, external_type). is_tagged means the sink is keyed by a TaglessMemberId. external_type distinguishes the two serialization modes:

• None (bincode): the sink is FnMut(Bytes) (or FnMut((TaglessMemberId, Bytes)) when tagged) — Hydro serializes to Bytes before the sink.
• Some(payload) (embedded, see crate::networking::Embedded): the sink receives the raw payload — FnMut(payload) (or FnMut((TaglessMemberId, payload)) when tagged).

network_inputs: SparseSecondaryMap<LocationKey, Vec<(String, bool, Option<Type>)>>

Network input port names per location key (receiver side of channels). Each entry is (port_name, is_tagged, external_type). is_tagged means the source is keyed by a TaglessMemberId. external_type distinguishes the two serialization modes:

• None (bincode): the source is Stream<Item = Result<BytesMut, Error>> (or Result<(TaglessMemberId, BytesMut), Error> when tagged) — the transport Result is unwrapped and the BytesMut deserialized by Hydro.
• Some(payload) (embedded, see crate::networking::Embedded): the source delivers the raw payload with no transport Result — Stream<Item = payload> (or Stream<Item = (TaglessMemberId, payload)> when tagged); handling faults is left to the external code that produces the stream.

membership_streams: SparseSecondaryMap<LocationKey, Vec<LocationKey>>

Cluster membership streams needed per location key. Maps location_key -> vec of cluster LocationKeys whose membership is needed.

Trait Implementations

impl Default for EmbeddedInstantiateEnv

fn default() -> EmbeddedInstantiateEnv

Returns the “default value” for a type.