Enum Request 

pub enum Request {
    InitContext {
        protocol_version: u32,
        repo_path: String,
        python_path: Option<String>,
        execution_mode: Option<String>,
    },
    Collect {
        context_id: String,
        force: bool,
    },
    Run {
        context_id: String,
        node_ids: Vec<String>,
        workers: Option<u32>,
        maxfail: Option<u32>,
    },
    List {
        context_id: String,
        keyword: Option<String>,
        marker: Option<String>,
    },
    GetInventory {
        context_id: String,
    },
    GetWorkerStatus {
        context_id: String,
    },
    ConfigureWorkers {
        context_id: String,
        num_workers: u32,
    },
    Shutdown {
        context_id: Option<String>,
    },
    Ping,
    RunStream {
        context_id: String,
        node_ids: Vec<String>,
        workers: Option<u32>,
        maxfail: Option<u32>,
    },
    GetRunProgress {
        context_id: String,
        run_id: String,
    },
    GetFlakinessReport {
        context_id: String,
    },
    GetTestFlakiness {
        context_id: String,
        node_id: String,
    },
    ConfigureRerun {
        context_id: String,
        enabled: bool,
        max_reruns: u32,
        only_flaky: bool,
        delay_ms: u32,
    },
    GetRerunConfig {
        context_id: String,
    },
    RunWithRerun {
        context_id: String,
        node_ids: Vec<String>,
        workers: Option<u32>,
        maxfail: Option<u32>,
    },
    ConfigureFixtureReuse {
        context_id: String,
        enabled: bool,
        max_age_seconds: f64,
        teardown_on_conftest_change: bool,
    },
    GetFixtureConfig {
        context_id: String,
    },
    GetSessionStatus {
        context_id: String,
    },
    GetShard {
        context_id: String,
        node_ids: Vec<String>,
        shard_index: u32,
        total_shards: u32,
        strategy: String,
    },
    GetShardInfo {
        context_id: String,
        node_ids: Vec<String>,
        total_shards: u32,
        strategy: String,
    },
}

Re-export commonly used types Commands sent from CLI to daemon.

Variants

InitContext

Initialize a repository context within the daemon.

Fields

protocol_version: u32

Protocol version for compatibility checking.

repo_path: String

Absolute path to the repository root.

python_path: Option<String>

Optional path to Python interpreter.

execution_mode: Option<String>

Execution mode: “embedded”, “subprocess”, or “auto”.

Collect

Collect tests for a repository context.

Fields

context_id: String

Context identifier returned from InitContext.

force: bool

Force full re-collection even if cache is valid.

Run

Run a set of tests.

Fields

context_id: String

Context identifier.

node_ids: Vec<String>

List of test node IDs to run.

workers: Option<u32>

Number of parallel workers (None = auto).

maxfail: Option<u32>

Stop after N failures.

List

List tests matching filters (without running).

Fields

context_id: String

Context identifier.

keyword: Option<String>

Keyword expression filter.

marker: Option<String>

Marker expression filter.

GetInventory

Get detailed inventory with full test metadata.

Fields

context_id: String

Context identifier.

GetWorkerStatus

Get worker pool status.

Fields

context_id: String

Context identifier.

ConfigureWorkers

Configure worker pool.

Fields

context_id: String

Context identifier.

num_workers: u32

Number of workers to maintain.

Shutdown

Shutdown the daemon or a specific context.

Fields

context_id: Option<String>

If Some, shutdown only this context. If None, shutdown entire daemon.

Ping

Health check / ping.

RunStream

Start a streaming run (returns run_id, results come via GetRunProgress).

Fields

context_id: String

Context identifier.

node_ids: Vec<String>

List of test node IDs to run.

workers: Option<u32>

Number of parallel workers (None = auto).

maxfail: Option<u32>

Stop after N failures.

GetRunProgress

Get progress and results from a streaming run.

Fields

context_id: String

Context identifier.

run_id: String

Run identifier from RunStream response.

GetFlakinessReport

Get flakiness report for all tracked tests.

Fields

context_id: String

Context identifier.

GetTestFlakiness

Get flakiness info for a specific test.

Fields

context_id: String

Context identifier.

node_id: String

Test node ID.

ConfigureRerun

Configure auto-rerun behavior.

Fields

context_id: String

Context identifier.

enabled: bool

Enable auto-rerun.

max_reruns: u32

Maximum reruns per test.

only_flaky: bool

Only rerun known flaky tests.

delay_ms: u32

Delay between reruns in milliseconds.

GetRerunConfig

Get current rerun configuration.

Fields

context_id: String

Context identifier.

RunWithRerun

Run tests with auto-rerun enabled.

Fields

context_id: String

Context identifier.

node_ids: Vec<String>

List of test node IDs to run.

workers: Option<u32>

Number of parallel workers (None = auto).

maxfail: Option<u32>

Stop after N failures.

ConfigureFixtureReuse

Configure session fixture reuse.

Fields

context_id: String

Context identifier.

enabled: bool

Enable fixture reuse.

max_age_seconds: f64

Max fixture age in seconds.

teardown_on_conftest_change: bool

Teardown on conftest.py changes.

GetFixtureConfig

Get fixture configuration.

Fields

context_id: String

Context identifier.

GetSessionStatus

Get session status.

Fields

context_id: String

Context identifier.

GetShard

Get tests for a specific shard.

Fields

context_id: String

Context identifier.

node_ids: Vec<String>

Tests to shard (empty = all inventory).

shard_index: u32

This shard’s index (0-based).

total_shards: u32

Total number of shards.

strategy: String

Sharding strategy.

GetShardInfo

Get sharding distribution info.

Fields

context_id: String

Context identifier.

node_ids: Vec<String>

Tests to shard (empty = all inventory).

total_shards: u32

Total number of shards.

strategy: String

Sharding strategy.

Trait Implementations

impl Clone for Request

fn clone(&self) -> Request

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Request

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Request

fn deserialize<__D>( __deserializer: __D, ) -> Result<Request, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for Request

fn eq(&self, other: &Request) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for Request

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Request