Struct google_cloud_spanner::session::SessionManager

pub struct SessionManager { /* private fields */ }

Implementations

impl SessionManager

pub async fn new(
    database: impl Into<String>,
    conn_pool: ConnectionManager,
    config: SessionConfig
) -> Result<SessionManager, Status>

Examples found in repository

src/client.rs (line 200)

    pub async fn new_with_config(
        database: impl Into<String>,
        config: ClientConfig,
    ) -> Result<Self, InitializationError> {
        if config.session_config.max_opened > config.channel_config.num_channels * 100 {
            return Err(InitializationError::InvalidConfig(format!(
                "max session size is {} because max session size is 100 per gRPC connection",
                config.channel_config.num_channels * 100
            )));
        }

        let environment = Environment::from_project(config.project).await?;
        let pool_size = config.channel_config.num_channels;
        let conn_pool = ConnectionManager::new(pool_size, &environment, config.endpoint.as_str()).await?;
        let session_manager = SessionManager::new(database, conn_pool, config.session_config).await?;

        Ok(Client {
            sessions: Arc::new(session_manager),
        })
    }

pub fn num_opened(&self) -> usize

Examples found in repository

src/client.rs (line 624)

    pub fn session_count(&self) -> usize {
        self.sessions.num_opened()
    }

pub fn session_waiters(&self) -> usize

pub async fn get(&self) -> Result<ManagedSession, SessionError>

Examples found in repository

src/client.rs (line 670)

    async fn get_session(&self) -> Result<ManagedSession, SessionError> {
        self.sessions.get().await
    }