Struct Client

Source

pub struct Client { /* private fields */ }

Implementations§

Source §

impl Client

Source

pub fn new(host: String, port: u16, timeout: Duration) -> Result<Client>

Examples found in repository ?

examples/client.rs (line 9)

7async fn main() {
8    let path = "/test_path";
9    let c = client::Client::new("localhost".to_string(), 39999, Duration::from_secs(10)).unwrap();
10
11    let r = c.exists(path, option::Exists).await.unwrap();
12    let s = "123";
13    let d = s.as_bytes();
14    let buf = BufReader::new(d);
15    let id = c
16        .create_file(path, option::CreateFile::default())
17        .await
18        .unwrap();
19    c.write(id, BufReader::new(buf)).await.unwrap();
20    c.close(id).await.unwrap();
21    println!("{} {}", r, id);
22}

Source

pub async fn write<'a, I>(&'a self, id: i64, input: I) -> Result<i64>
where I: AsyncRead + Send + Sync + 'a + 'static,

Examples found in repository ?

examples/client.rs (line 19)

7async fn main() {
8    let path = "/test_path";
9    let c = client::Client::new("localhost".to_string(), 39999, Duration::from_secs(10)).unwrap();
10
11    let r = c.exists(path, option::Exists).await.unwrap();
12    let s = "123";
13    let d = s.as_bytes();
14    let buf = BufReader::new(d);
15    let id = c
16        .create_file(path, option::CreateFile::default())
17        .await
18        .unwrap();
19    c.write(id, BufReader::new(buf)).await.unwrap();
20    c.close(id).await.unwrap();
21    println!("{} {}", r, id);
22}

Source

pub async fn close(&self, id: i64) -> Result<()>

Examples found in repository ?

examples/client.rs (line 20)

7async fn main() {
8    let path = "/test_path";
9    let c = client::Client::new("localhost".to_string(), 39999, Duration::from_secs(10)).unwrap();
10
11    let r = c.exists(path, option::Exists).await.unwrap();
12    let s = "123";
13    let d = s.as_bytes();
14    let buf = BufReader::new(d);
15    let id = c
16        .create_file(path, option::CreateFile::default())
17        .await
18        .unwrap();
19    c.write(id, BufReader::new(buf)).await.unwrap();
20    c.close(id).await.unwrap();
21    println!("{} {}", r, id);
22}

Source

pub async fn read(&self, id: i64) -> Result<impl AsyncRead>

Source §

impl Client

Source

pub async fn create_directory( &self, path: &str, options: CreateDirectory, ) -> Result<()>

Source

pub async fn create_file(&self, path: &str, options: CreateFile) -> Result<i64>

Examples found in repository ?

examples/client.rs (line 16)

7async fn main() {
8    let path = "/test_path";
9    let c = client::Client::new("localhost".to_string(), 39999, Duration::from_secs(10)).unwrap();
10
11    let r = c.exists(path, option::Exists).await.unwrap();
12    let s = "123";
13    let d = s.as_bytes();
14    let buf = BufReader::new(d);
15    let id = c
16        .create_file(path, option::CreateFile::default())
17        .await
18        .unwrap();
19    c.write(id, BufReader::new(buf)).await.unwrap();
20    c.close(id).await.unwrap();
21    println!("{} {}", r, id);
22}

Source

pub async fn delete(&self, path: &str, options: Delete) -> Result<()>

Source

pub async fn exists(&self, path: &str, options: Exists) -> Result<bool>

Examples found in repository ?

examples/client.rs (line 11)

7async fn main() {
8    let path = "/test_path";
9    let c = client::Client::new("localhost".to_string(), 39999, Duration::from_secs(10)).unwrap();
10
11    let r = c.exists(path, option::Exists).await.unwrap();
12    let s = "123";
13    let d = s.as_bytes();
14    let buf = BufReader::new(d);
15    let id = c
16        .create_file(path, option::CreateFile::default())
17        .await
18        .unwrap();
19    c.write(id, BufReader::new(buf)).await.unwrap();
20    c.close(id).await.unwrap();
21    println!("{} {}", r, id);
22}