Enum CtlReply 

pub enum CtlReply {
    Listed {
        agents: Vec<AgentRecord>,
    },
    Spawned {
        id: String,
        endpoint: Endpoint,
    },
    AttachAck {
        endpoint: Endpoint,
    },
    Killed,
    Respawned {
        id: String,
    },
    Removed,
    Status(DaemonStatus),
    ShutdownAck,
    Drained {
        agents: Vec<DrainedAgent>,
    },
    StatusReported,
    Error {
        error: SupervisorError,
    },
}

Control-plane replies.

Variants

Listed

Successful list response.

Fields

agents: Vec<AgentRecord>

Registered agents.

Spawned

Successful spawn.

Fields

id: String

Newly assigned id.

endpoint: Endpoint

Per-agent endpoint the caller can attach to.

AttachAck

Successful attach handshake (the per-agent endpoint is also returned here for backwards-compat with attach <id>).

Fields

endpoint: Endpoint

Per-agent endpoint.

Killed

Successful kill.

Respawned

Successful respawn — new id assigned.

Fields

id: String

New id (old id is removed).

Removed

Successful rm.

Status(DaemonStatus)

Daemon status snapshot.

ShutdownAck

Daemon will shut down once it’s drained.

Drained

Result of a Drain: the agents that were signalled to checkpoint, each with a resume reference (its session directory). Already-terminal agents are not included.

Fields

agents: Vec<DrainedAgent>

One entry per agent drained by this request.

StatusReported

Acknowledged a status report.

Error

An error occurred.

Fields

error: SupervisorError

Structured error variant.

Trait Implementations

impl Clone for CtlReply

fn clone(&self) -> CtlReply

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CtlReply

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CtlReply

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for CtlReply

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.