Struct FileTransferServiceImpl 

pub struct FileTransferServiceImpl { /* private fields */ }

Default file transfer service implementation.

Implementations

impl FileTransferServiceImpl

pub async fn new( source_node: NodeId, backend: Arc<dyn MessageBackend>, stream_opener: Arc<dyn ChunkStreamOpener>, config: FileTransferConfig, ) -> Result<FileTransferServiceImpl, FileTransferError>

Creates a new service and starts internal control handling.

Errors

Returns FileTransferError::Transport if subscribing to the backend fails.

Panics

This method does not panic.

pub fn control(&self) -> Arc<ControlDispatcher>

Returns the control dispatcher for sending/receiving control messages.

Panics

This method does not panic.

pub fn receive_handler(&self) -> Arc<ReceiveHandler>

Returns the receive handler for incoming transfer data.

Panics

This method does not panic.

pub fn path_validator(&self) -> &PathValidator

Returns the path validator used for file operations.

Panics

This method does not panic.

Trait Implementations

impl FileTransferService for FileTransferServiceImpl

fn send_file<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, target: NodeId, source_path: &'life1 Path, dest_path: &'life2 Path, options: TransferOptions, ) -> Pin<Box<dyn Future<Output = Result<TransferHandle, FileTransferError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, FileTransferServiceImpl: 'async_trait,

Sends a file to a target node.

fn broadcast_file<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, source_path: &'life1 Path, dest_path: &'life2 Path, options: TransferOptions, ) -> Pin<Box<dyn Future<Output = Result<BroadcastHandle, FileTransferError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, FileTransferServiceImpl: 'async_trait,

Sends a file to all connected peers.

fn sync_file<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, local_path: &'life1 Path, remote_path: &'life2 Path, targets: Option<Vec<NodeId>>, options: SyncOptions, ) -> Pin<Box<dyn Future<Output = Result<SyncHandle, FileTransferError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, FileTransferServiceImpl: 'async_trait,

Synchronizes a local path with a remote path.

fn exists<'life0, 'life1, 'async_trait>( &'life0 self, target: NodeId, path: &'life1 Path, ) -> Pin<Box<dyn Future<Output = Result<bool, FileTransferError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, FileTransferServiceImpl: 'async_trait,

Checks if a path exists on a target node.

fn remove<'life0, 'life1, 'async_trait>( &'life0 self, target: NodeId, path: &'life1 Path, options: RemoveOptions, ) -> Pin<Box<dyn Future<Output = Result<(), FileTransferError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, FileTransferServiceImpl: 'async_trait,

Removes a file or directory on a target node.

fn metadata<'life0, 'life1, 'async_trait>( &'life0 self, target: NodeId, path: &'life1 Path, ) -> Pin<Box<dyn Future<Output = Result<FileMetadata, FileTransferError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, FileTransferServiceImpl: 'async_trait,

Fetches metadata for a file or directory on a target node.

fn list_files<'life0, 'life1, 'async_trait>( &'life0 self, target: NodeId, dir_path: &'life1 Path, options: ListOptions, ) -> Pin<Box<dyn Future<Output = Result<Vec<FileInfo>, FileTransferError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, FileTransferServiceImpl: 'async_trait,

Lists files within a directory on a target node.

fn cancel_transfer<'life0, 'async_trait>( &'life0 self, session_id: TransferSessionId, ) -> Pin<Box<dyn Future<Output = Result<(), FileTransferError>> + Send + 'async_trait>>

where 'life0: 'async_trait, FileTransferServiceImpl: 'async_trait,

Cancels an active transfer by session id.

fn pause_transfer<'life0, 'async_trait>( &'life0 self, session_id: TransferSessionId, ) -> Pin<Box<dyn Future<Output = Result<(), FileTransferError>> + Send + 'async_trait>>

where 'life0: 'async_trait, FileTransferServiceImpl: 'async_trait,

Pauses an active transfer by session id.

fn resume_transfer<'life0, 'async_trait>( &'life0 self, session_id: TransferSessionId, ) -> Pin<Box<dyn Future<Output = Result<TransferHandle, FileTransferError>> + Send + 'async_trait>>

where 'life0: 'async_trait, FileTransferServiceImpl: 'async_trait,

Resumes a paused transfer by session id.

fn active_transfers(&self) -> Vec<TransferSessionInfo>

Returns a snapshot of active transfer sessions.