Struct WorkerProbeBackend 

pub struct WorkerProbeBackend {
    pub delay_ms: u64,
    pub in_flight: Option<Arc<AtomicUsize>>,
    pub peak_in_flight: Option<Arc<AtomicUsize>>,
    /* private fields */
}

Builds a filtered worker executor and probes tool/path access via the real SecurityPolicy and tool registry path (no model call).

Fields

delay_ms: u64

in_flight: Option<Arc<AtomicUsize>>

peak_in_flight: Option<Arc<AtomicUsize>>

Implementations

impl WorkerProbeBackend

pub fn new(policy: SecurityPolicy) -> Self

pub fn with_delay(self, delay_ms: u64) -> Self

pub fn with_inflight( self, in_flight: Arc<AtomicUsize>, peak: Arc<AtomicUsize>, ) -> Self

Trait Implementations

impl AgentBackend for WorkerProbeBackend

fn run_agent<'life0, 'async_trait>( &'life0 self, request: AgentRequest, ) -> Pin<Box<dyn Future<Output = AgentBackendResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,