You are an expert in writing code in many different languages. Your goal is to perform code completion for the following code, keeping in mind the rest of the code and the file meta data.
    Metadata details:
    filename: main.rs
    path of file: ./repos/fluvio/crates/fluvio-test/src
    
    the code of the file until where you have to start completion: use std::collections::HashMap;
use std::panic::AssertUnwindSafe;
use std::process::{exit, self};
use std::sync::Arc;
use std::sync::atomic::{AtomicBool, Ordering};
use std::thread;
use std::time::{SystemTime, Duration};

use indicatif::{ProgressBar, ProgressStyle};
use clap::Parser;

use fluvio::Fluvio;
use fluvio_test_util::test_meta
    
fn main() {
    let option = BaseCli::parse();

    debug!("{:?}", option);

    let test_name = option.environment.test_name.clone();

    // Get test from inventory
    let test_meta = FluvioTestMeta::from_name(test_name.clone())
        .expect("StructOpt should have caught this error");

    let mut subcommand = vec![test_name];

    if let Some(TestCli::Args(args)) = option.test_cmd_args {
        // Add the args to the subcommand
        subcommand.extend(args);
    }

    // We want to get a TestOption compatible struct back
    let test_opt: Box<dyn TestOption> = (test_meta.validate_fn)(subcommand);

    println!("Start running fluvio test runner");
    fluvio_future::subscriber::init_logger();

    // Test connecting to a cluster
    // Deploy a cluster if requested
    cluster_setup(&option.environment).expect("Failed to connect to a cluster");

    // Check on test requirements before running the test
    if !TestDriver::is_env_acceptable(
        &(test_meta.requirements)(),
        &TestCase::new(option.environment.clone(), test_opt.clone()),
    ) {
        exit(-1);
    }

    let test_result = run_test(option.environment.clone(), test_opt, test_meta);

    cluster_cleanup(option.environment);
    println!("{test_result}");

    if test_result.success {
        exit(0)
    } else {
        exit(-1)
    }
}