pub enum HydroDeploy {}Available on crate feature
deploy only.Expand description
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§
Source§impl ClusterSpec<'_, HydroDeploy> for DeployClusterSpec
impl ClusterSpec<'_, HydroDeploy> for DeployClusterSpec
Source§impl<T: Into<TrybuildHost>, I: IntoIterator<Item = T>> ClusterSpec<'_, HydroDeploy> for I
impl<T: Into<TrybuildHost>, I: IntoIterator<Item = T>> ClusterSpec<'_, HydroDeploy> for I
Source§impl<'a> Deploy<'a> for HydroDeploy
impl<'a> Deploy<'a> for HydroDeploy
Source§type InstantiateEnv = Deployment
type InstantiateEnv = Deployment
Available on crate feature
build only.Source§type CompileEnv = ()
type CompileEnv = ()
Available on crate feature
build only.Source§type Process = DeployNode
type Process = DeployNode
Available on crate feature
build only.Source§type Cluster = DeployCluster
type Cluster = DeployCluster
Available on crate feature
build only.Source§type External = DeployExternal
type External = DeployExternal
Available on crate feature
build only.Source§type GraphId = ()
type GraphId = ()
Available on crate feature
build only.Type of ID used to switch between different subgraphs at runtime.
Source§type ExternalRawPort = CustomClientPort
type ExternalRawPort = CustomClientPort
Available on crate feature
build only.Source§fn allocate_process_port(process: &Self::Process) -> Self::Port
fn allocate_process_port(process: &Self::Process) -> Self::Port
Available on crate feature
build only.Source§fn allocate_cluster_port(cluster: &Self::Cluster) -> Self::Port
fn allocate_cluster_port(cluster: &Self::Cluster) -> Self::Port
Available on crate feature
build only.Source§fn allocate_external_port(external: &Self::External) -> Self::Port
fn allocate_external_port(external: &Self::External) -> Self::Port
Available on crate feature
build only.Source§fn o2o_sink_source(
_env: &(),
_p1: &Self::Process,
p1_port: &Self::Port,
_p2: &Self::Process,
p2_port: &Self::Port,
) -> (Expr, Expr)
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.Source§fn o2o_connect(
p1: &Self::Process,
p1_port: &Self::Port,
p2: &Self::Process,
p2_port: &Self::Port,
) -> Box<dyn FnOnce()>
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.Source§fn o2m_sink_source(
_env: &(),
_p1: &Self::Process,
p1_port: &Self::Port,
_c2: &Self::Cluster,
c2_port: &Self::Port,
) -> (Expr, Expr)
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.Source§fn o2m_connect(
p1: &Self::Process,
p1_port: &Self::Port,
c2: &Self::Cluster,
c2_port: &Self::Port,
) -> Box<dyn FnOnce()>
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.Source§fn m2o_sink_source(
_env: &(),
_c1: &Self::Cluster,
c1_port: &Self::Port,
_p2: &Self::Process,
p2_port: &Self::Port,
) -> (Expr, Expr)
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.Source§fn m2o_connect(
c1: &Self::Cluster,
c1_port: &Self::Port,
p2: &Self::Process,
p2_port: &Self::Port,
) -> Box<dyn FnOnce()>
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.Source§fn m2m_sink_source(
_env: &(),
_c1: &Self::Cluster,
c1_port: &Self::Port,
_c2: &Self::Cluster,
c2_port: &Self::Port,
) -> (Expr, Expr)
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.Source§fn m2m_connect(
c1: &Self::Cluster,
c1_port: &Self::Port,
c2: &Self::Cluster,
c2_port: &Self::Port,
) -> Box<dyn FnOnce()>
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.Source§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
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.Source§fn e2o_many_sink(shared_handle: String) -> Expr
fn e2o_many_sink(shared_handle: String) -> Expr
Available on crate feature
build only.Source§fn e2o_source(
_compile_env: &Self::CompileEnv,
extra_stmts: &mut Vec<Stmt>,
_p1: &Self::External,
_p1_port: &Self::Port,
_p2: &Self::Process,
p2_port: &Self::Port,
codec_type: &Type,
shared_handle: String,
) -> Expr
fn e2o_source( _compile_env: &Self::CompileEnv, extra_stmts: &mut Vec<Stmt>, _p1: &Self::External, _p1_port: &Self::Port, _p2: &Self::Process, p2_port: &Self::Port, codec_type: &Type, shared_handle: String, ) -> Expr
Available on crate feature
build only.Source§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()>
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.Source§fn o2e_sink(
_compile_env: &Self::CompileEnv,
_p1: &Self::Process,
_p1_port: &Self::Port,
_p2: &Self::External,
_p2_port: &Self::Port,
shared_handle: String,
) -> Expr
fn o2e_sink( _compile_env: &Self::CompileEnv, _p1: &Self::Process, _p1_port: &Self::Port, _p2: &Self::External, _p2_port: &Self::Port, shared_handle: String, ) -> Expr
Available on crate feature
build only.Source§fn cluster_ids(
_env: &Self::CompileEnv,
of_cluster: usize,
) -> impl QuotedWithContext<'a, &'a [u32], ()> + Copy + 'a
fn cluster_ids( _env: &Self::CompileEnv, of_cluster: usize, ) -> impl QuotedWithContext<'a, &'a [u32], ()> + Copy + 'a
Available on crate feature
build only.Source§fn cluster_self_id(
_env: &Self::CompileEnv,
) -> impl QuotedWithContext<'a, u32, ()> + Copy + 'a
fn cluster_self_id( _env: &Self::CompileEnv, ) -> impl QuotedWithContext<'a, u32, ()> + Copy + 'a
Available on crate feature
build only.Source§fn has_trivial_node() -> bool
fn has_trivial_node() -> bool
Available on crate feature
build only.Source§fn trivial_process(_id: usize) -> Self::Process
fn trivial_process(_id: usize) -> Self::Process
Available on crate feature
build only.Source§fn trivial_cluster(_id: usize) -> Self::Cluster
fn trivial_cluster(_id: usize) -> Self::Cluster
Available on crate feature
build only.Source§fn trivial_external(_id: usize) -> Self::External
fn trivial_external(_id: usize) -> Self::External
Available on crate feature
build only.Source§impl<H: Host + 'static> ExternalSpec<'_, HydroDeploy> for Arc<H>
impl<H: Host + 'static> ExternalSpec<'_, HydroDeploy> for Arc<H>
Source§impl ExternalSpec<'_, HydroDeploy> for Arc<dyn Host>
impl ExternalSpec<'_, HydroDeploy> for Arc<dyn Host>
Source§impl<H: Host + 'static> IntoProcessSpec<'_, HydroDeploy> for Arc<H>
impl<H: Host + 'static> IntoProcessSpec<'_, HydroDeploy> for Arc<H>
Source§type ProcessSpec = TrybuildHost
type ProcessSpec = TrybuildHost
Available on crate feature
build only.Source§fn into_process_spec(self) -> TrybuildHost
fn into_process_spec(self) -> TrybuildHost
Available on crate feature
build only.Source§impl IntoProcessSpec<'_, HydroDeploy> for Arc<dyn Host>
impl IntoProcessSpec<'_, HydroDeploy> for Arc<dyn Host>
Source§type ProcessSpec = TrybuildHost
type ProcessSpec = TrybuildHost
Available on crate feature
build only.Source§fn into_process_spec(self) -> TrybuildHost
fn into_process_spec(self) -> TrybuildHost
Available on crate feature
build only.Source§impl ProcessSpec<'_, HydroDeploy> for DeployProcessSpec
impl ProcessSpec<'_, HydroDeploy> for DeployProcessSpec
Source§impl ProcessSpec<'_, HydroDeploy> for TrybuildHost
impl ProcessSpec<'_, HydroDeploy> for TrybuildHost
Source§impl<'a> RegisterPort<'a, HydroDeploy> for DeployExternal
impl<'a> RegisterPort<'a, HydroDeploy> for DeployExternal
Source§fn register(&self, key: usize, port: <HydroDeploy as Deploy<'_>>::Port)
fn register(&self, key: usize, port: <HydroDeploy as Deploy<'_>>::Port)
Available on crate feature
build only.Source§fn raw_port(&self, key: usize) -> <HydroDeploy as Deploy<'_>>::ExternalRawPort
fn raw_port(&self, key: usize) -> <HydroDeploy as Deploy<'_>>::ExternalRawPort
Available on crate feature
build only.Source§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
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.Source§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>>>)> + 'awhere
InT: Serialize + 'static,
OutT: DeserializeOwned + 'static,
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>>>)> + 'awhere
InT: Serialize + 'static,
OutT: DeserializeOwned + 'static,
Available on crate feature
build only.Source§fn as_bincode_sink<T: Serialize + 'static>(
&self,
key: usize,
) -> impl Future<Output = Pin<Box<dyn Sink<T, Error = Error>>>> + 'a
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.Source§fn as_bincode_source<T: DeserializeOwned + 'static>(
&self,
key: usize,
) -> impl Future<Output = Pin<Box<dyn Stream<Item = T>>>> + 'a
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.Auto Trait Implementations§
impl Freeze for HydroDeploy
impl RefUnwindSafe for HydroDeploy
impl Send for HydroDeploy
impl Sync for HydroDeploy
impl Unpin for HydroDeploy
impl UnwindSafe for HydroDeploy
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> ToSinkBuild for T
impl<T> ToSinkBuild for T
§fn iter_to_sink_build(self) -> SendIterBuild<Self>
fn iter_to_sink_build(self) -> SendIterBuild<Self>
§fn stream_to_sink_build(self) -> SendStreamBuild<Self>where
Self: Sized + Stream,
fn stream_to_sink_build(self) -> SendStreamBuild<Self>where
Self: Sized + Stream,
Starts a [
SinkBuild] adaptor chain to send all items from self as a [Stream].