Struct LambdaService 

pub struct LambdaService { /* private fields */ }

Implementations

impl LambdaService

pub const GROUPS: &'static [&'static str]

pub fn new() -> Self

pub fn with_data_dir(dir: impl AsRef<Path>) -> Self

pub fn with_max_blob_bytes(self, bytes: u64) -> Self

pub fn store(&self) -> AccountRegionStore<LambdaState>

pub fn body_store(&self) -> Option<&Arc<BodyStore>>

Trait Implementations

impl BlobInventory for LambdaService

fn known_blobs(&self) -> Vec<(String, String, String)>

impl Default for LambdaService

fn default() -> Self

Returns the “default value” for a type.

impl ServiceHandler for LambdaService

fn service_name(&self) -> &str

The AWS service name (e.g., “s3”, “sqs”, “dynamodb”).

fn signing_name(&self) -> &str

The signing name used in SigV4 Authorization headers. Usually the same as service_name, but not always.

fn protocol(&self) -> Protocol

The primary protocol this service uses.

fn routes(&self) -> Vec<RouteDefinition>

Route definitions for REST-protocol services. Not needed for RPC-style protocols (awsJson, awsQuery).

fn handle<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, operation: &'life1 str, input: Value, ctx: &'life2 RequestContext, ) -> Pin<Box<dyn Future<Output = Result<Value, AwsError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Handle an AWS API operation.

fn snapshot(&self) -> Option<Vec<u8>>

Serialize the service’s state to bytes for persistence.

fn restore(&self, data: &[u8]) -> Result<(), String>

Restore the service’s state from a previous snapshot.

fn iam_action(&self, operation: &str) -> Option<String>

fn iam_resource( &self, operation: &str, input: &Value, ctx: &RequestContext, ) -> Option<String>

fn handle_streaming<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, operation: &'life1 str, input: Value, ctx: &'life2 RequestContext, ) -> Pin<Box<dyn Future<Output = Result<HandlerResult, AwsError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: 'async_trait,

Streaming-aware variant. The default delegates to handle and wraps the JSON result so existing services don’t need to do anything; services that genuinely stream (Bedrock data plane) override this and return HandlerResult::Streaming.

fn tick<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Periodic tick. The gateway spawns a single 1-second loop that calls tick on every registered service after the server is up. Use this hook for time-driven behavior that doesn’t fit into the request path: SQS visibility-timeout reclamation, DynamoDB TTL expiry, Lambda event-source-mapping polling, S3 lifecycle transitions, EventBridge schedule firing, SecretsManager rotation, etc.