Struct MockRuntime 

pub struct MockRuntime { /* private fields */ }

In-memory ContainerRuntime for tests.

Every container becomes ContainerStatus::Healthy 30 ms after start, unless its name is configured as a failure target via MockRuntime::fail_on.

Implementations

impl MockRuntime

pub fn new() -> Self

Build a fresh runtime with empty state.

pub fn fail_on(&self, name: &str)

Configure the runtime to reject start for the resource whose ContainerSpec.name equals name.

pub fn started_resources(&self) -> Vec<String>

Snapshot of the resource names in start order.

pub fn stopped_resources(&self) -> Vec<String>

Snapshot of the resource names in stop order.

pub fn started_specs(&self) -> Vec<ContainerSpec>

Snapshot of every container spec the runtime has accepted.

Trait Implementations

impl Clone for MockRuntime

fn clone(&self) -> MockRuntime

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ContainerRuntime for MockRuntime

async fn start(&self, spec: &ContainerSpec) -> Result<ContainerId, RuntimeError>

Start a container according to spec. Pulls the image if not already present locally.

async fn stop( &self, id: &ContainerId, _grace: Duration, ) -> Result<(), RuntimeError>

Stop a container, sending SIGTERM and then SIGKILL after grace. Idempotent: stopping an already stopped container is a no-op.

async fn remove(&self, name: &str) -> Result<(), RuntimeError>

Remove a container by name, forcing removal even if it is still running. Idempotent: removing a container that does not exist is a no-op. Named volumes are preserved.

async fn inspect( &self, id: &ContainerId, ) -> Result<ContainerStatus, RuntimeError>

Report the current status of a container.

async fn wait_healthy( &self, id: &ContainerId, timeout: Duration, ) -> Result<(), RuntimeError>

Block until the container reports a healthy status or timeout elapses. Returns crate::RuntimeError::Timeout in the latter case.

async fn logs( &self, _id: &ContainerId, _follow: bool, ) -> Result<LogChunkStream, RuntimeError>

Stream logs from a container. When follow is true the stream stays open and emits new chunks as they arrive; when false the stream completes after the existing logs are drained.

async fn ensure_project_network( &self, _project: &str, ) -> Result<(), RuntimeError>

Ensure a per-project user-defined bridge network exists, creating it when absent. Idempotent: concurrent calls are safe because a 409 Conflict response (network already exists) is treated as success. Containers attached to this network can reach each other by their container name, enabling resources.<name>.url hostnames to resolve without extra configuration.

async fn teardown_project_network( &self, _project: &str, ) -> Result<(), RuntimeError>

Remove the per-project bridge network. Idempotent: a 404 Not Found response is treated as success. Call after all containers belonging to the project have been removed; Docker refuses to delete a network that still has active endpoints.

impl Default for MockRuntime

fn default() -> Self

Returns the “default value” for a type.