Struct LocalFrontend

pub struct LocalFrontend {
    pub opts: FrontendOpts,
    env: FrontendEnv,
}

An embedded frontend without starting meta and without starting frontend as a tcp server.

Fields

opts: FrontendOpts

env: FrontendEnv

Implementations

impl LocalFrontend

pub async fn new(opts: FrontendOpts) -> Self

pub async fn run_sql( &self, sql: impl Into<String>, ) -> Result<RwPgResponse, Box<dyn Error + Send + Sync>>

pub async fn run_sql_with_session( &self, session_ref: Arc<SessionImpl>, sql: impl Into<String>, ) -> Result<RwPgResponse, Box<dyn Error + Send + Sync>>

pub async fn run_user_sql( &self, sql: impl Into<String>, database: String, user_name: String, user_id: u32, ) -> Result<RwPgResponse, Box<dyn Error + Send + Sync>>

pub async fn query_formatted_result( &self, sql: impl Into<String>, ) -> Vec<String>

pub async fn get_explain_output(&self, sql: impl Into<String>) -> String

pub fn session_ref(&self) -> Arc<SessionImpl>

Creates a new session

pub fn session_user_ref( &self, database: String, user_name: String, user_id: u32, ) -> Arc<SessionImpl>

Trait Implementations

impl SessionManager for LocalFrontend

type Session = SessionImpl

fn create_dummy_session( &self, _database_id: u32, _user_name: u32, ) -> Result<Arc<Self::Session>, BoxedError>

In the process of auto schema change, we need a dummy session to access catalog information in frontend and build a replace plan for the table.

fn connect( &self, _database: &str, _user_name: &str, _peer_addr: AddressRef, ) -> Result<Arc<Self::Session>, BoxedError>

fn cancel_queries_in_session(&self, _session_id: SessionId)

fn cancel_creating_jobs_in_session(&self, _session_id: SessionId)

fn end_session(&self, _session: &Self::Session)

fn shutdown(&self) -> impl Future<Output = ()> + Send

Run some cleanup tasks before the server shutdown.