ydb 0.17.1

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
30
31

use std::time::Duration;

use crate::grpc_connection_manager::GrpcConnectionManager;
use crate::grpc_wrapper::raw_errors::{RawError, RawResult};
use crate::grpc_wrapper::raw_query_service::client::RawQueryClient;
use crate::grpc_wrapper::raw_query_service::execute_script::RawExecuteScriptRequest;
use crate::grpc_wrapper::raw_ydb_operation::RawOperationParams;

/// Start a long-running ExecuteScript operation (for integration tests).
pub(crate) async fn start_execute_script_operation(
    connection_manager: &GrpcConnectionManager,
) -> RawResult<String> {
    let mut client = connection_manager
        .get_auth_service(RawQueryClient::new)
        .await
        .map_err(|e| RawError::custom(e.to_string()))?;

    let req = RawExecuteScriptRequest {
        yql_text: "$items = ListFromRange(1, 50000000); SELECT ListSum($items);".to_string(),
        parameters: Default::default(),
        results_ttl: Duration::from_secs(3600),
        operation_params: RawOperationParams::for_execute_script(
            Duration::from_secs(3600),
            Duration::from_secs(3600),
        ),
        collect_stats: false,
    };

    let (operation_id, _) = client.execute_script(req).await?;
    Ok(operation_id)
}