Skip to main content

Installed

Struct Installed 

Source
pub struct Installed<'local, 'd: 'local, I: Catalog> { /* private fields */ }
Expand description

Installed database application owned by one executor generation.

Trait Implementations§

Source§

impl<'local, 'd: 'local, I: Catalog> App<'d> for Installed<'local, 'd, I>

Source§

unsafe fn park<'app, 'driver, 'turn>( app: Pin<&'app mut Self>, (): &mut Self::ParkPlan, park: Park<'driver, 'turn, 'd>, )
where 'd: 'driver + 'turn,

§Safety

The root, prepared plan, and park authority belong to this installed owner.

Source§

const ROUTES: Routes = settings::Routes::EMPTY

Source§

const COORDS: usize = 1

Upper bound on idle coordinator probes, including delegated probes.
Source§

fn select_park() -> Option<Self::ParkPlan>

Source§

fn released(released: Released<'_, Self>) -> Released<'_, Self>

Source§

fn shutdown<'app, 'turn, 'driver>( shutdown: Shutdown<'app, 'turn, 'driver, 'd, Self>, ) -> Shutdown<'app, 'turn, 'driver, 'd, Self>

Source§

fn finish<'app, 'finish, 'owner, 'epoch>( finish: Finish<'app, 'finish, 'owner, 'epoch, 'd, Self>, ) -> Finish<'app, 'finish, 'owner, 'epoch, 'd, Self>

Source§

fn progress(app: Pin<&Self>, _: Progress<'_, '_, 'd>) -> Progress<'d>

Source§

fn stopping(app: Pin<&Self>, _: Progress<'_, '_, 'd>) -> Progress<'d>

Source§

const WAKE_ROUTES: Routes = settings::Routes::EMPTY

Routes whose installed owners may receive activation.
Source§

fn prepare_park(_: Pin<&Self>, _: &mut Self::ParkPlan) -> Option<Count>

Prepares the selected coordinator shares once after installation. The count does not exceed COORDS; field presence and shares remain stable through finish. None reports count overflow.
Source§

fn admit(_: Pin<&Self>, needs: &mut Needs) -> Result<(), Claim>

Accumulates the routes of the owners actually present in this pinned root.
Source§

fn install<'app, 'owner>( install: Install<'app, 'owner, 'd, Self>, ) -> Install<'app, 'owner, 'd, Self>

Source§

unsafe fn activate<'app, 'driver, 'turn>( _: Pin<&'app mut Self>, _: Activate<'driver, 'turn, 'd>, ) -> bool
where 'd: 'driver, 'd: 'turn,

Returns whether a present owner handled this activation. On false, the caller may continue through the remaining owners of the same root. Read more
Source§

fn dispatch<'app, 'driver, 'turn>( call: Dispatch<'app, 'driver, 'turn, 'd, Self>, ) -> ControlFlow<Event<'d>>

Source§

impl<I: Catalog> Drop for Installed<'_, '_, I>

Source§

fn drop(&mut self)

Executes the destructor for this type. Read more
Source§

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)
Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned. Read more
Source§

impl<'local, 'd: 'local, I: Catalog> Layout<'d> for Installed<'local, 'd, I>

Source§

type ParkPlan = ()

Pre-park state selected once and retained with this pinned application.
Source§

impl<'local, 'd: 'local, I: Catalog> Provider<'d> for Installed<'local, 'd, I>

Source§

type Client<'app> = Result<Connection<'app, 'local, 'd, I>, Error>
where Self: 'app, 'd: 'app,

Source§

fn provide<'app>(context: Context<'_, 'app, 'd, Self>) -> Self::Client<'app>
where Self: 'app, 'd: 'app,

Source§

impl<'local, 'd: 'local, I: Catalog> Resume<'d> for Installed<'local, 'd, I>

Auto Trait Implementations§

§

impl<'local, 'd, I> !RefUnwindSafe for Installed<'local, 'd, I>

§

impl<'local, 'd, I> !Send for Installed<'local, 'd, I>

§

impl<'local, 'd, I> !Sync for Installed<'local, 'd, I>

§

impl<'local, 'd, I> !Unpin for Installed<'local, 'd, I>

§

impl<'local, 'd, I> !UnwindSafe for Installed<'local, 'd, I>

§

impl<'local, 'd, I> Forget for Installed<'local, 'd, I>

§

impl<'local, 'd, I> Freeze for Installed<'local, 'd, I>
where NonNull<Phase<'local, 'd, I>>: Freeze, PhantomData<(Phase<'local, 'd, I>, PhantomPinned)>: Freeze,

§

impl<'local, 'd, I> UnsafeUnpin for Installed<'local, 'd, I>
where NonNull<Phase<'local, 'd, I>>: UnsafeUnpin, PhantomData<(Phase<'local, 'd, I>, PhantomPinned)>: UnsafeUnpin,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> Convert<T> for T

Source§

fn into(self) -> T

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<'d, P> Root<'d> for P
where P: Provider<'d>,

Source§

type Provider = P

Source§

fn provider(self: Pin<&P>) -> Pin<&<P as Root<'d>>::Provider>

Source§

impl<'w, 'd, W, P, ID> Sink<'w, 'd, W, ID, Never> for P
where ID: Identity, W: Spec<TerminalFailure = Never> + 'w, P: ?Sized,

Source§

fn fail(&self, _: Id<'d, ID>, cause: Error<'w, W>, _: &mut Token<Identity<'d>>)

Source§

impl<'w, 'd, W, P, ID> Sink<'w, 'd, W, ID, Never> for P
where ID: Identity, W: Spec<OpenFailure = Never> + 'w, P: ?Sized,

Source§

fn fail( &self, _: Completion<'_, 'd, ID>, cause: Error<'w, W>, _: &mut Context<'_, 'd>, )

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.