Struct lambda_extension::Extension

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

An Extension that runs event and log processors

Implementations

impl<'a> Extension<'a, Identity<LambdaEvent>, MakeIdentity<Vec<LambdaLog>>>

pub fn new() -> Self

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

impl<'a, E, L> Extension<'a, E, L> where
    E: Service<LambdaEvent>,
    E::Future: Future<Output = Result<(), E::Error>>,
    E::Error: Into<Box<dyn Error + Send + Sync>> + 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<Box<dyn Error + Send + Sync>> + Debug,
    L::MakeError: Into<Box<dyn Error + Send + Sync>> + Debug,
    L::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> where
    N: Service<LambdaEvent>,
    N::Future: Future<Output = Result<(), N::Error>>,
    N::Error: Into<Box<dyn Error + Send + Sync>> + 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> where
    N: Service<()>,
    N::Future: Future<Output = Result<NS, N::Error>>,
    N::Error: Into<Box<dyn Error + Send + Sync>> + 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 async fn run(self) -> Result<(), Error>

Execute the given extension

Trait Implementations

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

fn default() -> Self

Returns the “default value” for a type.