pub struct LocalProcessReconciler { /* private fields */ }Expand description
Reconciler for components bound to a local-process compute slot.
Implementations§
Source§impl LocalProcessReconciler
impl LocalProcessReconciler
pub fn new() -> Self
Sourcepub fn with_log_buf(self, log_buf: LogBuffer) -> Self
pub fn with_log_buf(self, log_buf: LogBuffer) -> Self
Stream into a caller-owned LogBuffer instead of a private one.
Sourcepub fn with_build_log_end_sink(self, sink: PhaseCursor) -> Self
pub fn with_build_log_end_sink(self, sink: PhaseCursor) -> Self
Publish the build→run boundary into a caller-owned PhaseCursor as
soon as it’s known, rather than only once up() returns it.
Trait Implementations§
Source§impl Debug for LocalProcessReconciler
impl Debug for LocalProcessReconciler
Source§impl Default for LocalProcessReconciler
impl Default for LocalProcessReconciler
Source§fn default() -> LocalProcessReconciler
fn default() -> LocalProcessReconciler
Returns the “default value” for a type. Read more
Source§impl Reconciler for LocalProcessReconciler
impl Reconciler for LocalProcessReconciler
Source§fn kind(&self) -> &'static str
fn kind(&self) -> &'static str
Workload kind this reconciler handles (matches
ServiceComponent.kind).Source§fn up<'life0, 'life1, 'async_trait>(
&'life0 self,
ctx: ReconcileCtx<'life1>,
) -> Pin<Box<dyn Future<Output = Result<RunningWorkload>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn up<'life0, 'life1, 'async_trait>(
&'life0 self,
ctx: ReconcileCtx<'life1>,
) -> Pin<Box<dyn Future<Output = Result<RunningWorkload>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Bring the workload up. Returns a handle whose lifecycle is tied to
the mirror being up.
Auto Trait Implementations§
impl !RefUnwindSafe for LocalProcessReconciler
impl !UnwindSafe for LocalProcessReconciler
impl Freeze for LocalProcessReconciler
impl Send for LocalProcessReconciler
impl Sync for LocalProcessReconciler
impl Unpin for LocalProcessReconciler
impl UnsafeUnpin for LocalProcessReconciler
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<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere
T: Any,
Source§fn into_any(self: Box<T>) -> Box<dyn Any>
fn into_any(self: Box<T>) -> Box<dyn Any>
Convert
Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>. Box<dyn Any> can
then be further downcast into Box<ConcreteType> where ConcreteType implements Trait.Source§fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
Convert
Rc<Trait> (where Trait: Downcast) to Rc<Any>. Rc<Any> can then be
further downcast into Rc<ConcreteType> where ConcreteType implements Trait.Source§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
Convert
&Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &Any’s vtable from &Trait’s.Source§fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
Convert
&mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &mut Any’s vtable from &mut Trait’s.Source§impl<T> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere
T: Any,
Source§fn into_any(self: Box<T>) -> Box<dyn Any>
fn into_any(self: Box<T>) -> Box<dyn Any>
Converts
Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>, which can then be
downcast into Box<dyn ConcreteType> where ConcreteType implements Trait.Source§fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
Converts
Rc<Trait> (where Trait: Downcast) to Rc<Any>, which can then be further
downcast into Rc<ConcreteType> where ConcreteType implements Trait.Source§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
Converts
&Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &Any’s vtable from &Trait’s.Source§fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
Converts
&mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &mut Any’s vtable from &mut Trait’s.Source§impl<T> DowncastSend for T
impl<T> DowncastSend for T
Source§impl<T> DowncastSync for T
impl<T> DowncastSync for T
Source§impl<T> DowncastSync for T
impl<T> DowncastSync for T
impl<T> ErasedDestructor for Twhere
T: 'static,
impl<T> Fruit for T
impl<A, B, T> HttpServerConnExec<A, B> for Twhere
B: Body,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§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