Struct Extension

pub struct Extension<'a, E, L, T> { /* private fields */ }

An Extension that runs event, log and telemetry processors

Implementations

impl Extension<'_, Identity<LambdaEvent>, MakeIdentity<Vec<LambdaLog>>, MakeIdentity<Vec<LambdaTelemetry>>>

pub fn new() -> Self

Create a new base Extension with a no-op events processor

impl<'a, E, L, T> Extension<'a, E, L, T>

where E: Service<LambdaEvent>, E::Future: Future<Output = Result<(), E::Error>>, E::Error: Into<Error> + Display + Debug, L: MakeService<(), Vec<LambdaLog>, Response = ()> + Send + Sync + 'static, L::Service: Service<Vec<LambdaLog>, Response = ()> + Send + Sync, <L::Service as Service<Vec<LambdaLog>>>::Future: Send + 'a, L::Error: Into<Error> + Debug, L::MakeError: Into<Error> + Debug, L::Future: Send, T: MakeService<(), Vec<LambdaTelemetry>, Response = ()> + Send + Sync + 'static, T::Service: Service<Vec<LambdaTelemetry>, Response = ()> + Send + Sync, <T::Service as Service<Vec<LambdaTelemetry>>>::Future: Send + 'a, T::Error: Into<Error> + Debug, T::MakeError: Into<Error> + Debug, T::Future: Send,

pub fn with_extension_name(self, extension_name: &'a str) -> Self

Create a new Extension with a given extension name

pub fn with_events(self, events: &'a [&'a str]) -> Self

Create a new Extension with a list of given events. The only accepted events are INVOKE and SHUTDOWN.

pub fn with_events_processor<N>(self, ep: N) -> Extension<'a, N, L, T>

where N: Service<LambdaEvent>, N::Future: Future<Output = Result<(), N::Error>>, N::Error: Into<Error> + Display,

Create a new Extension with a service that receives Lambda events.

pub fn with_logs_processor<N, NS>(self, lp: N) -> Extension<'a, E, N, T>

where N: Service<()>, N::Future: Future<Output = Result<NS, N::Error>>, N::Error: Into<Error> + Display,

Create a new Extension with a service that receives Lambda logs.

pub fn with_log_types(self, log_types: &'a [&'a str]) -> Self

Create a new Extension with a list of logs types to subscribe. The only accepted log types are function, platform, and extension.

pub fn with_log_buffering(self, lb: LogBuffering) -> Self

Create a new Extension with specific configuration to buffer logs.

pub fn with_log_port_number(self, port_number: u16) -> Self

Create a new Extension with a different port number to listen to logs.

pub fn with_telemetry_processor<N, NS>(self, lp: N) -> Extension<'a, E, L, N>

where N: Service<()>, N::Future: Future<Output = Result<NS, N::Error>>, N::Error: Into<Error> + Display,

Create a new Extension with a service that receives Lambda telemetry data.

pub fn with_telemetry_types(self, telemetry_types: &'a [&'a str]) -> Self

Create a new Extension with a list of telemetry types to subscribe. The only accepted telemetry types are function, platform, and extension.

pub fn with_telemetry_buffering(self, lb: LogBuffering) -> Self

Create a new Extension with specific configuration to buffer telemetry.

pub fn with_telemetry_port_number(self, port_number: u16) -> Self

Create a new Extension with a different port number to listen to telemetry.

pub async fn register(self) -> Result<RegisteredExtension<E>, Error>

Register the extension.

Performs the init phase Lambda lifecycle operations to register the extension. When implementing an internal Lambda extension, it is safe to call lambda_runtime::run once the future returned by this function resolves.

pub async fn run(self) -> Result<(), Error>

Execute the given extension.

Trait Implementations

impl Default for Extension<'_, Identity<LambdaEvent>, MakeIdentity<Vec<LambdaLog>>, MakeIdentity<Vec<LambdaTelemetry>>>

fn default() -> Self

Returns the “default value” for a type.