Struct SnowflakeSession 

pub struct SnowflakeSession { /* private fields */ }

A live, authenticated Snowflake session.

Holds the session and master tokens behind a mutex so a query (reading the session token) and a heartbeat/renew can interleave. query runs SQL; renew swaps in a fresh session token via the master token; heartbeat keeps the master token alive so renewal can continue indefinitely.

Implementations

impl SnowflakeSession

pub fn session_expiring_within(&self, within: TimeDelta) -> bool

Whether the session token expires within within from now.

pub fn master_expires_at(&self) -> DateTime<Utc>

When the master token currently expires (renewal must happen before this, kept alive by heartbeat).

pub async fn query(&self, sql: &str) -> Result<Vec<Row>>

Runs SQL and returns the result rows.

Errors

Error::SessionExpired when the session token is no longer valid (renew or re-authenticate), or a transport/server/protocol error.

pub async fn renew(&self) -> Result<()>

Renews the session token using the master token, extending the session.

Errors

Error::SessionExpired when the master token has itself expired (a full re-authentication is then required), or a transport/server error.

pub async fn heartbeat(&self) -> Result<()>

Sends a keep-alive heartbeat, extending the master token server-side.

Errors

A transport/server error, or Error::SessionExpired if the session token used to authorize the heartbeat has already lapsed.

pub async fn close(&self) -> Result<()>

Logs the session out (best-effort).

Errors

A transport/server error.