Struct hydro_lang::deploy::macro_runtime::DeployRuntime

pub struct DeployRuntime {}

Trait Implementations

impl ClusterSpec<'_, DeployRuntime> for ()

fn build(self, _id: usize, _name_hint: &str) -> DeployRuntimeCluster

impl<'a> Deploy<'a> for DeployRuntime

type InstantiateEnv = ()

type CompileEnv = RuntimeData<&'a DeployPorts<HydroflowPlusMeta>>

type Process = DeployRuntimeNode

type Cluster = DeployRuntimeCluster

type ExternalProcess = DeployRuntimeNode

type Port = String

type ExternalRawPort = ()

type Meta = ()

type GraphId = usize

Type of ID used to switch between different subgraphs at runtime.

fn has_trivial_node() -> bool

fn trivial_process(_id: usize) -> Self::Process

fn trivial_cluster(_id: usize) -> Self::Cluster

fn allocate_process_port(process: &Self::Process) -> Self::Port

fn allocate_cluster_port(cluster: &Self::Cluster) -> Self::Port

fn allocate_external_port(_external: &Self::ExternalProcess) -> Self::Port

fn o2o_sink_source( env: &Self::CompileEnv, _p1: &Self::Process, p1_port: &Self::Port, _p2: &Self::Process, p2_port: &Self::Port, ) -> (Expr, Expr)

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

fn o2m_sink_source( env: &Self::CompileEnv, _p1: &Self::Process, p1_port: &Self::Port, _c2: &Self::Cluster, c2_port: &Self::Port, ) -> (Expr, Expr)

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

fn m2o_sink_source( env: &Self::CompileEnv, _c1: &Self::Cluster, c1_port: &Self::Port, _p2: &Self::Process, p2_port: &Self::Port, ) -> (Expr, Expr)

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

fn m2m_sink_source( env: &Self::CompileEnv, _c1: &Self::Cluster, c1_port: &Self::Port, _c2: &Self::Cluster, c2_port: &Self::Port, ) -> (Expr, Expr)

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

fn e2o_source( _compile_env: &Self::CompileEnv, _p1: &Self::ExternalProcess, _p1_port: &Self::Port, _p2: &Self::Process, _p2_port: &Self::Port, ) -> Expr

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

fn o2e_sink( _compile_env: &Self::CompileEnv, _p1: &Self::Process, _p1_port: &Self::Port, _p2: &Self::ExternalProcess, _p2_port: &Self::Port, ) -> Expr

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

fn cluster_ids( env: &Self::CompileEnv, of_cluster: usize, ) -> impl QuotedWithContext<'a, &'a Vec<u32>, ()> + Copy + 'a

fn cluster_self_id( env: &Self::CompileEnv, ) -> impl QuotedWithContext<'a, u32, ()> + Copy + 'a

impl ExternalSpec<'_, DeployRuntime> for ()

fn build(self, _id: usize, _name_hint: &str) -> DeployRuntimeNode

impl ProcessSpec<'_, DeployRuntime> for ()

fn build(self, _id: usize, _name_hint: &str) -> DeployRuntimeNode

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