Struct SocketRunner 

pub struct SocketRunner { /* private fields */ }

Implementations

impl SocketRunner

pub async fn new( name: impl Into<String>, cmd: Vec<String>, pool_size: usize, max_in_flight: usize, env: Option<HashMap<String, String>>, cwd: Option<String>, tcp_socket: Option<String>, response_timeout_seconds: Option<f64>, connect_timeout: Duration, shutdown_term_grace: Duration, send_cancel_hints: bool, capture_output: bool, ) -> Result<Self>

Trait Implementations

impl Runner for SocketRunner

fn execute<'life0, 'async_trait>( &'life0 self, request: ExecutionRequest, ) -> Pin<Box<dyn Future<Output = Result<ExecutionOutcome>> + Send + 'async_trait>>

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

fn execute_with_timeout<'life0, 'async_trait>( &'life0 self, request: ExecutionRequest, timeout_duration: Duration, send_cancel_hint: bool, ) -> Pin<Box<dyn Future<Output = RunnerExecutionResult> + Send + 'async_trait>>

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

fn cancel<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, job_id: &'life1 str, request_id: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn handle_timeout<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, job_id: &'life1 str, request_id: Option<&'life2 str>, send_cancel_hint: bool, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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