Struct DockerManager 

pub struct DockerManager { /* private fields */ }

Docker container manager

Implementations

impl DockerManager

pub fn new() -> Result<Self>

Create a new Docker manager

Errors

Returns an error if the Docker client cannot be created

pub async fn ensure_image(&self, image: &str) -> Result<()>

Pull an image if it doesn’t exist

Errors

Returns an error if the image cannot be pulled

pub async fn run_container( &self, image: &str, name: &str, env_vars: HashMap<String, String>, ports: HashMap<String, String>, volumes: HashMap<String, String>, cmd: Option<Vec<String>>, extra_hosts: Option<Vec<String>>, health_check_cmd: Option<Vec<String>>, bind_ip: Option<String>, ) -> Result<String>

Create and start a container

Errors

Returns an error if the container cannot be created or started

pub async fn stop_and_remove_container( &self, container_id: &str, container_name: &str, ) -> Result<()>

Stops and removes a Docker container

Errors

Returns an error if the container cannot be stopped or removed

pub async fn create_network(&self, network_name: &str) -> Result<()>

Creates a Docker network

Errors

Returns an error if the network cannot be created

pub async fn connect_to_network( &self, container_name: &str, network_name: &str, ) -> Result<()>

Connects a container to a Docker network

Errors

Returns an error if the container cannot be connected to the network

pub async fn is_container_running(&self, container_id: &str) -> Result<bool>

Checks if the container is running

Errors

Returns an error if the container cannot be inspected

pub async fn dump_container_logs(&self, container_id: &str)

Wait for the container to become healthy

Errors

Returns an error if the container is not healthy within the timeout period

pub async fn wait_for_container_health( &self, container_id: &str, timeout_secs: u64, ) -> Result<()>

Waits for a specified Docker container to report a healthy status.

This function polls the container’s health status periodically until it becomes healthy, an unhealthy status is reported, or the timeout is reached. If the container reports unhealthy, its logs will be dumped.

Arguments

• container_id - The ID of the container to monitor.
• timeout_secs - The maximum time in seconds to wait for the container to become healthy.

Errors

This function will return an error if:

• Inspecting the container fails (e.g., due to Docker API issues).
• The container reports an UNHEALTHY status.
• The timeout is reached before the container becomes healthy.
• The container is not running and has no health check configured.

Trait Implementations

impl Clone for DockerManager

fn clone(&self) -> DockerManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for DockerManager

fn default() -> Self

Returns the “default value” for a type.