Struct BollardClientProvider 

pub struct BollardClientProvider { /* private fields */ }

Revision-aware Bollard provider for local and strict-SSH hosts.

Implementations

impl BollardClientProvider

pub fn new(pool: Arc<ConnectionPool<OpenSshConnector>>) -> Self

Creates a provider backed by the shared strict-OpenSSH pool.

pub fn with_remote_socket( self, host: HostId, path: impl Into<PathBuf>, ) -> InfraResult<Self>

Configures an explicit remote Docker socket for one SSH host.

Trait Implementations

impl ContainerExecClientProvider for BollardClientProvider

fn exec_client<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, host: &'life1 HostRecord, cancellation: &'life2 CancellationToken, ) -> Pin<Box<dyn Future<Output = InfraResult<Arc<dyn ContainerExecMutator>>> + Send + 'async_trait>>

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

Creates an exec client bound to the exact host revision.

impl ContainerRecreateClientProvider for BollardClientProvider

fn recreate_client<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, host: &'life1 HostRecord, cancellation: &'life2 CancellationToken, ) -> Pin<Box<dyn Future<Output = InfraResult<Arc<dyn ContainerRecreateClient>>> + Send + 'async_trait>>

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

Creates a client bound to the exact host topology revision.

impl DockerArtifactClientProvider for BollardClientProvider

fn artifact_client<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, host: &'life1 HostRecord, cancellation: &'life2 CancellationToken, ) -> Pin<Box<dyn Future<Output = InfraResult<Arc<dyn DockerArtifactClient>>> + Send + 'async_trait>>

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

Returns a client bound to the exact host revision.

impl DockerCleanupClientProvider for BollardClientProvider

fn cleanup_client<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, host: &'life1 HostRecord, cancellation: &'life2 CancellationToken, ) -> Pin<Box<dyn Future<Output = InfraResult<Arc<dyn DockerCleanupClient>>> + Send + 'async_trait>>

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

Resolves one cleanup client for the exact host revision.

impl DockerClientProvider for BollardClientProvider

fn client<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, host: &'life1 HostRecord, cancellation: &'life2 CancellationToken, ) -> Pin<Box<dyn Future<Output = InfraResult<Arc<dyn DockerReadClient>>> + Send + 'async_trait>>

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

Returns a client bound to the exact host revision.

impl DockerMutationClientProvider for BollardClientProvider

fn mutation_client<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, host: &'life1 HostRecord, cancellation: &'life2 CancellationToken, ) -> Pin<Box<dyn Future<Output = InfraResult<Arc<dyn DockerMutationClient>>> + Send + 'async_trait>>

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

Returns a mutation-capable client bound to the exact host revision.