Method runtime_snapshot

core/src/ahp/executor.rs:302–331

Return the current runtime counters observed by AHP.

(&self)

    /// Return the current runtime counters observed by AHP.
    pub fn runtime_snapshot(&self) -> AhpRuntimeSnapshot {
        let active_tools = self.runtime_state.active_tools();
        let pending_actions = self.runtime_state.pending_actions();
        let queue_depth = self.runtime_state.queue_depth();
        let tokens_used = self.runtime_state.tokens_used();
        let total_events_processed = self.total_events.load(Ordering::Relaxed);
        let error_count = self.error_count.load(Ordering::Relaxed) as usize;
        let uptime_ms = self.start_time.elapsed().as_millis() as u64;
        let current_state = if pending_actions > 0 {
            "waiting"
        } else if active_tools > 0 {
            "running_tools"
        } else if self.get_idle_duration_ms() >= self.idle_threshold_ms {
            "idle"
        } else {
            "active"
        }
        .to_string();

        AhpRuntimeSnapshot {
            active_tools,
            pending_actions,
            queue_depth,
            tokens_used,
            total_events_processed,
            error_count,
            uptime_ms,
            current_state,
        }
    }

    /// Get idle duration in milliseconds.
    pub fn get_idle_duration_ms(&self) -> u64 {