Struct OpenSshDriver 

pub struct OpenSshDriver { /* private fields */ }

Pooled strict OpenSSH command driver.

Implementations

impl OpenSshDriver

pub fn new(connector: OpenSshConnector) -> Self

Creates a driver with an empty revision-aware connection pool.

pub async fn invalidate_host(&self, host: &HostId) -> FleetResult<usize>

Invalidates every cached revision for one host.

pub async fn retain_snapshot( &self, snapshot: &TopologySnapshot, ) -> FleetResult<usize>

Evicts cached sessions absent from the supplied snapshot.

pub async fn shutdown(&self) -> FleetResult<usize>

Closes all cached sessions.

pub async fn connection( &self, host: &HostRecord, cancellation: &CancellationToken, ) -> FleetResult<Arc<OpenSshConnection>>

Returns the exact pooled connection for forwarding adapters.

Trait Implementations

impl CommandExecutor for OpenSshDriver

fn execute<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, host: &'life1 HostRecord, request: &'life2 CommandRequest, cancellation: &'life3 CancellationToken, ) -> Pin<Box<dyn Future<Output = FleetResult<CommandOutput>> + Send + 'async_trait>>

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

Executes a validated command request on one exact host revision.

impl Default for OpenSshDriver

fn default() -> Self

Returns the “default value” for a type.