Struct DeployRuntimeNode 

pub struct DeployRuntimeNode { /* private fields */ }

Trait Implementations

impl Clone for DeployRuntimeNode

fn clone(&self) -> DeployRuntimeNode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Node for DeployRuntimeNode

type Port = String

type Meta = ()

type InstantiateEnv = ()

fn next_port(&self) -> String

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

fn instantiate( &self, _env: &mut Self::InstantiateEnv, _meta: &mut Self::Meta, _graph: HydroflowGraph, _extra_stmts: Vec<Stmt>, )

impl<'a> RegisterPort<'a, DeployRuntime> for DeployRuntimeNode

fn register(&self, _key: usize, _port: <DeployRuntime as Deploy<'_>>::Port)

fn raw_port( &self, _key: usize, ) -> <DeployRuntime as Deploy<'_>>::ExternalRawPort

fn as_bytes_sink( &self, _key: usize, ) -> impl Future<Output = Pin<Box<dyn Sink<Bytes, Error = Error>>>> + 'a

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

fn as_bytes_source( &self, _key: usize, ) -> impl Future<Output = Pin<Box<dyn Stream<Item = Bytes>>>> + 'a

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