Struct Env

pub struct Env {
    sqlness_home: PathBuf,
    server_addrs: ServerAddr,
    wal: WalConfig,
    bins_dir: Arc<Mutex<Option<PathBuf>>>,
    versioned_bins_dirs: Arc<Mutex<HashMap<String, PathBuf>>>,
    pull_version_on_need: bool,
    store_config: StoreConfig,
}

Fields

sqlness_home: PathBuf

server_addrs: ServerAddr

wal: WalConfig

bins_dir: Arc<Mutex<Option<PathBuf>>>

The path to the directory that contains the pre-built GreptimeDB binary. When running in CI, this is expected to be set. If not set, this runner will build the GreptimeDB binary itself when needed, and set this field by then.

versioned_bins_dirs: Arc<Mutex<HashMap<String, PathBuf>>>

The path to the directory that contains the old pre-built GreptimeDB binaries.

pull_version_on_need: bool

Pull different versions of GreptimeDB on need.

store_config: StoreConfig

Store address for metasrv metadata

Implementations

impl Env

pub fn new( data_home: PathBuf, server_addrs: ServerAddr, wal: WalConfig, pull_version_on_need: bool, bins_dir: Option<PathBuf>, store_config: StoreConfig, ) -> Self

async fn start_standalone(&self, id: usize) -> GreptimeDB

async fn start_distributed(&self, id: usize) -> GreptimeDB

async fn create_pg_client(&self, pg_server_addr: &str) -> PgClient

async fn create_mysql_client(&self, mysql_server_addr: &str) -> MySqlClient

async fn connect_db(&self, server_addr: &ServerAddr, id: usize) -> GreptimeDB

fn stop_server(process: &mut Child)

async fn start_server( &self, mode: ServerMode, db_ctx: &GreptimeDBContext, id: usize, truncate_log: bool, ) -> Child

async fn restart_server(&self, db: &GreptimeDB, is_full_restart: bool)

stop and restart the server process

fn setup_wal(&self)

Setup kafka wal cluster if needed. The counterpart is in GreptimeDB::stop.

fn setup_etcd(&self)

Setup etcd if needed.

fn setup_pg(&self)

Setup PostgreSql if needed.

async fn setup_mysql(&self)

Setup MySql if needed.

fn build_db(&self)

Build the DB with cargo build --bin greptime

Trait Implementations

impl Clone for Env

fn clone(&self) -> Env

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl EnvController for Env

fn stop<'life0, 'life1, 'async_trait>( &'life0 self, _mode: &'life1 str, database: Self::DB, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Stop one [Database].

type DB = GreptimeDB

fn start<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, mode: &'life1 str, id: usize, _config: Option<&'life2 Path>, ) -> Pin<Box<dyn Future<Output = Self::DB> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Start a [Database] to run test queries.