Struct ToolResilience 

pub struct ToolResilience { /* private fields */ }

Unified facade for tool resilience. Wraps the adaptive rate limiter and the circuit breaker so callers can use a single API for admission, fault isolation, and post-call accounting.

Example

use vtcode_core::tools::resilience::{GLOBAL_TOOL_RESILIENCE, CallOutcome, Priority};

// On entry:
GLOBAL_TOOL_RESILIENCE
    .try_acquire("read_file", Priority::Normal)
    .map_err(|wait| anyhow!("rate limited; retry after {wait:?}"))?;

// On exit:
match result {
    Ok(_) => GLOBAL_TOOL_RESILIENCE.record_success("read_file"),
    Err(e) if e.is_argument_error() => {
        GLOBAL_TOOL_RESILIENCE.record_outcome("read_file", CallOutcome::InvalidArgument);
    }
    Err(_) => {
        GLOBAL_TOOL_RESILIENCE.record_outcome("read_file", CallOutcome::ExecutionError);
    }
}

Implementations

impl ToolResilience

pub fn new( rate_limiter: AdaptiveRateLimiter, circuit_breaker: CircuitBreaker, ) -> Self

Construct a new facade with the supplied adaptive rate limiter and circuit breaker.

pub fn try_acquire( &self, tool_name: &str, priority: Priority, ) -> Result<(), Duration>

Try to acquire a token for the tool. Returns Ok(()) when the call is allowed. When the tool is currently rate limited the suggested wait duration is returned in Err.

pub fn record_success(&self, tool_name: &str)

Record a successful call. Closes the circuit if it was HalfOpen.

pub fn record_outcome(&self, tool_name: &str, outcome: CallOutcome)

Record a non-success outcome. Categorical errors that should not trip the breaker (InvalidArgument) are routed through CallOutcome::InvalidArgument. See CallOutcome.

pub fn circuit_snapshot(&self) -> CircuitBreakerSnapshot

Diagnostic snapshot of the circuit breaker.