pub struct Mount<A, O> { /* private fields */ }Expand description
One process-owned customer mount over a canonical workspace checkout.
Implementations§
Source§impl<A, O> Mount<A, O>
impl<A, O> Mount<A, O>
Sourcepub async fn sync(&self) -> Result<(), MountLifecycleError>
pub async fn sync(&self) -> Result<(), MountLifecycleError>
Publishes all pending authored effects with one fenced generation.
§Errors
Returns a typed publication failure without discarding pending state.
Sourcepub async fn sync_with_permit(
&self,
permit: PublicationPermit,
) -> Result<(), MountLifecycleError>
pub async fn sync_with_permit( &self, permit: PublicationPermit, ) -> Result<(), MountLifecycleError>
Publishes all pending effects under one active operation lease.
Sourcepub async fn refresh(&self) -> Result<(), MountLifecycleError>
pub async fn refresh(&self) -> Result<(), MountLifecycleError>
Publishes pending writes and advances the live checkout to workspace head.
This keeps a direct-parent agent mount coherent after a child join without exposing remount orchestration to adapters.
Sourcepub async fn advance_to_head(&self) -> Result<(), MountLifecycleError>
pub async fn advance_to_head(&self) -> Result<(), MountLifecycleError>
Advances an already-clean live checkout to the workspace head.
Use this after an external, fenced workspace publication when the
caller already synchronized the mount before that publication. Unlike
Self::refresh, this does not try to republish against the newer head.
§Errors
Returns a typed conflict or storage failure without changing the mounted generation.
Sourcepub fn sync_blocking(&self) -> Result<(), MountLifecycleError>
pub fn sync_blocking(&self) -> Result<(), MountLifecycleError>
Publishes all pending effects on the source’s dedicated callback runtime.
§Errors
Returns a typed publication failure without discarding pending state.
Sourcepub async fn unmount(&self) -> Result<(), MountLifecycleError>
pub async fn unmount(&self) -> Result<(), MountLifecycleError>
Publishes pending effects and detaches the native namespace exactly once.
§Errors
Publication failure leaves the live mount owned by this handle. A detach failure retains driver state and its destination fence for drop retry.
Sourcepub fn abandon(&self) -> Result<(), MountLifecycleError>
pub fn abandon(&self) -> Result<(), MountLifecycleError>
Detaches and cancels this mount without publishing pending callbacks.
This is the fail-closed recovery path after a fenced publication. The caller may remount from the last durable generation.
Sourcepub fn unmount_blocking(&self) -> Result<(), MountLifecycleError>
pub fn unmount_blocking(&self) -> Result<(), MountLifecycleError>
Synchronously publishes and detaches for foreign-runtime worker threads.
§Errors
Publication or detach failure retains the complete owner for retry.
Auto Trait Implementations§
impl<A, O> !Freeze for Mount<A, O>
impl<A, O> !RefUnwindSafe for Mount<A, O>
impl<A, O> !UnwindSafe for Mount<A, O>
impl<A, O> Send for Mount<A, O>
impl<A, O> Sync for Mount<A, O>
impl<A, O> Unpin for Mount<A, O>
impl<A, O> UnsafeUnpin for Mount<A, O>
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a tonic::Request