Rust client SDK for the AWS Lambda Runtime APIs. This crate defines a RuntimeClient that encapsulates interactions with AWS Lambda's Runtime APIs.

To return errors to the Runtime APIs through the event_error() or fail_init() methods the Error objects must implement the error::RuntimeApiError trait from this crate. The RuntimeApiError trait defines a single method called to_response(). The method must return an error::RuntimeError object. See the error::ApiError object in this crate for an example.

Examples

extern crate lambda_runtime_client;
#[macro_use]
extern crate serde_derive;
extern crate serde_json;

use lambda_runtime_client::{RuntimeClient, EventContext};

#[derive(Serialize, Deserialize, Debug)]
struct CustomEvent {
name: String,
}

#[derive(Serialize, Deserialize, Debug)]
struct CustomResponse {
surname: String,
}

fn main() {
let client = RuntimeClient::new("http://localhost:8080", None, None)
.expect("Could not initialize client");

let (event_data, event_context) = client.next_event()
.expect("Could not retrieve next event");
let custom_event: CustomEvent = serde_json::from_slice(&event_data)
.expect("Could not turn Vec<u8> into CustomEvent object");

println!("Event for {}", custom_event.name);
if custom_event.name == "John" {
let resp_object = CustomResponse{ surname: String::from("Doe")};
let resp_vec = serde_json::to_vec(&resp_object)
.expect("Could not serialize CustomResponse to Vec<u8>");
client.event_response(&event_context.aws_request_id, &resp_vec)
.expect("Response sent successfully");
} else {
// return a custom error by implementing the RuntimeApiError trait.
// See the error module for examples.
//client.event_error(&event_context.aws_request_id, CustomErrorType::new("Invalid first name"))
//    .expect("Could not send error response");
}
}

lambda_runtime_client 0.2.2

Examples