Enum AgentResponse 

pub enum AgentResponse {
    ReconcileResult(ReconcileReport),
    NodeInfo(NodeInfo),
    NodeStats(NodeStats),
    TenantList(Vec<String>),
    InstanceList(Vec<InstanceState>),
    WakeResult {
        success: bool,
    },
    InstanceActionResult {
        success: bool,
        new_status: String,
        error: Option<String>,
    },
    SandboxResult {
        success: bool,
        response: Value,
        error: Option<String>,
    },
    Error {
        code: u16,
        message: String,
    },
    DeploymentStatus {
        pool_id: String,
        current_revision: String,
        target_revision: Option<String>,
        strategy: UpdateStrategy,
        phase: DeploymentPhase,
        instances_updated: u32,
        instances_pending: u32,
        canary_health: Option<f64>,
        paused: bool,
        errors: Vec<String>,
    },
    DeploymentControlResult {
        success: bool,
        pool_id: String,
        new_phase: String,
        message: String,
    },
    BatchActionResult {
        results: Vec<BatchActionItemResult>,
        total: u32,
        succeeded: u32,
        failed: u32,
    },
    PoolActionResult {
        success: bool,
        pool_id: String,
        instances_affected: u32,
        errors: Vec<String>,
    },
    Metrics(MetricsSnapshot),
    AuditLog {
        entries: Vec<AuditEntry>,
        total_count: u32,
    },
    HealthStatus {
        instances: Vec<InstanceHealthReport>,
        unhealthy_count: u32,
        degraded_count: u32,
    },
    ReconcileHistory {
        runs: Vec<ReconcileHistoryEntry>,
    },
    StateDump(Box<StateDumpContent>),
    SecretsUpdateResult {
        success: bool,
        tenant_id: String,
        instances_reloaded: u32,
        errors: Vec<String>,
    },
    ConfigUpdateResult {
        success: bool,
        pool_id: String,
        instances_updated: u32,
        errors: Vec<String>,
    },
    SyncEventsResult {
        events: Vec<Value>,
        current_sequence: u64,
    },
}

Strongly typed response returned over QUIC streams.

Variants

ReconcileResult(ReconcileReport)

Result of a reconcile pass.

NodeInfo(NodeInfo)

Node info.

NodeStats(NodeStats)

Aggregate node stats.

TenantList(Vec<String>)

List of tenant IDs.

InstanceList(Vec<InstanceState>)

List of instance states.

WakeResult

Result of a wake operation.

Fields

success: bool

InstanceActionResult

Result of an imperative instance action.

Fields

success: bool

new_status: String

error: Option<String>

SandboxResult

Result of a sandbox operation (filesystem, exec, logs).

Fields

success: bool

response: Value

error: Option<String>

Error

Error response.

Fields

code: u16

message: String

DeploymentStatus

Deployment status with rollout progress.

Fields

pool_id: String

current_revision: String

target_revision: Option<String>

strategy: UpdateStrategy

phase: DeploymentPhase

instances_updated: u32

instances_pending: u32

canary_health: Option<f64>

paused: bool

errors: Vec<String>

DeploymentControlResult

Result of pause/resume/rollback operations.

Fields

success: bool

pool_id: String

new_phase: String

message: String

BatchActionResult

Result of batch instance operations.

Fields

results: Vec<BatchActionItemResult>

total: u32

succeeded: u32

failed: u32

PoolActionResult

Result of pool-level action.

Fields

success: bool

pool_id: String

instances_affected: u32

errors: Vec<String>

Metrics(MetricsSnapshot)

Metrics snapshot.

AuditLog

Audit log entries.

Fields

entries: Vec<AuditEntry>

total_count: u32

HealthStatus

Health status report for instances.

Fields

instances: Vec<InstanceHealthReport>

unhealthy_count: u32

degraded_count: u32

ReconcileHistory

Reconciliation history.

Fields

runs: Vec<ReconcileHistoryEntry>

StateDump(Box<StateDumpContent>)

Complete node state dump (boxed due to size).

SecretsUpdateResult

Result of secrets update.

Fields

success: bool

tenant_id: String

instances_reloaded: u32

errors: Vec<String>

ConfigUpdateResult

Result of config update.

Fields

success: bool

pool_id: String

instances_updated: u32

errors: Vec<String>

SyncEventsResult

Incremental state events in response to SyncEvents.

Fields

events: Vec<Value>

Events with sequence > the requested since value.

current_sequence: u64

Current sequence number at the coordinator.

Trait Implementations

impl Clone for AgentResponse

fn clone(&self) -> AgentResponse

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AgentResponse

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AgentResponse

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AgentResponse

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

where __S: Serializer,

Serialize this value into the given Serde serializer.