Struct RdsRuntime 

pub struct RdsRuntime { /* private fields */ }

Implementations

impl RdsRuntime

pub fn new(server_port: u16) -> Option<Self>

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

Construct the Kubernetes backend. server_port is fakecloud’s bound port (used when FAKECLOUD_K8S_SELF_URL omits one). Fails fast on misconfiguration — never silently degrades to Docker.

pub fn cli_name(&self) -> &str

pub async fn reap_stale(&self)

Sweep DB Pods orphaned by a previous process (k8s only; no-op on the Docker backend, which the shared container reaper handles).

pub async fn ensure_postgres( &self, db_instance_identifier: &str, engine: &str, engine_version: &str, username: &str, password: &str, db_name: &str, account_id: &str, region: &str, tags: &[RdsTag], ) -> Result<RunningDbContainer, RuntimeError>

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

pub async fn restart_container( &self, db_instance_identifier: &str, engine: &str, username: &str, password: &str, db_name: &str, ) -> Result<RunningDbContainer, RuntimeError>

pub async fn stop_all(&self)

pub async fn remove_data_volume( &self, account_id: &str, db_instance_identifier: &str, )

Remove the persisted data volume for an instance. Called on DeleteDBInstance so a later instance reusing the same identifier starts clean rather than inheriting the deleted instance’s data. A no-op on the k8s backend (PVC lifecycle is handled there) and for engines without a managed volume.

pub async fn dump_database( &self, db_instance_identifier: &str, engine: &str, username: &str, password: &str, db_name: &str, ) -> Result<Vec<u8>, RuntimeError>

pub async fn read_log_file( &self, db_instance_identifier: &str, container_path: &str, ) -> Result<Vec<u8>, RuntimeError>

Cat a file inside the running container by absolute path. Returns Unavailable when the runtime/daemon is missing or the instance has no live container; returns ContainerStartFailed when the file is missing or unreadable. Callers map those to the AWS-shaped responses.

pub async fn restore_database( &self, db_instance_identifier: &str, engine: &str, username: &str, password: &str, db_name: &str, dump_data: &[u8], ) -> Result<(), RuntimeError>