Struct ClientSession 

pub struct ClientSession { /* private fields */ }

Implementations

impl ClientSession

pub fn new(session: Session) -> Arc<Self>

pub fn id(&self) -> i64

pub fn space(&self) -> Option<SpaceSummary>

pub fn set_space(&self, space: SpaceSummary)

pub fn clear_space(&self)

pub fn space_name(&self) -> Option<String>

pub fn user(&self) -> String

pub fn roles(&self) -> HashMap<i64, RoleType>

pub fn role_with_space(&self, space: i64) -> Option<RoleType>

pub fn is_god(&self) -> bool

pub fn is_admin(&self) -> bool

pub fn is_schema_admin(&self) -> bool

pub fn set_role(&self, space: i64, role: RoleType)

pub fn idle_seconds(&self) -> u64

pub fn charge(&self)

pub fn timezone(&self) -> Option<i32>

pub fn set_timezone(&self, timezone: i32)

pub fn graph_addr(&self) -> Option<String>

pub fn update_graph_addr(&self, host_addr: String)

pub fn get_session(&self) -> Session

pub fn update_space_name(&self, space_name: String)

pub fn add_query(&self, ep_id: u32, query_context: String)

pub fn register_streaming_query( &self, query_id: u32, query_text: String, runtime: Weak<ExecutionRuntime>, )

Register a streaming query with a weak runtime reference for KILL QUERY support.

pub fn unregister_streaming_query(&self, query_id: u32)

Unregister a streaming query on completion.

pub fn delete_query(&self, ep_id: u32)

pub fn find_query(&self, ep_id: u32) -> bool

pub fn mark_query_killed(&self, ep_id: u32)

pub fn mark_all_queries_killed(&self)

pub fn active_queries_count(&self) -> usize

pub fn kill_query(&self, query_id: u32) -> QueryResult<()>

pub fn kill_multiple_queries(&self, query_ids: &[u32]) -> Vec<QueryResult<()>>

pub fn open_cursor( &self, query: String, result: StreamingQueryResult, columns: Vec<String>, ) -> Result<u64, String>

Open a forward-only cursor over an already-started streaming result.

pub fn fetch_cursor_page( &self, cursor_id: u64, page_size: usize, ) -> Result<CursorPage, String>

Fetch one page from a cursor (blocking; run off the async runtime).

pub fn close_cursor(&self, cursor_id: u64) -> bool

Release a cursor; returns false when the id was unknown.

pub fn close_all_cursors(&self)

Release every cursor held by this session.

pub fn cursor_count(&self) -> usize

Number of currently open cursors.

pub fn current_transaction(&self) -> Option<TransactionId>

pub fn bind_transaction(&self, txn_id: TransactionId)

pub fn unbind_transaction(&self)

pub fn has_active_transaction(&self) -> bool

pub fn is_auto_commit(&self) -> bool

pub fn set_auto_commit(&self, auto_commit: bool)

pub fn transaction_options(&self) -> TransactionOptions

pub fn set_transaction_options(&self, options: TransactionOptions)

pub fn push_savepoint(&self, savepoint_id: SavepointId)

pub fn savepoint_stack(&self) -> Vec<SavepointId>

pub fn clear_savepoints(&self)

pub fn savepoint_count(&self) -> usize

pub fn statistics(&self) -> &SessionStatistics

pub fn set_variable(&self, name: String, value: Value)

Assign a session variable, recording a transaction overlay operation when an explicit transaction is active.

pub fn variable_value(&self, name: &str) -> Option<Value>

Effective value of a session variable: transaction overlay first, then the base store.

pub fn variables_snapshot(&self) -> HashMap<String, Value>

Snapshot of all session variables (base + overlay) for injection as query inputs.

pub fn commit_variables(&self)

COMMIT: apply overlay operations to the base store and clear the overlay (the last assignment of each variable wins).

pub fn rollback_variables(&self)

Full ROLLBACK: restore pre-transaction values and clear the overlay.

pub fn rollback_variables_to(&self, savepoint_name: &str) -> bool

ROLLBACK TO SAVEPOINT: restore values assigned after the named savepoint and truncate the overlay at the savepoint marker.

pub fn release_variable_savepoint(&self, savepoint_name: &str)

RELEASE SAVEPOINT: drop the marker (operations stay part of the transaction; they are no longer individually rollback-able).

pub fn push_variable_savepoint(&self, savepoint_name: &str)

SAVEPOINT: record a variable-overlay boundary so ROLLBACK TO can restore assignments made after the savepoint.

Trait Implementations

impl Debug for ClientSession

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.