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 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§fn o2o_sink_source(
_p1: &Self::Process,
p1_port: &<Self::Process as Node>::Port,
_p2: &Self::Process,
p2_port: &<Self::Process as Node>::Port,
) -> (Expr, Expr)
fn o2o_sink_source( _p1: &Self::Process, p1_port: &<Self::Process as Node>::Port, _p2: &Self::Process, p2_port: &<Self::Process as Node>::Port, ) -> (Expr, Expr)
Available on crate feature
build only.Source§fn o2o_connect(
p1: &Self::Process,
p1_port: &<Self::Process as Node>::Port,
p2: &Self::Process,
p2_port: &<Self::Process as Node>::Port,
) -> Box<dyn FnOnce()>
fn o2o_connect( p1: &Self::Process, p1_port: &<Self::Process as Node>::Port, p2: &Self::Process, p2_port: &<Self::Process as Node>::Port, ) -> Box<dyn FnOnce()>
Available on crate feature
build only.Source§fn o2m_sink_source(
_p1: &Self::Process,
p1_port: &<Self::Process as Node>::Port,
_c2: &Self::Cluster,
c2_port: &<Self::Cluster as Node>::Port,
) -> (Expr, Expr)
fn o2m_sink_source( _p1: &Self::Process, p1_port: &<Self::Process as Node>::Port, _c2: &Self::Cluster, c2_port: &<Self::Cluster as Node>::Port, ) -> (Expr, Expr)
Available on crate feature
build only.Source§fn o2m_connect(
p1: &Self::Process,
p1_port: &<Self::Process as Node>::Port,
c2: &Self::Cluster,
c2_port: &<Self::Cluster as Node>::Port,
) -> Box<dyn FnOnce()>
fn o2m_connect( p1: &Self::Process, p1_port: &<Self::Process as Node>::Port, c2: &Self::Cluster, c2_port: &<Self::Cluster as Node>::Port, ) -> Box<dyn FnOnce()>
Available on crate feature
build only.Source§fn m2o_sink_source(
_c1: &Self::Cluster,
c1_port: &<Self::Cluster as Node>::Port,
_p2: &Self::Process,
p2_port: &<Self::Process as Node>::Port,
) -> (Expr, Expr)
fn m2o_sink_source( _c1: &Self::Cluster, c1_port: &<Self::Cluster as Node>::Port, _p2: &Self::Process, p2_port: &<Self::Process as Node>::Port, ) -> (Expr, Expr)
Available on crate feature
build only.Source§fn m2o_connect(
c1: &Self::Cluster,
c1_port: &<Self::Cluster as Node>::Port,
p2: &Self::Process,
p2_port: &<Self::Process as Node>::Port,
) -> Box<dyn FnOnce()>
fn m2o_connect( c1: &Self::Cluster, c1_port: &<Self::Cluster as Node>::Port, p2: &Self::Process, p2_port: &<Self::Process as Node>::Port, ) -> Box<dyn FnOnce()>
Available on crate feature
build only.Source§fn m2m_sink_source(
_c1: &Self::Cluster,
c1_port: &<Self::Cluster as Node>::Port,
_c2: &Self::Cluster,
c2_port: &<Self::Cluster as Node>::Port,
) -> (Expr, Expr)
fn m2m_sink_source( _c1: &Self::Cluster, c1_port: &<Self::Cluster as Node>::Port, _c2: &Self::Cluster, c2_port: &<Self::Cluster as Node>::Port, ) -> (Expr, Expr)
Available on crate feature
build only.Source§fn m2m_connect(
c1: &Self::Cluster,
c1_port: &<Self::Cluster as Node>::Port,
c2: &Self::Cluster,
c2_port: &<Self::Cluster as Node>::Port,
) -> Box<dyn FnOnce()>
fn m2m_connect( c1: &Self::Cluster, c1_port: &<Self::Cluster as Node>::Port, c2: &Self::Cluster, c2_port: &<Self::Cluster as Node>::Port, ) -> Box<dyn FnOnce()>
Available on crate feature
build only.Source§fn e2o_many_source(
extra_stmts: &mut Vec<Stmt>,
_p2: &Self::Process,
p2_port: &<Self::Process as Node>::Port,
codec_type: &Type,
shared_handle: String,
) -> Expr
fn e2o_many_source( extra_stmts: &mut Vec<Stmt>, _p2: &Self::Process, p2_port: &<Self::Process as Node>::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(
extra_stmts: &mut Vec<Stmt>,
_p1: &Self::External,
_p1_port: &<Self::External as Node>::Port,
_p2: &Self::Process,
p2_port: &<Self::Process as Node>::Port,
codec_type: &Type,
shared_handle: String,
) -> Expr
fn e2o_source( extra_stmts: &mut Vec<Stmt>, _p1: &Self::External, _p1_port: &<Self::External as Node>::Port, _p2: &Self::Process, p2_port: &<Self::Process as Node>::Port, codec_type: &Type, shared_handle: String, ) -> Expr
Available on crate feature
build only.Source§fn e2o_connect(
p1: &Self::External,
p1_port: &<Self::External as Node>::Port,
p2: &Self::Process,
p2_port: &<Self::Process as Node>::Port,
_many: bool,
server_hint: NetworkHint,
) -> Box<dyn FnOnce()>
fn e2o_connect( p1: &Self::External, p1_port: &<Self::External as Node>::Port, p2: &Self::Process, p2_port: &<Self::Process as Node>::Port, _many: bool, server_hint: NetworkHint, ) -> Box<dyn FnOnce()>
Available on crate feature
build only.Source§fn o2e_sink(
_p1: &Self::Process,
_p1_port: &<Self::Process as Node>::Port,
_p2: &Self::External,
_p2_port: &<Self::External as Node>::Port,
shared_handle: String,
) -> Expr
fn o2e_sink( _p1: &Self::Process, _p1_port: &<Self::Process as Node>::Port, _p2: &Self::External, _p2_port: &<Self::External as Node>::Port, shared_handle: String, ) -> Expr
Available on crate feature
build only.Source§fn cluster_ids(
of_cluster: usize,
) -> impl QuotedWithContext<'a, &'a [TaglessMemberId], ()> + Clone + 'a
fn cluster_ids( of_cluster: usize, ) -> impl QuotedWithContext<'a, &'a [TaglessMemberId], ()> + Clone + 'a
Available on crate feature
build only.Source§fn cluster_self_id() -> impl QuotedWithContext<'a, TaglessMemberId, ()> + Clone + 'a
fn cluster_self_id() -> impl QuotedWithContext<'a, TaglessMemberId, ()> + Clone + 'a
Available on crate feature
build only.Source§fn cluster_membership_stream(
location_id: &LocationId,
) -> impl QuotedWithContext<'a, Box<dyn Stream<Item = (TaglessMemberId, MembershipEvent)> + Unpin>, ()>
fn cluster_membership_stream( location_id: &LocationId, ) -> impl QuotedWithContext<'a, Box<dyn Stream<Item = (TaglessMemberId, MembershipEvent)> + Unpin>, ()>
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, external_port_id: ExternalPortId, port: Self::Port)
fn register(&self, external_port_id: ExternalPortId, port: Self::Port)
Available on crate feature
build only.Source§fn as_bytes_bidi(
&self,
external_port_id: ExternalPortId,
) -> impl Future<Output = (Pin<Box<dyn Stream<Item = Result<BytesMut, Error>>>>, Pin<Box<dyn Sink<Bytes, Error = Error>>>)> + 'a
fn as_bytes_bidi( &self, external_port_id: ExternalPortId, ) -> 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,
external_port_id: ExternalPortId,
) -> 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,
external_port_id: ExternalPortId,
) -> 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,
external_port_id: ExternalPortId,
) -> impl Future<Output = Pin<Box<dyn Sink<T, Error = Error>>>> + 'a
fn as_bincode_sink<T: Serialize + 'static>( &self, external_port_id: ExternalPortId, ) -> 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,
external_port_id: ExternalPortId,
) -> impl Future<Output = Pin<Box<dyn Stream<Item = T>>>> + 'a
fn as_bincode_source<T: DeserializeOwned + 'static>( &self, external_port_id: ExternalPortId, ) -> 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 moreCreates a shared type from an unshared type.