Struct AgentStatusSnapshot 

pub struct AgentStatusSnapshot {

    pub agent_id: String,
    pub model_name: String,
    pub provider_id: String,
    pub nats_connected: bool,
    pub current_job: Option<String>,
    pub current_round: Option<u32>,
    pub current_phase: Option<String>,
    pub uptime_secs: u64,
    pub tasks_completed: u64,
    pub tasks_failed: u64,
    pub recent_tasks: VecDeque<TaskLogEntry>,
    pub scratchpad_keys: u64,
    pub event_log: VecDeque<EventLogEntry>,
    pub is_paused: bool,
    pub buffered_count: u32,
    pub error_rate: f32,
    pub recent_scores: VecDeque<ScoreEntry>,
    pub mean_score: Option<f32>,
    pub score_std_dev: Option<f32>,
    pub is_flagged: bool,
    pub flag_reason: Option<String>,
}

Real-time snapshot of agent state for operator monitoring.

Fields

agent_id: String

model_name: String

provider_id: String

nats_connected: bool

current_job: Option<String>

current_round: Option<u32>

current_phase: Option<String>

Current deliberation phase: "propose", "evaluate", or null.

uptime_secs: u64

tasks_completed: u64

tasks_failed: u64

recent_tasks: VecDeque<TaskLogEntry>

scratchpad_keys: u64

event_log: VecDeque<EventLogEntry>

Chronological event log for the dashboard event stream.

is_paused: bool

Whether the agent is paused (HITL control plane).

buffered_count: u32

Number of responses currently held in the HITL buffer.

error_rate: f32

Rolling error rate: tasks_failed / (tasks_completed + tasks_failed).

recent_scores: VecDeque<ScoreEntry>

Recent peer evaluation scores received from the orchestrator. Primary divergence indicator — consistently low scores flag a problem.

mean_score: Option<f32>

Rolling mean of recent_scores. None if no scores received yet.

score_std_dev: Option<f32>

Standard deviation of recent scores — higher values indicate divergence.

is_flagged: bool

Whether the agent is flagged for operator attention.

flag_reason: Option<String>

Human-readable reason why the agent is flagged.

Implementations

impl AgentStatusSnapshot

pub fn new(agent_id: String, model_name: String, provider_id: String) -> Self

Create a new snapshot with identity fields populated.

pub fn push_task(&mut self, entry: TaskLogEntry)

Record a completed task. Trims the log to MAX_RECENT_TASKS.

pub fn push_score(&mut self, entry: ScoreEntry)

Record a peer evaluation score and update mean_score, score_std_dev, and flagging state.

pub fn check_flags(&mut self)

Evaluate flagging conditions based on recent score history.

Scores are signed QV sums (Σ score_q_s): positive = endorsed, negative = rejected. Thresholds are calibrated for this range.

• Rejected: Recent 3-score average < −0.3 → flagged.
• High divergence: Score std_dev > 1.5 → flagged.
• Flags are cleared when conditions no longer apply.

pub fn push_event( &mut self, event_type: &str, job_id: Option<&str>, detail: &str, )

Append a lifecycle event to the event stream log.

Trait Implementations

impl Clone for AgentStatusSnapshot

fn clone(&self) -> AgentStatusSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ComposeSchema for AgentStatusSnapshot

fn compose(generics: Vec<RefOr<Schema>>) -> RefOr<Schema>

impl Debug for AgentStatusSnapshot

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

Formats the value using the given formatter.

impl Serialize for AgentStatusSnapshot

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl ToSchema for AgentStatusSnapshot

fn name() -> Cow<'static, str>

Return name of the schema.

fn schemas(schemas: &mut Vec<(String, RefOr<Schema>)>)

Implement reference utoipa::openapi::schema::Schemas for this type.