Enum EmbeddedDeploy 

pub enum EmbeddedDeploy {}

Available on crate feature build only.

Marker type for the embedded deployment backend.

All networking methods panic — this backend only supports pure local computation.

Trait Implementations

impl<S: Into<String>> ClusterSpec<'_, EmbeddedDeploy> for S

fn build(self, location_key: LocationKey, _name_hint: &str) -> EmbeddedNode

impl<'a> Deploy<'a> for EmbeddedDeploy

type Meta = ()

type InstantiateEnv = EmbeddedInstantiateEnv

type Process = EmbeddedNode

type Cluster = EmbeddedNode

type External = EmbeddedNode

fn o2o_sink_source( env: &mut Self::InstantiateEnv, p1: &Self::Process, _p1_port: &(), p2: &Self::Process, _p2_port: &(), name: Option<&str>, ) -> (Expr, Expr)

Generates the source and sink expressions when connecting a Self::Process to another Self::Process.

fn o2o_connect( _p1: &Self::Process, _p1_port: &(), _p2: &Self::Process, _p2_port: &(), ) -> Box<dyn FnOnce()>

Performs any runtime wiring needed after code generation for a Self::Process-to-Self::Process channel.

fn o2m_sink_source( env: &mut Self::InstantiateEnv, p1: &Self::Process, _p1_port: &(), c2: &Self::Cluster, _c2_port: &(), name: Option<&str>, ) -> (Expr, Expr)

Generates the source and sink expressions when connecting a Self::Process to a Self::Cluster (one-to-many).

fn o2m_connect( _p1: &Self::Process, _p1_port: &(), _c2: &Self::Cluster, _c2_port: &(), ) -> Box<dyn FnOnce()>

Performs any runtime wiring needed after code generation for a Self::Process-to-Self::Cluster channel.

fn m2o_sink_source( env: &mut Self::InstantiateEnv, c1: &Self::Cluster, _c1_port: &(), p2: &Self::Process, _p2_port: &(), name: Option<&str>, ) -> (Expr, Expr)

Generates the source and sink expressions when connecting a Self::Cluster to a Self::Process (many-to-one).

fn m2o_connect( _c1: &Self::Cluster, _c1_port: &(), _p2: &Self::Process, _p2_port: &(), ) -> Box<dyn FnOnce()>

Performs any runtime wiring needed after code generation for a Self::Cluster-to-Self::Process channel.

fn m2m_sink_source( env: &mut Self::InstantiateEnv, c1: &Self::Cluster, _c1_port: &(), c2: &Self::Cluster, _c2_port: &(), name: Option<&str>, ) -> (Expr, Expr)

Generates the source and sink expressions when connecting a Self::Cluster to another Self::Cluster (many-to-many).

fn m2m_connect( _c1: &Self::Cluster, _c1_port: &(), _c2: &Self::Cluster, _c2_port: &(), ) -> Box<dyn FnOnce()>

Performs any runtime wiring needed after code generation for a Self::Cluster-to-Self::Cluster channel.

fn e2o_many_source( _extra_stmts: &mut Vec<Stmt>, _p2: &Self::Process, _p2_port: &(), _codec_type: &Type, _shared_handle: String, ) -> Expr

fn e2o_many_sink(_shared_handle: String) -> Expr

fn e2o_source( _extra_stmts: &mut Vec<Stmt>, _p1: &Self::External, _p1_port: &(), _p2: &Self::Process, _p2_port: &(), _codec_type: &Type, _shared_handle: String, ) -> Expr

fn e2o_connect( _p1: &Self::External, _p1_port: &(), _p2: &Self::Process, _p2_port: &(), _many: bool, _server_hint: NetworkHint, ) -> Box<dyn FnOnce()>

fn o2e_sink( _p1: &Self::Process, _p1_port: &(), _p2: &Self::External, _p2_port: &(), _shared_handle: String, ) -> Expr

fn cluster_ids( _of_cluster: LocationKey, ) -> impl QuotedWithContext<'a, &'a [TaglessMemberId], ()> + Clone + 'a

fn cluster_self_id() -> impl QuotedWithContext<'a, TaglessMemberId, ()> + Clone + 'a

fn cluster_membership_stream( env: &mut Self::InstantiateEnv, at_location: &LocationId, location_id: &LocationId, ) -> impl QuotedWithContext<'a, Box<dyn Stream<Item = (TaglessMemberId, MembershipEvent)> + Unpin>, ()>

fn register_embedded_input( env: &mut Self::InstantiateEnv, location_key: LocationKey, ident: &Ident, element_type: &Type, )

Registers an embedded input for the given ident and element type.

fn register_embedded_output( env: &mut Self::InstantiateEnv, location_key: LocationKey, ident: &Ident, element_type: &Type, )

Registers an embedded output for the given ident and element type.

impl<S: Into<String>> ExternalSpec<'_, EmbeddedDeploy> for S

fn build(self, location_key: LocationKey, _name_hint: &str) -> EmbeddedNode

impl<S: Into<String>> ProcessSpec<'_, EmbeddedDeploy> for S

fn build(self, location_key: LocationKey, _name_hint: &str) -> EmbeddedNode

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,