rs_transfer 8.0.0

A simple crate to handle downloads and uploads on multiple providers
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

mod file_writer;
mod ftp_writer;
mod gcs_writer;
mod s3_writer;
mod sftp_writer;

use crate::{StreamData, error::Error};
use async_std::channel::Receiver;
use async_trait::async_trait;

#[async_trait]
pub trait StreamWriter {
  async fn write_stream(
    &self,
    path: &str,
    receiver: Receiver<StreamData>,
    job_and_notification: &dyn WriteJob,
  ) -> Result<(), Error>;
}

pub trait WriteJob: Send + Sync {
  fn get_str_job_id(&self) -> String {
    "".to_string()
  }
  fn progress(&self, progress: u8) -> Result<(), Error> {
    log::info!(target: &self.get_str_job_id(), "Received progress {progress}/100");
    Ok(())
  }

  fn is_stopped(&self) -> bool {
    false
  }
}

pub struct DummyWriteJob {}

impl WriteJob for DummyWriteJob {}