Struct BollardReadClient 

pub struct BollardReadClient { /* private fields */ }

Local Bollard implementation of the neutral Docker read contracts.

Implementations

impl BollardReadClient

pub fn connect_local(host: &HostRecord) -> InfraResult<Self>

Connects to a local Docker socket and binds the client to one host revision.

pub async fn connect_remote( connection: Arc<OpenSshConnection>, host: &HostRecord, remote_socket: &Path, cancellation: &CancellationToken, ) -> InfraResult<Self>

Connects to a remote Docker Unix socket through a strict OpenSSH forward.

pub async fn close(self) -> InfraResult<()>

Explicitly closes an owned remote forward when present.

Trait Implementations

impl ContainerExecMutator for BollardReadClient

fn exec_container<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, host: &'life1 HostRecord, request: &'life2 ContainerExecRequest, cancellation: &'life3 CancellationToken, ) -> Pin<Box<dyn Future<Output = MutationResult<ContainerExecReceipt>> + Send + 'async_trait>>

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

Executes one direct argv command without a shell or TTY.

impl ContainerLifecycleMutator for BollardReadClient

fn mutate_container<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, host: &'life1 HostRecord, request: &'life2 ContainerLifecycleRequest, cancellation: &'life3 CancellationToken, ) -> Pin<Box<dyn Future<Output = MutationResult<ContainerMutationReceipt>> + Send + 'async_trait>>

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

Sends one lifecycle mutation while preserving send uncertainty.

impl ContainerReader for BollardReadClient

fn list_containers<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, host: &'life1 HostRecord, options: &'life2 ContainerListOptions, cancellation: &'life3 CancellationToken, ) -> Pin<Box<dyn Future<Output = InfraResult<Vec<ContainerSummary>>> + Send + 'async_trait>>

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

Lists containers.

fn inspect_container<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, host: &'life1 HostRecord, container: &'life2 str, cancellation: &'life3 CancellationToken, ) -> Pin<Box<dyn Future<Output = InfraResult<ContainerInspect>> + Send + 'async_trait>>

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

Inspects one container.

fn top_container<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, host: &'life1 HostRecord, container: &'life2 str, cancellation: &'life3 CancellationToken, ) -> Pin<Box<dyn Future<Output = InfraResult<ContainerProcessTable>> + Send + 'async_trait>>

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

Returns one container process table.

impl ContainerRecreateInspector for BollardReadClient

fn recreate_fingerprint<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, host: &'life1 HostRecord, container: &'life2 str, cancellation: &'life3 CancellationToken, ) -> Pin<Box<dyn Future<Output = InfraResult<ContainerRecreateFingerprint>> + Send + 'async_trait>>

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

Captures replacement-relevant container configuration.

impl ContainerRecreateMutator for BollardReadClient

fn recreate_container<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, host: &'life1 HostRecord, request: &'life2 ContainerRecreateRequest, cancellation: &'life3 CancellationToken, ) -> Pin<Box<dyn Future<Output = MutationResult<ContainerRecreateReceipt>> + Send + 'async_trait>>

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

Replaces a container from its captured configuration.

impl DockerCleanupMutator for BollardReadClient

fn remove_image<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, host: &'life1 HostRecord, request: &'life2 ImageRemovalRequest, cancellation: &'life3 CancellationToken, ) -> Pin<Box<dyn Future<Output = MutationResult<ImageRemovalReceipt>> + Send + 'async_trait>>

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

Removes one image.

fn prune<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, host: &'life1 HostRecord, request: &'life2 DockerPruneRequest, cancellation: &'life3 CancellationToken, ) -> Pin<Box<dyn Future<Output = MutationResult<DockerPruneReceipt>> + Send + 'async_trait>>

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

Prunes one target scope.

impl DockerSystemReader for BollardReadClient

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

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

Reads Docker daemon information.

impl DockerTelemetryReader for BollardReadClient

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

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

Reads daemon disk usage.

fn container_logs<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, host: &'life1 HostRecord, container: &'life2 str, options: &'life3 ContainerLogOptions, cancellation: &'life4 CancellationToken, ) -> Pin<Box<dyn Future<Output = InfraResult<ContainerLogs>> + Send + 'async_trait>>

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

Reads bounded one-shot container logs.

fn container_stats<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, host: &'life1 HostRecord, container: &'life2 str, cancellation: &'life3 CancellationToken, ) -> Pin<Box<dyn Future<Output = InfraResult<ContainerStatsSnapshot>> + Send + 'async_trait>>

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

Reads one container statistics frame.

impl ImagePullMutator for BollardReadClient

fn pull_image<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, host: &'life1 HostRecord, request: &'life2 ImagePullRequest, progress: &'life3 dyn MutationProgressReporter, cancellation: &'life4 CancellationToken, ) -> Pin<Box<dyn Future<Output = MutationResult<ImagePullReceipt>> + Send + 'async_trait>>

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

Pulls one image while emitting canonical progress and preserving send uncertainty.

impl ImageReader for BollardReadClient

fn list_images<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, host: &'life1 HostRecord, options: &'life2 ImageListOptions, cancellation: &'life3 CancellationToken, ) -> Pin<Box<dyn Future<Output = InfraResult<Vec<ImageSummary>>> + Send + 'async_trait>>

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

Lists images.

impl NetworkReader for BollardReadClient

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

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

Lists networks.

impl VolumeReader for BollardReadClient

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

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

Lists volumes.