Struct LambdaRuntime 

pub struct LambdaRuntime { /* private fields */ }

Implementations

impl LambdaRuntime

pub fn from_backend(backend: Arc<dyn LambdaBackend>) -> Self

Construct a runtime over the supplied backend. Callers that want auto-detection should use Self::auto_detect_docker or Self::new.

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

Auto-detect Docker or Podman. Returns None if neither is available. Override with FAKECLOUD_CONTAINER_CLI env var.

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

Backwards-compatible alias for Self::auto_detect_docker. Callers across the workspace use ContainerRuntime::new(port).

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

Construct a runtime backed by the Kubernetes backend. Reads configuration from env vars (FAKECLOUD_K8S_SELF_URL, FAKECLOUD_K8S_NAMESPACE, etc.) and connects to the cluster via in-cluster service account or kubeconfig. Hard-fails on any configuration or connectivity issue — we don’t silently fall back to Docker because the operator explicitly opted in to K8s.

internal_token is the bearer token the artifact endpoints on the fakecloud server expect from Pod init containers — caller must register the same token on those endpoints.

pub fn cli_name(&self) -> &str

pub async fn invoke( &self, func: &LambdaFunction, payload: &[u8], layers: &[Vec<u8>], ) -> Result<Vec<u8>, RuntimeError>

Invoke a Lambda function, starting an instance if needed. Layer ZIPs are extracted into /opt of the runtime sandbox; AWS base images already include /opt/python, /opt/nodejs/node_modules, /opt/lib, and /opt/bin on the right import paths.

pub async fn invoke_streaming( &self, func: &LambdaFunction, payload: &[u8], layers: &[Vec<u8>], ) -> Result<StreamingInvocation, RuntimeError>

Invoke a Lambda function and yield the raw HTTP body as a stream of byte chunks. Each chunk corresponds to one HTTP frame the RIE flushed to the wire — for streaming-aware handlers this preserves the chunk boundaries the function emitted. Buffered handlers come back as a single chunk, which is still a valid streamed response.

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

Stop and remove a warm instance for a specific function.

pub async fn stop_all(&self)

Stop and remove all warm instances (used on server shutdown or reset).

pub fn list_warm_containers( &self, lambda_state: &SharedLambdaState, ) -> Vec<Value>

List all warm instances and their metadata for introspection.

pub async fn evict_container(&self, function_name: &str) -> bool

Evict (stop and remove) the warm instance for a specific function. Returns true if an instance was found and evicted.

pub async fn run_cleanup_loop(self: Arc<Self>, ttl: Duration)

Background loop that stops instances idle longer than ttl.