Struct ElastiCacheRuntime 

pub struct ElastiCacheRuntime { /* private fields */ }

Implementations

impl ElastiCacheRuntime

pub fn new() -> Option<Self>

Construct the Docker/Podman backend. Returns None when no container CLI is available.

pub async fn new_k8s( server_port: u16, internal_token: String, ) -> Result<Self, BackendInitError>

Construct the Kubernetes backend. server_port is fakecloud’s bound port (used when FAKECLOUD_K8S_SELF_URL omits one); internal_token guards the per-resource RDB endpoint that seeds snapshot data into restored Redis Pods. Fails fast on misconfiguration — never silently degrades.

pub fn cli_name(&self) -> &str

Name of the active backend, for logging.

pub fn pending_rdb(&self) -> Option<PendingRdb>

The pending-RDB map the server’s internal endpoint serves from. None on the Docker backend (which stages snapshots via the daemon, not HTTP).

pub fn endpoint_host(&self) -> &str

Address fakecloud advertises for clients to reach a spawned cache container, and uses for readiness probes. 127.0.0.1 on the host; host.docker.internal when fakecloud is containerized (issue #1539, bug 0.4). Only meaningful for the Docker backend (k8s addresses are per-Pod and returned from ensure_*).

pub async fn ensure_redis( &self, resource_id: &str, rdb_path: Option<&str>, tags: &BTreeMap<String, String>, ) -> Result<RunningCacheContainer, RuntimeError>

pub async fn ensure_memcached( &self, resource_id: &str, tags: &BTreeMap<String, String>, ) -> Result<RunningCacheContainer, RuntimeError>

pub async fn stop_container(&self, resource_id: &str)

pub async fn remove_data_volume(&self, resource_id: &str)

Remove the persisted redis/valkey data volume for a resource. Called on delete so a later resource reusing the identifier starts clean instead of reloading the deleted resource’s RDB. No-op on the k8s backend (PVC lifecycle is handled there) and for memcached (no volume).

pub async fn restart_container( &self, resource_id: &str, tags: &BTreeMap<String, String>, ) -> Result<(), RuntimeError>

Restart the underlying backing instance, mirroring real ElastiCache’s RebootCacheCluster behaviour. Returns Unavailable if the resource has no live instance tracked here.

pub async fn exec_redis( &self, resource_id: &str, redis_args: &[String], ) -> Result<CacheExec, RuntimeError>

Execute a redis-cli command inside a tracked instance.

pub async fn dump_rdb( &self, resource_id: &str, dest_path: &str, ) -> Result<(), RuntimeError>

Trigger SAVE inside a running Redis instance and copy the resulting dump.rdb out to dest_path.

pub async fn stop_all(&self)

pub async fn reap_stale(&self)

Sweep cache Pods orphaned by a previous fakecloud process (k8s only; the Docker backend relies on the shared reaper).

Trait Implementations

impl Clone for ElastiCacheRuntime

fn clone(&self) -> ElastiCacheRuntime

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ElastiCacheRuntime

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.