Struct MockLambdaRuntimeApiServer

pub struct MockLambdaRuntimeApiServer(/* private fields */);

A mock server for the Lambda Runtime API. Use Self::bind to create a new server, and Self::serve to start serving requests.

If you want to handle each connection manually, use Self::handle_next. If you want to forward requests to the real Lambda Runtime API, use Self::passthrough.

Examples

use aws_lambda_runtime_proxy::MockLambdaRuntimeApiServer;

let server = MockLambdaRuntimeApiServer::bind(3000).await.unwrap();
// proxy all requests to the real Lambda Runtime API
server.passthrough().await;

Implementations

impl MockLambdaRuntimeApiServer

pub async fn bind(port: u16) -> Result<Self>

Create a new server bound to the provided port.

pub async fn handle_next<ResBody, Fut>( &self, processor: impl Fn(Request<Incoming>) -> Fut + Send + Sync + 'static, ) -> Result<()>

where ResBody: Body + Send + 'static, <ResBody as Body>::Error: Into<Box<dyn Error + Send + Sync>> + Send, Fut: Future<Output = Result<Response<ResBody>>> + Send, <ResBody as Body>::Data: Send,

Handle the next incoming connection with the provided processor.

pub async fn serve<ResBody, Fut>( &self, processor: impl Fn(Request<Incoming>) -> Fut + Send + Sync + Clone + 'static, )

where Fut: Future<Output = Result<Response<ResBody>>> + Send, ResBody: Body + Send + 'static, <ResBody as Body>::Error: Into<Box<dyn Error + Send + Sync>> + Send, <ResBody as Body>::Data: Send,

Block the current thread and handle connections with the processor in a loop.

pub async fn passthrough(&self)

Block the current thread and handle connections in a loop, forwarding requests to a new LambdaRuntimeApiClient, and responding with the client’s response.