Struct GraphService 

pub struct GraphService<S: StorageClient + Clone + 'static> {
    pub stats_manager: Arc<StatsManager>,
    /* private fields */
}

Fields

stats_manager: Arc<StatsManager>

Implementations

impl<S: StorageClient + StorageSchemaContextOps + StorageSyncContextOps + StorageOperationContextOps + Clone + AutoCommitBatchOps + 'static> GraphService<S>

pub async fn execute_batch( &self, session_id: i64, statements: &[String], parameters: Option<HashMap<String, Value>>, session_variables: Option<HashMap<String, Value>>, ) -> Vec<Result<QueryResult, GraphServiceError>>

Execute a batch of auto-commit DML statements inside one shared auto-commit batch window.

impl<S: StorageClient + StorageSchemaContextOps + StorageSyncContextOps + StorageOperationContextOps + Clone + AutoCommitBatchOps + AutoCommitGroupOps + 'static> GraphService<S>

pub async fn execute_batch_grouped( &self, session_id: i64, statements: &[String], group_size: usize, ) -> Vec<Result<QueryResult, GraphServiceError>>

Execute a batch of auto-commit DML statements inside shared group-commit windows.

impl<S: StorageClient + StorageSchemaContextOps + StorageSyncContextOps + StorageOperationContextOps + Clone + 'static> GraphService<S>

pub async fn open_cursor( &self, session_id: i64, stmt: &str, ) -> Result<(u64, Vec<String>), String>

Open a forward-only cursor over a single statement’s result.

pub async fn fetch_cursor( &self, session_id: i64, cursor_id: u64, page_size: usize, ) -> Result<CursorPage, String>

Fetch one page from a cursor. Chunk pulls run off the async runtime; a failed execution drops the cursor and reports the error.

pub async fn close_cursor( &self, session_id: i64, cursor_id: u64, ) -> Result<bool, String>

Release a cursor. Unknown ids report closed: false, never an error.

impl<S: StorageClient + StorageSchemaContextOps + StorageSyncContextOps + StorageOperationContextOps + Clone + 'static> GraphService<S>

pub async fn estimate_rows(&self, session_id: i64, stmt: &str) -> Option<u64>

Best-effort output row estimate for automatic routing.

pub async fn explain( &self, session_id: i64, stmt: &str, parameters: Option<HashMap<String, Value>>, session_variables: Option<HashMap<String, Value>>, ) -> Result<QueryResult, GraphServiceError>

Plan a statement via EXPLAIN without executing it.

impl<S: StorageClient + StorageSchemaContextOps + StorageSyncContextOps + StorageOperationContextOps + Clone + 'static> GraphService<S>

pub async fn new(config: Config, storage: Arc<S>) -> Arc<Self>

Create a new GraphService (without a transaction manager, for use in a production environment).

pub async fn new_for_test(config: Config, storage: Arc<S>) -> Arc<Self>

Create a new GraphService (without a transaction manager and without starting any background tasks, for testing purposes).

pub async fn new_with_transaction_manager( config: Config, storage: Arc<S>, transaction_manager: Arc<TransactionManager>, ) -> Arc<Self>

Use the transaction manager to create a GraphService.

pub async fn new_with_transaction_manager_and_stats( config: Config, storage: Arc<S>, transaction_manager: Arc<TransactionManager>, stats_manager: Arc<StatsManager>, ) -> Arc<Self>

Use the transaction manager and external StatsManager to create a GraphService.

impl<S: StorageClient + StorageSchemaContextOps + StorageSyncContextOps + StorageOperationContextOps + Clone + 'static> GraphService<S>

pub async fn execute( &self, session_id: i64, stmt: &str, ) -> Result<QueryResult, GraphServiceError>

pub async fn execute_with_params( &self, session_id: i64, stmt: &str, parameters: Option<HashMap<String, Value>>, session_variables: Option<HashMap<String, Value>>, ) -> Result<QueryResult, GraphServiceError>

Execute a query with client-supplied query parameters (@name references) and/or session variables ($name references).

pub async fn execute_with_consistency( &self, session_id: i64, stmt: &str, parameters: Option<HashMap<String, Value>>, session_variables: Option<HashMap<String, Value>>, consistency: ConsistencyLevel, ) -> Result<QueryResult, GraphServiceError>

Execute a query with explicit consistency requirement.

impl<S: StorageClient + StorageSchemaContextOps + StorageSyncContextOps + StorageOperationContextOps + Clone + 'static> GraphService<S>

pub async fn authenticate( &self, username: &str, password: &str, ) -> Result<Arc<ClientSession>, String>

pub fn security_config(&self) -> &SecurityConfig

Password-policy settings snapshotted at startup.

pub fn validate_new_password( &self, username: &str, password: &str, ) -> Result<(), String>

Validate a new plaintext password against the configured policy.

Applies on every write path, including auth-disabled deployments: disabling auth only skips the login step, never weak-password writes.

pub fn password_expired(&self, username: &str) -> bool

Whether the account password is past the configured maximum age.

pub fn session_idle_timeout(&self) -> Duration

Session idle timeout driving expiry responses and reclamation.

pub fn must_change_password(&self, username: &str) -> bool

Whether the login response should prompt a password change.

True when forced rotation is configured and the default seed account has never changed its password, or when the account password is past the configured maximum age.

pub fn is_user_locked(&self, username: &str) -> bool

Whether the account is currently disabled.

pub fn shutdown(&self)

Graceful shutdown of the shared execution infrastructure.

pub async fn signout(&self, session_id: i64)

pub fn get_session_manager(&self) -> &Arc<GraphSessionManager>

pub fn get_permission_manager(&self) -> &Arc<PermissionManager>

pub fn permission_checker(&self) -> PermissionChecker

pub fn is_auth_disabled(&self) -> bool

Whether authentication is globally disabled.

Returns true when either [auth].enable_authorize = false or [bootstrap].single_user_mode = true. Both flags cause the middleware layer to skip session-id verification and fall through to a default identity so purely-local deployments can operate without a login round-trip.

pub fn auth_config(&self) -> &AuthConfig

Authenticator configuration reference.

pub fn bootstrap_config(&self) -> &BootstrapConfig

Bootstrap configuration reference.

pub fn get_storage_space_id(&self, space_name: &str) -> Option<i64>

pub fn get_stats_manager(&self) -> &Arc<StatsManager>

pub fn sync_api(&self) -> Option<&Arc<SyncApi>>

pub fn query_manager(&self) -> Arc<QueryManager>

Shared process-level query manager.

pub async fn list_sessions(&self) -> Vec<SessionInfo>

Obtain the session list (SHOW SESSIONS)

pub async fn get_session_info(&self, session_id: i64) -> Option<SessionInfo>

Obtain detailed information about the specified session.

pub async fn kill_session( &self, session_id: i64, current_user: &str, ) -> SessionResult<()>

Terminate the session (KILL SESSION)

pub fn kill_query(&self, session_id: i64, query_id: u32) -> SessionResult<()>

Terminate the query (KILL QUERY)

pub fn list_users_detailed(&self) -> Vec<UserDetail>

List users with display role, enablement status and last login time.

pub fn admin_create_user( &self, caller: &str, username: &str, password: &str, ) -> Result<(), String>

Create a user through the admin channel.

pub async fn admin_reset_password( &self, caller: &str, caller_session_id: Option<i64>, username: &str, new_password: &str, ) -> Result<(), String>

Reset a password through the admin channel without old-password check.

except_session_id keeps the caller’s own session alive while every other session of the target account is invalidated.

pub async fn admin_set_user_enabled( &self, caller: &str, caller_session_id: Option<i64>, username: &str, enabled: bool, ) -> Result<(), String>

Enable or disable a user; disabling evicts existing sessions.

pub async fn admin_drop_user( &self, caller: &str, username: &str, ) -> Result<(), String>

Drop a user and clean roles plus sessions.

pub fn admin_grant_role( &self, caller: &str, username: &str, space: &str, role_name: &str, ) -> Result<(), String>

Grant a role with dual write to storage and permission state.

pub fn admin_revoke_role( &self, caller: &str, username: &str, space: &str, ) -> Result<(), String>

Revoke a role with dual write to storage and permission state.

pub fn sync_role_from_storage(&self, username: &str)

Sync query-channel role writes into permission state.

Storage remains the source of truth; this keeps the in-memory permission map consistent when GRANT/REVOKE arrive via queries.

impl<S: StorageClient + StorageSchemaContextOps + StorageSyncContextOps + StorageOperationContextOps + Clone + 'static> GraphService<S>

pub async fn execute_stream( &self, session_id: i64, stmt: &str, ) -> Result<StreamingQueryResult, GraphServiceError>

Execute a query and return a StreamingQueryResult for chunk-at-a-time consumption.

pub async fn execute_stream_with_params( &self, session_id: i64, stmt: &str, parameters: Option<HashMap<String, Value>>, session_variables: Option<HashMap<String, Value>>, ) -> Result<StreamingQueryResult, GraphServiceError>

Execute a query with caller-supplied bindings and return a streaming handle.