Struct FilesystemWireService 

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

One SDK-owned protocol adapter over the canonical filesystem engine.

Deployments wrap this adapter with authentication, quota, credential issuance, and transport policy. Filesystem semantics stay here.

Implementations

impl<A, O> FilesystemWireService<A, O>

pub fn new( filesystem: Fs<A, O>, limits: FilesystemWireLimits, ) -> Result<Self, Status>

Binds one canonical engine and validates finite protocol bounds.

Errors

Rejects a zero bound.

pub const fn filesystem(&self) -> &Fs<A, O>

Borrows the exact engine served by this adapter.

pub fn with_credential_issuer( self, issuer: Arc<dyn FilesystemCredentialIssuer>, ) -> Self

Installs the authenticated deployment’s scoped credential issuer.

pub fn with_source_provider( self, provider: Arc<dyn FilesystemSourceProvider>, ) -> Self

Installs the deployment’s authenticated hosted-source provider.

Trait Implementations

impl<A: Clone, O: Clone> Clone for FilesystemWireService<A, O>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<A, O> FilesystemService for FilesystemWireService<A, O>

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

type ExportStream = Pin<Box<dyn Stream<Item = Result<ExportChunk, Status>> + Send>>

Server streaming response type for the Export method.

fn handshake<'life0, 'async_trait>( &'life0 self, request: Request<HandshakeRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<HandshakeResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn create_workspace<'life0, 'async_trait>( &'life0 self, request: Request<CreateWorkspaceRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<WorkspaceResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn open_workspace<'life0, 'async_trait>( &'life0 self, request: Request<OpenWorkspaceRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<WorkspaceResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn delete_workspace<'life0, 'async_trait>( &'life0 self, request: Request<DeleteWorkspaceRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<MutationResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_head<'life0, 'async_trait>( &'life0 self, request: Request<GetHeadRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GenerationResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_generation<'life0, 'async_trait>( &'life0 self, request: Request<GetGenerationRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GenerationResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn read<'life0, 'async_trait>( &'life0 self, request: Request<ReadRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ReadResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn stat<'life0, 'async_trait>( &'life0 self, request: Request<StatRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<StatResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn list_directory<'life0, 'async_trait>( &'life0 self, request: Request<ListDirectoryRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListDirectoryResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn read_link<'life0, 'async_trait>( &'life0 self, request: Request<ReadLinkRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ReadResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn plan_extents<'life0, 'async_trait>( &'life0 self, request: Request<PlanExtentsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<PlanExtentsResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn apply_transaction<'life0, 'async_trait>( &'life0 self, request: Request<ApplyTransactionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<MutationResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn rebase_transaction<'life0, 'async_trait>( &'life0 self, request: Request<RebaseTransactionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RebaseTransactionResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn fork_workspace<'life0, 'async_trait>( &'life0 self, request: Request<ForkWorkspaceRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<WorkspaceResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn diff<'life0, 'async_trait>( &'life0 self, request: Request<DiffRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DiffResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn rebase<'life0, 'async_trait>( &'life0 self, request: Request<RebaseRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RebaseResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn plan_join<'life0, 'async_trait>( &'life0 self, request: Request<PlanJoinRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<JoinPlan>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn apply_join<'life0, 'async_trait>( &'life0 self, request: Request<ApplyJoinRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<JoinResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn checkpoint<'life0, 'async_trait>( &'life0 self, request: Request<RetainGenerationRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RetainGenerationResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn pin<'life0, 'async_trait>( &'life0 self, request: Request<RetainGenerationRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RetainGenerationResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn export<'life0, 'async_trait>( &'life0 self, request: Request<ExportRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::ExportStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn import<'life0, 'async_trait>( &'life0 self, request: Request<Streaming<ImportChunk>>, ) -> Pin<Box<dyn Future<Output = Result<Response<ImportResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn issue_mount_credential<'life0, 'async_trait>( &'life0 self, request: Request<CredentialRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CredentialResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn issue_s3_credential<'life0, 'async_trait>( &'life0 self, request: Request<CredentialRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CredentialResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_source_state<'life0, 'async_trait>( &'life0 self, request: Request<SourceStateRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SourceResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn reconcile_source<'life0, 'async_trait>( &'life0 self, request: Request<SourceOperationRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SourceResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn rescan_source<'life0, 'async_trait>( &'life0 self, request: Request<SourceOperationRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SourceResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn seal_source<'life0, 'async_trait>( &'life0 self, request: Request<SourceOperationRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SourceResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn observe<'life0, 'async_trait>( &'life0 self, request: Request<ObserveRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ObserveResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn cancel<'life0, 'async_trait>( &'life0 self, request: Request<CancelRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CancelResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,