Enum HydroDeploy 

pub enum HydroDeploy {}

Available on crate feature deploy only.

Deployment backend that uses hydro_deploy for provisioning and launching.

Automatically used when you call crate::compile::builder::FlowBuilder::deploy and pass in an &mut reference to hydro_deploy::Deployment as the deployment context.

Trait Implementations

impl ClusterSpec<'_, HydroDeploy> for DeployClusterSpec

fn build(self, id: usize, _name_hint: &str) -> DeployCluster

Available on crate feature build only.

impl<T: Into<TrybuildHost>, I: IntoIterator<Item = T>> ClusterSpec<'_, HydroDeploy> for I

fn build(self, id: usize, name_hint: &str) -> DeployCluster

Available on crate feature build only.

impl<'a> Deploy<'a> for HydroDeploy

type InstantiateEnv = Deployment

Available on crate feature build only.

type CompileEnv = ()

Available on crate feature build only.

type Process = DeployNode

Available on crate feature build only.

type Cluster = DeployCluster

Available on crate feature build only.

type External = DeployExternal

Available on crate feature build only.

type Meta = HashMap<usize, Vec<u32>>

Available on crate feature build only.

type GraphId = ()

Available on crate feature build only.

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

type Port = String

Available on crate feature build only.

type ExternalRawPort = CustomClientPort

Available on crate feature build only.

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

Available on crate feature build only.

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

Available on crate feature build only.

fn allocate_external_port(external: &Self::External) -> Self::Port

Available on crate feature build only.

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

Available on crate feature build only.

fn o2o_connect( p1: &Self::Process, p1_port: &Self::Port, p2: &Self::Process, p2_port: &Self::Port, ) -> Box<dyn FnOnce()>

Available on crate feature build only.

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

Available on crate feature build only.

fn o2m_connect( p1: &Self::Process, p1_port: &Self::Port, c2: &Self::Cluster, c2_port: &Self::Port, ) -> Box<dyn FnOnce()>

Available on crate feature build only.

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

Available on crate feature build only.

fn m2o_connect( c1: &Self::Cluster, c1_port: &Self::Port, p2: &Self::Process, p2_port: &Self::Port, ) -> Box<dyn FnOnce()>

Available on crate feature build only.

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

Available on crate feature build only.

fn m2m_connect( c1: &Self::Cluster, c1_port: &Self::Port, c2: &Self::Cluster, c2_port: &Self::Port, ) -> Box<dyn FnOnce()>

Available on crate feature build only.

fn e2o_many_source( _compile_env: &Self::CompileEnv, extra_stmts: &mut Vec<Stmt>, _p2: &Self::Process, p2_port: &Self::Port, codec_type: &Type, shared_handle: String, ) -> Expr

Available on crate feature build only.

fn e2o_many_sink(shared_handle: String) -> Expr

Available on crate feature build only.

fn e2o_source( _compile_env: &Self::CompileEnv, _p1: &Self::External, p1_port: &Self::Port, _p2: &Self::Process, p2_port: &Self::Port, ) -> Expr

Available on crate feature build only.

fn e2o_connect( p1: &Self::External, p1_port: &Self::Port, p2: &Self::Process, p2_port: &Self::Port, many: bool, server_hint: NetworkHint, ) -> Box<dyn FnOnce()>

Available on crate feature build only.

fn o2e_sink( _compile_env: &Self::CompileEnv, _p1: &Self::Process, p1_port: &Self::Port, _p2: &Self::External, p2_port: &Self::Port, ) -> Expr

Available on crate feature build only.

fn o2e_connect( p1: &Self::Process, p1_port: &Self::Port, p2: &Self::External, p2_port: &Self::Port, ) -> Box<dyn FnOnce()>

Available on crate feature build only.

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

Available on crate feature build only.

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

Available on crate feature build only.

fn has_trivial_node() -> bool

Available on crate feature build only.

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

Available on crate feature build only.

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

Available on crate feature build only.

fn trivial_external(_id: usize) -> Self::External

Available on crate feature build only.

impl<H: Host + 'static> ExternalSpec<'_, HydroDeploy> for Arc<H>

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

Available on crate feature build only.

impl ExternalSpec<'_, HydroDeploy> for Arc<dyn Host>

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

Available on crate feature build only.

impl<H: Host + 'static> IntoProcessSpec<'_, HydroDeploy> for Arc<H>

type ProcessSpec = TrybuildHost

Available on crate feature build only.

fn into_process_spec(self) -> TrybuildHost

Available on crate feature build only.

impl IntoProcessSpec<'_, HydroDeploy> for Arc<dyn Host>

type ProcessSpec = TrybuildHost

Available on crate feature build only.

fn into_process_spec(self) -> TrybuildHost

Available on crate feature build only.

impl ProcessSpec<'_, HydroDeploy> for DeployProcessSpec

fn build(self, id: usize, _name_hint: &str) -> DeployNode

Available on crate feature build only.

impl ProcessSpec<'_, HydroDeploy> for TrybuildHost

fn build(self, id: usize, name_hint: &str) -> DeployNode

Available on crate feature build only.

impl<'a> RegisterPort<'a, HydroDeploy> for DeployExternal

fn register(&self, key: usize, port: <HydroDeploy as Deploy<'_>>::Port)

Available on crate feature build only.

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

Available on crate feature build only.

fn as_bytes_bidi( &self, key: usize, ) -> impl Future<Output = (Pin<Box<dyn Stream<Item = Result<BytesMut, Error>>>>, Pin<Box<dyn Sink<Bytes, Error = Error>>>)> + 'a

Available on crate feature build only.

fn as_bincode_bidi<InT, OutT>( &self, key: usize, ) -> impl Future<Output = (Pin<Box<dyn Stream<Item = OutT>>>, Pin<Box<dyn Sink<InT, Error = Error>>>)> + 'a

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

Available on crate feature build only.

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

Available on crate feature build only.

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

Available on crate feature build only.