ydb 0.12.0

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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

use crate::errors::YdbResult;
use secrecy::SecretString;
use std::fmt::{Debug, Formatter};
use std::ops::Add;
use std::time::{Duration, Instant};

pub(crate) const DEFAULT_TOKEN_RENEW_INTERVAL: Duration = Duration::from_secs(3600); // 1 hour

#[derive(Debug, Clone)]
pub struct TokenInfo {
    pub(crate) token: SecretString,
    pub(crate) next_renew: Instant,
}

impl TokenInfo {
    pub(crate) fn token(token: String) -> Self {
        Self {
            token: SecretString::new(token),
            next_renew: Instant::now().add(DEFAULT_TOKEN_RENEW_INTERVAL),
        }
    }

    pub(crate) fn with_renew(mut self, next_renew: Instant) -> Self {
        self.next_renew = next_renew;
        self
    }
}

pub trait Credentials: Send + Sync {
    // may not cache result and can block for some time (command execute, network request)
    // if always called from thread, available to block
    // successfully result will cache until TokenInfo.next_renew,
    // then create_token called in background.
    // cached token will use until successfully return again
    // and TokenInfo.next_renew reserve until token expire for renew it
    // and for retry errors
    fn create_token(&self) -> YdbResult<TokenInfo>;

    fn debug_string(&self) -> String {
        "some credentials".to_string()
    }
}

impl Debug for dyn Credentials + 'static {
    fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
        f.write_str(self.debug_string().as_str())
    }
}