Struct mz_sqllogictest::runner::RunnerInner

pub struct RunnerInner<'a> {

    server_addr: SocketAddr,
    internal_server_addr: SocketAddr,
    internal_http_server_addr: SocketAddr,
    client: Client,
    system_client: Client,
    clients: BTreeMap<String, Client>,
    auto_index_tables: bool,
    auto_index_selects: bool,
    auto_transactions: bool,
    enable_table_keys: bool,
    verbosity: usize,
    stdout: &'a dyn WriteFmt,
    _shutdown_trigger: Sender<()>,
    _server_thread: JoinOnDropHandle<()>,
    _temp_dir: TempDir,
}

Fields

server_addr: SocketAddr

internal_server_addr: SocketAddr

internal_http_server_addr: SocketAddr

client: Client

system_client: Client

clients: BTreeMap<String, Client>

auto_index_tables: bool

auto_index_selects: bool

auto_transactions: bool

enable_table_keys: bool

verbosity: usize

stdout: &'a dyn WriteFmt

_shutdown_trigger: Sender<()>

_server_thread: JoinOnDropHandle<()>

_temp_dir: TempDir

Implementations

impl<'a> RunnerInner<'a>

pub async fn start(config: &RunConfig<'a>) -> Result<RunnerInner<'a>, Error>

async fn ensure_fixed_features(&self) -> Result<(), Error>

Set features that should be enabled regardless of whether reset-server was called. These features may be set conditionally depending on the run configuration.

async fn run_record<'r>( &mut self, record: &'r Record<'r>, in_transaction: &mut bool ) -> Result<Outcome<'r>, Error>

async fn run_statement<'r>( &self, expected_error: Option<&'r str>, expected_rows_affected: Option<u64>, sql: &'r str, location: Location ) -> Result<Outcome<'r>, Error>

async fn prepare_query<'r>( &self, sql: &str, output: &'r Result<QueryOutput<'_>, &'r str>, location: Location, in_transaction: &mut bool ) -> Result<PrepareQueryOutcome<'r>, Error>

async fn execute_query<'r>( &self, sql: &str, output: &'r Result<QueryOutput<'_>, &'r str>, location: Location ) -> Result<Outcome<'r>, Error>

async fn execute_view_inner<'r>( &self, sql: &str, output: &'r Result<QueryOutput<'_>, &'r str>, location: Location ) -> Result<Option<Outcome<'r>>, Error>

async fn execute_view<'r>( &self, sql: &str, num_attributes: Option<usize>, output: &'r Result<QueryOutput<'_>, &'r str>, location: Location ) -> Result<Outcome<'r>, Error>

async fn run_query<'r>( &self, sql: &'r str, output: &'r Result<QueryOutput<'_>, &'r str>, location: Location, in_transaction: &mut bool ) -> Result<Outcome<'r>, Error>

async fn get_conn(&mut self, name: Option<&str>, user: Option<&str>) -> &Client

async fn run_simple<'r>( &mut self, conn: Option<&'r str>, user: Option<&'r str>, sql: &'r str, output: &'r Output, location: Location ) -> Result<Outcome<'r>, Error>

async fn check_catalog(&self) -> Result<(), Error>