Struct K6Executor 

pub struct K6Executor { /* private fields */ }

k6 executor

Implementations

impl K6Executor

pub fn new() -> Result<Self>

Create a new k6 executor

pub fn with_local_ips(self, local_ips: impl Into<String>) -> Self

Set the --local-ips value for subsequent k6 invocations. Accepts a comma-joined list of IPs, ranges (10.0.0.1-10.0.0.5), and/or CIDRs (192.168.0.0/24) - same syntax k6 expects.

pub fn with_discard_response_bodies(self, discard: bool) -> Self

Round 56 (#79) — enable K6_DISCARD_RESPONSE_BODIES so k6 does not hold response bodies in memory. Use for plain load runs (status-only checks); do NOT use where the script inspects/extracts response bodies.

pub fn is_k6_installed() -> bool

Check if k6 is installed

pub async fn get_version(&self) -> Result<String>

Get k6 version

pub async fn execute( &self, script_path: &Path, output_dir: Option<&Path>, verbose: bool, ) -> Result<K6Results>

Execute a k6 script.

api_port — when set, overrides k6’s default API server address (localhost:6565) to localhost:<api_port>. This prevents “address already in use” errors when running multiple k6 instances in parallel (e.g., multi-target bench). Pass Some(0) to bind an OS-assigned ephemeral port — the collision-proof choice for parallel runs, since the kernel never hands out a busy port (see the k6 CannotStartRESTAPI / exit-106 fix in parallel_executor). Pass None for single-target runs (uses k6’s default localhost:6565).

pub async fn execute_with_port( &self, script_path: &Path, output_dir: Option<&Path>, verbose: bool, api_port: Option<u16>, ) -> Result<K6Results>

Execute a k6 script with an optional custom API server port.

Trait Implementations

impl Default for K6Executor

fn default() -> Self

Returns the “default value” for a type.