Struct TimeoutConfig 

pub struct TimeoutConfig {
    pub total: Option<Duration>,
    pub first_response: Option<Duration>,
}

Configuration for operation timeouts

Fields

total: Option<Duration>

Overall timeout for the entire operation

first_response: Option<Duration>

Timeout for first response (useful for streaming)

Implementations

impl TimeoutConfig

pub fn none() -> Self

No timeout (operations can run indefinitely)

pub fn quick() -> Self

Quick timeout for fast operations

pub fn long() -> Self

Long timeout for expensive operations

pub fn custom(total: Duration, first_response: Option<Duration>) -> Self

Custom timeout

pub async fn execute<F, T>( &self, operation_name: &str, operation: F, ) -> Result<T, RuntimeError>

where F: Future<Output = Result<T, RuntimeError>>,

Execute an async operation with timeout protection

Example

use agent_runtime::timeout::TimeoutConfig;
use std::time::Duration;

let config = TimeoutConfig::default();
let result = config.execute(
    "fetch_data",
    async {
        // Your operation here
        Ok("success".to_string())
    }
).await?;

pub async fn execute_with_first_response<F, T>( &self, operation_name: &str, operation: F, ) -> Result<T, RuntimeError>

where F: Future<Output = Result<T, RuntimeError>> + Unpin,

Execute with first response timeout (useful for streaming)

Returns a tuple of (first_chunk, remaining_stream)

Trait Implementations

impl Clone for TimeoutConfig

fn clone(&self) -> TimeoutConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TimeoutConfig

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

Formats the value using the given formatter.

impl Default for TimeoutConfig

fn default() -> Self

Returns the “default value” for a type.