Enum Response 

pub enum Response {
    ContextReady {
        protocol_version: u32,
        context_id: String,
        inventory_hash: String,
    },
    CollectionComplete {
        node_count: usize,
        duration_ms: u64,
    },
    TestList {
        node_ids: Vec<String>,
    },
    InventoryData {
        hash: String,
        collected_at: u64,
        nodes: Vec<TestNodeInfo>,
    },
    RunComplete {
        total: usize,
        passed: usize,
        failed: usize,
        skipped: usize,
        errors: usize,
        duration_ms: u64,
    },
    WorkerStatus {
        active_workers: u32,
        idle_workers: u32,
        tests_executed: u64,
        avg_test_duration_ms: u64,
    },
    WorkerConfigAck {
        num_workers: u32,
    },
    ShutdownAck,
    Pong,
    RunStarted {
        run_id: String,
        total_tests: usize,
    },
    RunProgress {
        run_id: String,
        total: usize,
        completed: usize,
        running: usize,
        done: bool,
        results: Vec<TestResultInfo>,
    },
    Error {
        code: ErrorCode,
        message: String,
    },
    FlakinessReport {
        flaky_tests: Vec<FlakinessInfo>,
        unstable_tests: Vec<FlakinessInfo>,
        stable_count: usize,
        total_tracked: usize,
    },
    TestFlakiness {
        node_id: String,
        failure_rate: f64,
        is_flaky: bool,
        flaky_streak: u32,
        consecutive_failures: u32,
        consecutive_passes: u32,
        total_runs: u32,
        recent_outcomes: Vec<String>,
    },
    RerunConfig {
        enabled: bool,
        max_reruns: u32,
        only_flaky: bool,
        delay_ms: u32,
    },
    FixtureConfig {
        enabled: bool,
        max_fixture_age_seconds: f64,
        teardown_on_conftest_change: bool,
        teardown_on_test_file_change: bool,
        scopes_to_reuse: Vec<String>,
    },
    SessionStatus {
        session_id: String,
        repo_path: String,
        created_at: f64,
        last_run_at: f64,
        total_runs: u32,
        enabled: bool,
    },
    ShardedTests {
        shard_index: u32,
        total_shards: u32,
        node_ids: Vec<String>,
    },
    ShardInfo {
        strategy: String,
        total_shards: u32,
        total_tests: usize,
        shard_test_counts: Vec<usize>,
        shard_durations_ms: Vec<u64>,
        count_imbalance_percent: f64,
        duration_imbalance_percent: f64,
        estimated_wall_time_ms: u64,
    },
    ConfigAck {
        config_type: String,
        config: Value,
    },
}

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

Variants

ContextReady

Context successfully initialized.

Fields

protocol_version: u32

Protocol version for compatibility checking.

context_id: String

Unique context identifier.

inventory_hash: String

Hash of the current inventory for cache validation.

CollectionComplete

Collection completed.

Fields

node_count: usize

Number of test nodes collected.

duration_ms: u64

Collection duration in milliseconds.

TestList

List of test node IDs matching the query.

Fields

node_ids: Vec<String>

Matching node IDs.

InventoryData

Detailed inventory data.

Fields

hash: String

Inventory hash for cache validation.

collected_at: u64

Collection timestamp (Unix epoch ms).

nodes: Vec<TestNodeInfo>

Test nodes with metadata.

RunComplete

Run completed.

Fields

total: usize

Total tests run.

passed: usize

Tests passed.

failed: usize

Tests failed.

skipped: usize

Tests skipped.

errors: usize

Tests errored.

duration_ms: u64

Total duration in milliseconds.

WorkerStatus

Worker pool status.

Fields

active_workers: u32

Number of active workers.

idle_workers: u32

Number of idle workers.

tests_executed: u64

Total tests executed by pool.

avg_test_duration_ms: u64

Average test duration in milliseconds.

WorkerConfigAck

Worker configuration acknowledged.

Fields

num_workers: u32

New number of workers.

ShutdownAck

Shutdown acknowledged.

Pong

Pong response to ping.

RunStarted

Streaming run started.

Fields

run_id: String

Unique run identifier for polling progress.

total_tests: usize

Total tests to run.

RunProgress

Progress update with any completed test results.

Fields

run_id: String

Run identifier.

total: usize

Total tests in this run.

completed: usize

Tests completed so far.

running: usize

Tests currently running.

done: bool

Whether the run is complete.

results: Vec<TestResultInfo>

Newly completed test results since last poll.

Error

Error response.

Fields

code: ErrorCode

Error category.

message: String

Human-readable error message.

FlakinessReport

Flakiness report for tracked tests.

Fields

flaky_tests: Vec<FlakinessInfo>

Tests identified as flaky.

unstable_tests: Vec<FlakinessInfo>

Tests with some failures but not flaky.

stable_count: usize

Count of stable tests.

total_tracked: usize

Total tests tracked.

TestFlakiness

Flakiness info for a single test.

Fields

node_id: String

Test node ID.

failure_rate: f64

Failure rate (0.0-1.0).

is_flaky: bool

Whether test is considered flaky.

flaky_streak: u32

Number of outcome flips.

consecutive_failures: u32

Consecutive failures.

consecutive_passes: u32

Consecutive passes.

total_runs: u32

Total runs.

recent_outcomes: Vec<String>

Recent outcomes.

RerunConfig

Rerun configuration.

Fields

enabled: bool

Whether enabled.

max_reruns: u32

Max reruns per test.

only_flaky: bool

Only rerun known flaky.

delay_ms: u32

Delay between reruns ms.

FixtureConfig

Fixture configuration.

Fields

enabled: bool

Whether enabled.

max_fixture_age_seconds: f64

Max fixture age seconds.

teardown_on_conftest_change: bool

Teardown on conftest change.

teardown_on_test_file_change: bool

Teardown on test file change.

scopes_to_reuse: Vec<String>

Scopes to reuse.

SessionStatus

Session status.

Fields

session_id: String

Session ID.

repo_path: String

Repo path.

created_at: f64

Creation timestamp.

last_run_at: f64

Last run timestamp.

total_runs: u32

Total runs.

enabled: bool

Whether enabled.

ShardedTests

Tests assigned to a shard.

Fields

shard_index: u32

Shard index.

total_shards: u32

Total shards.

node_ids: Vec<String>

Node IDs in this shard.

ShardInfo

Sharding distribution info.

Fields

strategy: String

Strategy used.

total_shards: u32

Total shards.

total_tests: usize

Total tests.

shard_test_counts: Vec<usize>

Test counts per shard.

shard_durations_ms: Vec<u64>

Duration estimates per shard.

count_imbalance_percent: f64

Count imbalance percentage.

duration_imbalance_percent: f64

Duration imbalance percentage.

estimated_wall_time_ms: u64

Estimated wall time.

ConfigAck

Generic config acknowledgment.

Fields

config_type: String

Config type.

config: Value

The configuration.

Trait Implementations

impl Clone for Response

fn clone(&self) -> Response

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Response

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Response

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for Response

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for Response

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 Response