Struct ExecutorBuilder

pub struct ExecutorBuilder {
    pub config_path: Option<String>,
    pub config_format: Option<ConfigFormat>,
    pub ns3_path: Option<String>,
    pub task_concurrent: Option<usize>,
    pub retry_limit: Option<u32>,
}

Fields

config_path: Option<String>

config_format: Option<ConfigFormat>

ns3_path: Option<String>

task_concurrent: Option<usize>

retry_limit: Option<u32>

Implementations

impl ExecutorBuilder

pub fn new() -> Self

Examples found in repository

examples/simple.rs (line 67)

async fn main() {
    // ========== Use toml format as the config file ==========
    // Use ExecutorBuilder to build your executor.
    let mut exe: Executor<MyConfig, MyParam> = ExecutorBuilder::new()
        .config_path("config.toml")
        .config_format(ConfigFormat::Toml)
        .ns3_path("ns-allinone-3.33/ns-3.33/")
        .build()
        .unwrap();

    // Run your executor.
    let _ = exe.execute().await.unwrap();

    // Collect your results.
    let outputs = exe.get_outputs().to_owned();

    // Here I just print all the results, you can do whatever you want with them here.
    for (_, output) in outputs {
        for task in output {
            println!("{}", task.stderr);
        }
    }

    // ========== Use ron format as the config file ==========
    // Use ExecutorBuilder to build your executor.
    let mut exe: Executor<MyConfig, MyParam> = ExecutorBuilder::new()
        .config_path("config.ron")
        .config_format(ConfigFormat::Ron)
        .ns3_path("ns-allinone-3.33/ns-3.33/")
        .task_concurrent(4)
        .retry_limit(2)
        .build()
        .unwrap();

    // Run your executor.
    let _ = exe.execute().await.unwrap();

    // Collect your results.
    let outputs = exe.get_outputs().to_owned();

    // Here I just print all the results, you can do whatever you want with them here.
    for (_, output) in outputs {
        for task in output {
            println!("{}", task.stderr);
        }
    }
}

pub fn config_path(self, config_path: &str) -> Self

Examples found in repository

examples/simple.rs (line 68)

async fn main() {
    // ========== Use toml format as the config file ==========
    // Use ExecutorBuilder to build your executor.
    let mut exe: Executor<MyConfig, MyParam> = ExecutorBuilder::new()
        .config_path("config.toml")
        .config_format(ConfigFormat::Toml)
        .ns3_path("ns-allinone-3.33/ns-3.33/")
        .build()
        .unwrap();

    // Run your executor.
    let _ = exe.execute().await.unwrap();

    // Collect your results.
    let outputs = exe.get_outputs().to_owned();

    // Here I just print all the results, you can do whatever you want with them here.
    for (_, output) in outputs {
        for task in output {
            println!("{}", task.stderr);
        }
    }

    // ========== Use ron format as the config file ==========
    // Use ExecutorBuilder to build your executor.
    let mut exe: Executor<MyConfig, MyParam> = ExecutorBuilder::new()
        .config_path("config.ron")
        .config_format(ConfigFormat::Ron)
        .ns3_path("ns-allinone-3.33/ns-3.33/")
        .task_concurrent(4)
        .retry_limit(2)
        .build()
        .unwrap();

    // Run your executor.
    let _ = exe.execute().await.unwrap();

    // Collect your results.
    let outputs = exe.get_outputs().to_owned();

    // Here I just print all the results, you can do whatever you want with them here.
    for (_, output) in outputs {
        for task in output {
            println!("{}", task.stderr);
        }
    }
}

pub fn config_format(self, config_format: ConfigFormat) -> Self

Examples found in repository

examples/simple.rs (line 69)

async fn main() {
    // ========== Use toml format as the config file ==========
    // Use ExecutorBuilder to build your executor.
    let mut exe: Executor<MyConfig, MyParam> = ExecutorBuilder::new()
        .config_path("config.toml")
        .config_format(ConfigFormat::Toml)
        .ns3_path("ns-allinone-3.33/ns-3.33/")
        .build()
        .unwrap();

    // Run your executor.
    let _ = exe.execute().await.unwrap();

    // Collect your results.
    let outputs = exe.get_outputs().to_owned();

    // Here I just print all the results, you can do whatever you want with them here.
    for (_, output) in outputs {
        for task in output {
            println!("{}", task.stderr);
        }
    }

    // ========== Use ron format as the config file ==========
    // Use ExecutorBuilder to build your executor.
    let mut exe: Executor<MyConfig, MyParam> = ExecutorBuilder::new()
        .config_path("config.ron")
        .config_format(ConfigFormat::Ron)
        .ns3_path("ns-allinone-3.33/ns-3.33/")
        .task_concurrent(4)
        .retry_limit(2)
        .build()
        .unwrap();

    // Run your executor.
    let _ = exe.execute().await.unwrap();

    // Collect your results.
    let outputs = exe.get_outputs().to_owned();

    // Here I just print all the results, you can do whatever you want with them here.
    for (_, output) in outputs {
        for task in output {
            println!("{}", task.stderr);
        }
    }
}

pub fn ns3_path(self, ns3_path: &str) -> Self

Examples found in repository

examples/simple.rs (line 70)

async fn main() {
    // ========== Use toml format as the config file ==========
    // Use ExecutorBuilder to build your executor.
    let mut exe: Executor<MyConfig, MyParam> = ExecutorBuilder::new()
        .config_path("config.toml")
        .config_format(ConfigFormat::Toml)
        .ns3_path("ns-allinone-3.33/ns-3.33/")
        .build()
        .unwrap();

    // Run your executor.
    let _ = exe.execute().await.unwrap();

    // Collect your results.
    let outputs = exe.get_outputs().to_owned();

    // Here I just print all the results, you can do whatever you want with them here.
    for (_, output) in outputs {
        for task in output {
            println!("{}", task.stderr);
        }
    }

    // ========== Use ron format as the config file ==========
    // Use ExecutorBuilder to build your executor.
    let mut exe: Executor<MyConfig, MyParam> = ExecutorBuilder::new()
        .config_path("config.ron")
        .config_format(ConfigFormat::Ron)
        .ns3_path("ns-allinone-3.33/ns-3.33/")
        .task_concurrent(4)
        .retry_limit(2)
        .build()
        .unwrap();

    // Run your executor.
    let _ = exe.execute().await.unwrap();

    // Collect your results.
    let outputs = exe.get_outputs().to_owned();

    // Here I just print all the results, you can do whatever you want with them here.
    for (_, output) in outputs {
        for task in output {
            println!("{}", task.stderr);
        }
    }
}

pub fn task_concurrent(self, task_concurrent: usize) -> Self

Examples found in repository

examples/simple.rs (line 93)

async fn main() {
    // ========== Use toml format as the config file ==========
    // Use ExecutorBuilder to build your executor.
    let mut exe: Executor<MyConfig, MyParam> = ExecutorBuilder::new()
        .config_path("config.toml")
        .config_format(ConfigFormat::Toml)
        .ns3_path("ns-allinone-3.33/ns-3.33/")
        .build()
        .unwrap();

    // Run your executor.
    let _ = exe.execute().await.unwrap();

    // Collect your results.
    let outputs = exe.get_outputs().to_owned();

    // Here I just print all the results, you can do whatever you want with them here.
    for (_, output) in outputs {
        for task in output {
            println!("{}", task.stderr);
        }
    }

    // ========== Use ron format as the config file ==========
    // Use ExecutorBuilder to build your executor.
    let mut exe: Executor<MyConfig, MyParam> = ExecutorBuilder::new()
        .config_path("config.ron")
        .config_format(ConfigFormat::Ron)
        .ns3_path("ns-allinone-3.33/ns-3.33/")
        .task_concurrent(4)
        .retry_limit(2)
        .build()
        .unwrap();

    // Run your executor.
    let _ = exe.execute().await.unwrap();

    // Collect your results.
    let outputs = exe.get_outputs().to_owned();

    // Here I just print all the results, you can do whatever you want with them here.
    for (_, output) in outputs {
        for task in output {
            println!("{}", task.stderr);
        }
    }
}

pub fn retry_limit(self, retry_limit: u32) -> Self

Examples found in repository

examples/simple.rs (line 94)

async fn main() {
    // ========== Use toml format as the config file ==========
    // Use ExecutorBuilder to build your executor.
    let mut exe: Executor<MyConfig, MyParam> = ExecutorBuilder::new()
        .config_path("config.toml")
        .config_format(ConfigFormat::Toml)
        .ns3_path("ns-allinone-3.33/ns-3.33/")
        .build()
        .unwrap();

    // Run your executor.
    let _ = exe.execute().await.unwrap();

    // Collect your results.
    let outputs = exe.get_outputs().to_owned();

    // Here I just print all the results, you can do whatever you want with them here.
    for (_, output) in outputs {
        for task in output {
            println!("{}", task.stderr);
        }
    }

    // ========== Use ron format as the config file ==========
    // Use ExecutorBuilder to build your executor.
    let mut exe: Executor<MyConfig, MyParam> = ExecutorBuilder::new()
        .config_path("config.ron")
        .config_format(ConfigFormat::Ron)
        .ns3_path("ns-allinone-3.33/ns-3.33/")
        .task_concurrent(4)
        .retry_limit(2)
        .build()
        .unwrap();

    // Run your executor.
    let _ = exe.execute().await.unwrap();

    // Collect your results.
    let outputs = exe.get_outputs().to_owned();

    // Here I just print all the results, you can do whatever you want with them here.
    for (_, output) in outputs {
        for task in output {
            println!("{}", task.stderr);
        }
    }
}

pub fn build<T: Default + BuildParam<P> + DeserializeOwned, P: BuildCmd>( self, ) -> Result<Executor<T, P>, Error>

Examples found in repository

examples/simple.rs (line 71)

async fn main() {
    // ========== Use toml format as the config file ==========
    // Use ExecutorBuilder to build your executor.
    let mut exe: Executor<MyConfig, MyParam> = ExecutorBuilder::new()
        .config_path("config.toml")
        .config_format(ConfigFormat::Toml)
        .ns3_path("ns-allinone-3.33/ns-3.33/")
        .build()
        .unwrap();

    // Run your executor.
    let _ = exe.execute().await.unwrap();

    // Collect your results.
    let outputs = exe.get_outputs().to_owned();

    // Here I just print all the results, you can do whatever you want with them here.
    for (_, output) in outputs {
        for task in output {
            println!("{}", task.stderr);
        }
    }

    // ========== Use ron format as the config file ==========
    // Use ExecutorBuilder to build your executor.
    let mut exe: Executor<MyConfig, MyParam> = ExecutorBuilder::new()
        .config_path("config.ron")
        .config_format(ConfigFormat::Ron)
        .ns3_path("ns-allinone-3.33/ns-3.33/")
        .task_concurrent(4)
        .retry_limit(2)
        .build()
        .unwrap();

    // Run your executor.
    let _ = exe.execute().await.unwrap();

    // Collect your results.
    let outputs = exe.get_outputs().to_owned();

    // Here I just print all the results, you can do whatever you want with them here.
    for (_, output) in outputs {
        for task in output {
            println!("{}", task.stderr);
        }
    }
}

Trait Implementations

impl Clone for ExecutorBuilder

fn clone(&self) -> ExecutorBuilder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ExecutorBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ExecutorBuilder

fn default() -> Self

Returns the “default value” for a type.