Struct EmbeddedNode 

pub struct EmbeddedNode {
    pub fn_name: String,
    pub location_key: LocationKey,
}

Available on crate feature build only.

A trivial node type for embedded deployment. Stores a user-provided function name.

Fields

fn_name: String

The function name to use in the generated code for this location.

location_key: LocationKey

The location key for this node, used to register network ports.

Trait Implementations

impl Clone for EmbeddedNode

fn clone(&self) -> EmbeddedNode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Node for EmbeddedNode

type Port = ()

A logical communication endpoint for this node.

type Meta = ()

type InstantiateEnv = EmbeddedInstantiateEnv

fn next_port(&self) -> Self::Port

Allocates and returns a new port.

fn update_meta(&self, _meta: &Self::Meta)

fn instantiate( &self, _env: &mut Self::InstantiateEnv, _meta: &mut Self::Meta, _graph: DfirGraph, _extra_stmts: &[Stmt], _sidecars: &[Expr], )

impl<'a> RegisterPort<'a, EmbeddedDeploy> for EmbeddedNode

fn register(&self, _external_port_id: ExternalPortId, _port: Self::Port)

fn as_bytes_bidi( &self, _external_port_id: ExternalPortId, ) -> impl Future<Output = DynSourceSink<Result<BytesMut, Error>, Bytes, Error>> + 'a

fn as_bincode_bidi<InT, OutT>( &self, _external_port_id: ExternalPortId, ) -> impl Future<Output = DynSourceSink<OutT, InT, Error>> + 'a

where InT: Serialize + 'static, OutT: DeserializeOwned + 'static,

fn as_bincode_sink<T>( &self, _external_port_id: ExternalPortId, ) -> impl Future<Output = Pin<Box<dyn Sink<T, Error = Error>>>> + 'a

where T: Serialize + 'static,

fn as_bincode_source<T>( &self, _external_port_id: ExternalPortId, ) -> impl Future<Output = Pin<Box<dyn Stream<Item = T>>>> + 'a

where T: DeserializeOwned + 'static,