Struct relay_aws_extension::AwsExtension

pub struct AwsExtension { /* private fields */ }

Service implementing an AWS extension.

Spawns a service that:

• registers with the AWS extensions API
• sends blocking (0 timeout) NextEvent calls to the extensions API to get the next invocation

Each finished invocation immediately polls for the next event. Note that AWS might freeze the container indefinitely for unused lambdas and this request will also wait until things are active again.

The actual requests are done in a separate tokio runtime with one worker thread with a oneshot channel being used for communicating the necessary responses.

Implementations

impl AwsExtension

pub fn new(aws_runtime_api: &str) -> Result<Self, AwsExtensionError>

Creates a new AwsExtension instance.

Trait Implementations

impl Debug for AwsExtension

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Service for AwsExtension

type Interface = ()

The interface of messages this service implements.

fn spawn_handler(self, _rx: Receiver<Self::Interface>)

Spawns a task to handle service messages.

fn start(self) -> Addr<Self::Interface>

Starts the service in the current runtime and returns an address for it.

fn start_in(self, runtime: &Runtime) -> Addr<Self::Interface>

Starts the service in the given runtime and returns an address for it.

fn name() -> &'static str

Returns a unique name for this service implementation.