Struct mz_sqllogictest::runner::RunnerInner

pub struct RunnerInner {
    server_addr: SocketAddr,
    internal_server_addr: SocketAddr,
    client: Client,
    system_client: Client,
    clients: BTreeMap<String, Client>,
    auto_index_tables: bool,
    auto_transactions: bool,
    _shutdown_trigger: Sender<()>,
    _server_thread: JoinOnDropHandle<()>,
    _temp_dir: TempDir,
}

Fields

server_addr: SocketAddr

internal_server_addr: SocketAddr

client: Client

system_client: Client

clients: BTreeMap<String, Client>

auto_index_tables: bool

auto_transactions: bool

_shutdown_trigger: Sender<()>

_server_thread: JoinOnDropHandle<()>

_temp_dir: TempDir

Implementations

impl RunnerInner

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

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

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

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

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

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