Struct CheckoutMountSource 

pub struct CheckoutMountSource<A, O> { /* private fields */ }

Blocking native callback adapter over one async canonical checkout.

Implementations

impl<A, O> CheckoutMountSource<A, O>

pub fn new( checkout: Arc<SharedCheckout<A, O>>, config: VolumeConfig, ) -> Result<Self, NativeMountError>

Creates an independently cancellable adapter using the shared callback runtime.

Errors

Returns a driver failure when the bounded callback runtime cannot start.

pub fn new_at( checkout: Arc<SharedCheckout<A, O>>, config: VolumeConfig, root: NamespacePath, ) -> Result<Self, NativeMountError>

Creates an adapter rooted at an authenticated workspace subtree.

Errors

Returns a profile or runtime failure before any native mount starts.

pub fn volume_id(&self) -> Result<VolumeId, MountSourceError>

where A: Send + Sync, O: Send + Sync,

Returns the checkout’s owning volume without filesystem I/O.

Errors

Returns stale when callback admission exceeds the finite deadline.

pub fn cancel(&self)

Cancels future and in-flight canonical operations owned by this mount.

pub fn sync(&self) -> Result<(), MountSourceError>

where A: AsyncAuthorityStore + Send + Sync, O: AsyncObjectStore + Send + Sync,

Publishes every pending mount mutation regardless of automatic policy.

Errors

Returns the exact fenced publication failure and retains retry identity.

pub async fn sync_async(&self) -> Result<(), MountSourceError>

where A: AsyncAuthorityStore, O: AsyncObjectStore,

Asynchronously publishes every pending mount mutation.

This is the native customer handle path and does not enter the blocking foreign-thread callback bridge.

Errors

Returns the exact fenced publication failure and retains retry identity.

pub async fn sync_async_with_permit( &self, permit: PublicationPermit, ) -> Result<(), MountSourceError>

where A: AsyncAuthorityStore, O: AsyncObjectStore,

Publishes pending mutations only while the supplied operation lease is still active in the shared authority provider.

pub async fn refresh_async(&self) -> Result<(), MountSourceError>

where A: AsyncAuthorityStore, O: AsyncObjectStore,

Safely advances a clean mounted checkout to the workspace head.

Callers must publish pending native mutations first. Exact read dependencies are retained and checked against the candidate head; conflict leaves the mounted generation unchanged.

pub async fn advance_to_head_async(&self) -> Result<(), MountSourceError>

where A: AsyncAuthorityStore, O: AsyncObjectStore,

Adopts the workspace head after this checkout’s mutations were synchronized and a separate fenced operation published that head.

Trait Implementations

impl<A, O> MountFilesystem for CheckoutMountSource<A, O>

where A: AsyncAuthorityStore + Send + Sync + 'static, O: AsyncObjectStore + Send + Sync + 'static,

fn supports_posix_named_attributes(&self) -> bool

Whether this source can represent native POSIX named attributes.

fn view_epoch(&self) -> Option<u64>

Returns the current coherent projection view, when the source can precisely invalidate cached lookups.

fn binding_epoch(&self) -> Option<u64>

Changes only when existing path or handle bindings may be replaced by an external source transition. Ordinary mutations may advance view_epoch to invalidate caches without making a native callback stale. Sources without that distinction retain the conservative view epoch behavior.

fn view_is_stable(&self) -> bool

Whether a lookup may observe one coherent source view right now. Drivers must retry or fail stale while this is false.

fn acquire_view_lease( &self, expected_epoch: Option<u64>, ) -> Result<Box<dyn MountViewLease>, MountSourceError>

Pins the current coherent projection view for one native callback.

fn acquire_binding_lease( &self, expected_epoch: Option<u64>, ) -> Result<Box<dyn MountViewLease>, MountSourceError>

Pins source binding identity without treating ordinary native writes as an external rebind. A callback must separately validate its cache epoch before reusing a lookup result.

fn lookup( &self, path: &MountPath, ) -> Result<Option<MountLookup>, MountSourceError>

Looks up one absolute portable path without following links.

fn open_file( &self, path: &MountPath, ) -> Result<Arc<dyn MountOpenFile>, MountSourceError>

Opens one regular file as an attached path-independent handle.

fn detach_file( &self, path: &MountPath, ) -> Result<Arc<dyn MountOpenFile>, MountSourceError>

Captures one regular file as a detached path-independent open-file view.

fn read_link(&self, path: &MountPath) -> Result<Bytes, MountSourceError>

Reads one symbolic link’s exact opaque target bytes without following it.

fn read_range( &self, path: &MountPath, offset: u64, length: u32, ) -> Result<Bytes, MountSourceError>

Reads at most one exact logical range.

fn seek( &self, path: &MountPath, offset: u64, target: MountSeekTarget, ) -> Result<Option<u64>, MountSourceError>

Finds the first sparse data or hole byte at/after one offset.

fn read_directory( &self, path: &MountPath, cursor: Option<&[u8]>, maximum_entries: u32, ) -> Result<MountDirectoryPage, MountSourceError>

Reads one bounded page using a handle-owned opaque cursor.

fn create_file( &self, path: &MountPath, metadata: FileMetadata, ) -> Result<MountLookup, MountSourceError>

Creates one empty regular file.

fn create_directory( &self, path: &MountPath, metadata: FileMetadata, ) -> Result<MountLookup, MountSourceError>

Creates one empty directory.

fn create_symbolic_link( &self, path: &MountPath, target: Bytes, metadata: FileMetadata, ) -> Result<MountLookup, MountSourceError>

Creates one symbolic link with an exact opaque target.

fn create_special( &self, path: &MountPath, kind: MountNodeKind, device: Option<(u32, u32)>, metadata: FileMetadata, ) -> Result<MountLookup, MountSourceError>

Creates one FIFO, socket, character device, or block device.

fn set_attributes( &self, path: &MountPath, metadata: FileMetadata, logical_bytes: Option<u64>, ) -> Result<(), MountSourceError>

Atomically replaces complete metadata and optionally logical size.

fn read_attribute( &self, path: &MountPath, name: &[u8], ) -> Result<Option<Bytes>, MountSourceError>

Reads one exact native named attribute.

fn list_attributes( &self, path: &MountPath, cursor: Option<&[u8]>, maximum_entries: u32, ) -> Result<MountAttributePage, MountSourceError>

Lists one bounded page of native named-attribute names.

fn write_attribute( &self, path: &MountPath, name: &[u8], value: Bytes, mode: MountAttributeWriteMode, ) -> Result<(), MountSourceError>

Inserts or replaces one exact native named attribute.

fn remove_attribute( &self, path: &MountPath, name: &[u8], ) -> Result<(), MountSourceError>

Removes one exact native named attribute.

fn write_range( &self, path: &MountPath, offset: u64, bytes: Bytes, ) -> Result<(), MountSourceError>

Replaces one exact file range.

fn resize( &self, path: &MountPath, logical_bytes: u64, ) -> Result<(), MountSourceError>

Changes one file’s logical length.

fn allocate_range( &self, path: &MountPath, offset: u64, length: u64, operation: MountRangeAllocation, ) -> Result<(), MountSourceError>

Applies one exact sparse allocation operation.

fn clone_range( &self, source: &MountPath, source_offset: u64, destination: &MountPath, destination_offset: u64, length: u64, ) -> Result<(), MountSourceError>

Clones one immutable range between regular files without reading bytes.

fn clone_range_by_id( &self, source_file_id: FileId, source_offset: u64, destination_file_id: FileId, destination_offset: u64, length: u64, ) -> Result<(), MountSourceError>

Clones one logical range between stable attached file identities.

fn remove( &self, path: &MountPath, expected: Option<FileId>, ) -> Result<(), MountSourceError>

Removes one namespace binding.

fn rename( &self, source: &MountPath, destination: &MountPath, replace: bool, ) -> Result<(), MountSourceError>

Renames one binding atomically within the volume.

fn hard_link( &self, source: &MountPath, destination: &MountPath, ) -> Result<(), MountSourceError>

Creates one same-volume hard link.

fn flush(&self) -> Result<(), MountSourceError>

Seals all pending authored mutations through the checkout’s configured fenced publication path before acknowledging native durability.

fn capture_host_path( &self, source_root: &Path, path: &MountPath, ) -> Result<(), MountSourceError>

Reconciles exact final host state for one projected path and seals it.

fn capture_host_paths( &self, source_root: &Path, paths: &[MountPath], ) -> Result<(), MountSourceError>

Reconciles exact final host states together, preserving hard-link topology and admitting one bounded checkout candidate.

fn capture_host_subtree( &self, source_root: &Path, path: &MountPath, ) -> Result<(), MountSourceError>

Reconciles one imported directory and every descendant atomically.

fn flush_on_handle_close(&self) -> bool

Whether a native handle close is itself a publication boundary.