ydb 0.5.2

Crate contains generated low-level grpc code from YDB API protobuf, used as base for ydb crate
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

use std::time;
use std::time::UNIX_EPOCH;

use tracing_test::traced_test;

use crate::errors::YdbResult;
use crate::test_integration_helper::create_client;

#[tokio::test]
#[traced_test]
#[ignore] // need YDB access
async fn create_list_remove_directory() -> YdbResult<()> {
    let client = create_client().await?;
    let database_path = client.database();
    let mut scheme_client = client.scheme_client();
    let time_now = time::SystemTime::now().duration_since(UNIX_EPOCH)?;
    let directory_name = format!("directory_{}", time_now.as_millis());
    let directory_path = format!("{}/{}", database_path, directory_name.clone());

    scheme_client.make_directory(directory_path.clone()).await?;
    let directories = scheme_client.list_directory(database_path.clone()).await?;
    assert!(directories.iter().any(|d| d.name == directory_name));

    scheme_client.remove_directory(directory_path).await?;
    let directories = scheme_client.list_directory(database_path).await?;
    assert!(!directories.iter().any(|d| d.name == directory_name));

    Ok(())
}