Struct LocalFileTransfer 

pub struct LocalFileTransfer { /* private fields */ }

The reference file_transfer implementation.

Implementations

impl LocalFileTransfer

pub fn new( config: FileTransferConfig, api: AttaccaApiClient, tofu: TofuStore, confirmer: Arc<dyn PeerConfirmer>, link: Arc<dyn PeerLink>, ) -> LocalFileTransfer

pub fn pending( config: FileTransferConfig, tofu: TofuStore, confirmer: Arc<dyn PeerConfirmer>, link: Arc<dyn PeerLink>, ) -> LocalFileTransfer

The same thing, with the rendezvous client still to come.

A node announces its capabilities before it connects, and the client is something the connection hands back — so a node that registers this one has no client to give it yet. Until Self::set_api is called, send_to refuses rather than pretending: there is no way to find a peer without something to ask.

pub fn set_api(&self, api: AttaccaApiClient)

Plugs in the rendezvous client for the connection this node is on now.

Call it on every connect, not just the first. See Rendezvous.

pub fn rendezvous(&self) -> Rendezvous

The same handle this transfer looks peers up through, for a node that also wants to hand it to listen::serve_peers as its directory — one client, kept current in one place, serving both directions.

Trait Implementations

impl Clone for LocalFileTransfer

fn clone(&self) -> LocalFileTransfer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl FileTransfer for LocalFileTransfer

fn send_to<'life0, 'async_trait>( &'life0 self, node: String, path: String, name: Option<String>, overwrite: Option<bool>, ) -> Pin<Box<dyn Future<Output = Result<SendReceipt>> + Send + 'async_trait>>

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

Send a file on this machine to another node on the same account.

fn inbox_list<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<InboxEntry>>> + Send + 'async_trait>>

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

What has arrived in this machine’s inbox.