Struct DockerContainerMachine 

pub struct DockerContainerMachine<S> {
    pub nats: Option<Client>,
    pub docker: Docker,
    pub metadata: ContainerMetadata,
    pub state: S,
}

The core state machine representing a Docker container’s lifecycle.

Fields

nats: Option<Client>

The NATS client used for messaging, if available.

docker: Docker

The Docker client.

metadata: ContainerMetadata

Metadata associated with this container execution.

state: S

The current state of the machine.

Implementations

impl<S> DockerContainerMachine<S>

pub async fn get_network_mode(&self) -> Option<String>

Attempts to detect the Docker network mode the runner is operating in.

pub fn build_container_config( &self, spec: &CommonContainerSpec, mounts: Vec<Mount>, network_mode: Option<String>, storage_names: &[String], ) -> Result<Config<String>>

Builds the Docker container configuration based on the provided specifications.

pub fn parse_cpu_to_quota(&self, cpu: &str) -> Option<i64>

Parses a CPU string limit to Docker CPU quota representation.

pub fn parse_memory_to_bytes(&self, memory: &str) -> Option<i64>

Parses a memory string limit into bytes.

impl DockerContainerMachine<Finished>

pub fn into_result(self) -> ContainerState

Consumes the state machine, returning the final ContainerState result.

impl DockerContainerMachine<Initialized>

pub fn adopt(self, container_name: String) -> DockerContainerMachine<Running>

Adopts an already-running container by name, transitioning the state machine to Running.

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

Cleans up an orphaned container without running it through the state machine.

pub async fn start(self) -> Result<StartResult>

Starts a new Docker container, pulling images and unparking storage as necessary.

impl DockerContainerMachine<Running>

pub async fn wait(self) -> Result<DockerContainerMachine<Finished>>

Waits for the running container to finish executing, collects metrics and artifacts, and cleans it up.

impl DockerContainerMachine<Initialized>

pub fn new( docker: Docker, metadata: ContainerMetadata, nats: Option<Client>, ) -> Self

Creates a new, initialized container state machine.

Trait Implementations

impl<S: Clone> Clone for DockerContainerMachine<S>

fn clone(&self) -> DockerContainerMachine<S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.