Docs.rs
  • lambda-extension-0.10.0
    • lambda-extension 0.10.0
    • Docs.rs crate page
    • Apache-2.0
    • Links
    • Repository
    • crates.io
    • Source
    • Owners
    • bnusunny
    • maxday
    • Dependencies
      • async-stream ^0.3 normal
      • bytes ^1 normal
      • chrono ^0.4 normal
      • http ^1.0 normal
      • http-body-util ^0.1 normal
      • hyper ^1.0 normal
      • hyper-util ^0.1.1 normal
      • lambda_runtime_api_client ^0.10 normal
      • serde ^1 normal
      • serde_json ^1 normal
      • tokio ^1.0 normal
      • tokio-stream ^0.1.2 normal
      • tower ^0.4 normal
      • tracing ^0.1 normal
    • Versions
    • 100% of the crate is documented
  • Go to latest version
  • Platform
    • i686-pc-windows-msvc
    • i686-unknown-linux-gnu
    • x86_64-apple-darwin
    • x86_64-pc-windows-msvc
    • x86_64-unknown-linux-gnu
  • Feature flags
  • docs.rs
    • About docs.rs
    • Privacy policy
  • Rust
    • Rust website
    • The Book
    • Standard Library API Reference
    • Rust by Example
    • The Cargo Guide
    • Clippy Documentation

Crate lambda_extension

lambda_extension0.10.0

  • All Items
  • Re-exports
  • Modules
  • Structs
  • Enums
  • Traits
  • Functions
  • Type Aliases

Crates

  • lambda_extension
?
Change settings

Crate lambda_extension

source ·
Expand description

This module includes utilities to create Lambda Runtime Extensions.

Create a type that conforms to the Extension trait. This type can then be passed to the the lambda_extension::run function, which launches and runs the Lambda runtime extension.

Re-exports§

  • pub use tower;

Modules§

  • requests
    Include several request builders to interact with the Extension API.
  • tracing
    Utilities to initialize and use tracing and tracing-subscriber in Lambda Functions. This module provides primitives to work with tracing and tracing-subscriber in Lambda functions.

Structs§

  • Extension
    An Extension that runs event, log and telemetry processors
  • ExtensionError
    Simple error that encapsulates human readable descriptions
  • Identity
    A no-op generic processor
  • InitReportMetrics
    Init report metrics
  • InvokeEvent
    Event received when there is a new Lambda invocation.
  • LambdaEvent
    Wrapper with information about the next event that the Lambda Runtime is going to process
  • LambdaLog
    Payload received from the Lambda Logs API See: https://docs.aws.amazon.com/lambda/latest/dg/runtimes-logs-api.html#runtimes-logs-api-msg
  • LambdaTelemetry
    Payload received from the Telemetry API
  • LogBuffering
    Log buffering configuration. Allows Lambda to buffer logs before delivering them to a subscriber.
  • LogPlatformReportMetrics
    Platform report metrics
  • MakeIdentity
    Service factory to generate no-op generic processors
  • RegisteredExtension
    An extension registered by calling Extension::register.
  • ReportMetrics
    Report metrics
  • RuntimeDoneMetrics
    Runtime done metrics
  • SharedService
    A MakeService that produces services by cloning an inner service.
  • ShutdownEvent
    Event received when a Lambda function shuts down.
  • Span
    Span
  • TraceContext
    Tracing Context
  • Tracing
    Request tracing information

Enums§

  • InitPhase
    Phase in which initialization occurs
  • InitType
    Type of Initialization
  • LambdaLogRecord
    Record in a LambdaLog entry
  • LambdaTelemetryRecord
    Record in a LambdaTelemetry entry
  • NextEvent
    Event that the extension receives in either the INVOKE or SHUTDOWN phase
  • Status
    Status of invocation/initialization
  • TracingType
    Type of tracing

Traits§

  • Service
    An asynchronous function from a Request to a Response.

Functions§

  • run
    Execute the given events processor
  • service_fn
    Returns a new ServiceFn with the given closure.

Type Aliases§

  • Error
    Error type that extensions may result in

Results

struct
lambda_extension::tracing::subscriber::layer::Context
Represents information about the current context provided …
method
lambda_extension::tracing::event::Event::is_contextual
Returns true if the new event’s parent should be …
method
lambda_extension::tracing::span::Attributes::is_contextual
Returns true if the new span’s parent should be …
struct
lambda_extension::tracing::subscriber::fmt::FmtContext
Provides the current span context to a formatter.
struct
lambda_extension::TraceContext
Tracing Context
method
lambda_extension::tracing::subscriber::layer::Context::clone
method
lambda_extension::tracing::instrument::WithDispatch::try_poll
method
lambda_extension::tracing::instrument::Instrumented::try_poll
method
lambda_extension::tracing::subscriber::layer::Context::current_span
Returns the wrapped subscriber’s view of the current …
method
lambda_extension::tracing::subscriber::layer::Context::event
Records the provided event with the wrapped subscriber.
trait method
lambda_extension::tracing::subscriber::layer::Filter::enabled
Returns true if this layer is interested in a span or …
method
lambda_extension::tracing::subscriber::EnvFilter::enabled
Returns true if this EnvFilter would enable the provided …
method
lambda_extension::tracing::subscriber::layer::Context::enabled
Returns whether the wrapped subscriber would enable the …
method
lambda_extension::tracing::metadata::LevelFilter::enabled
method
lambda_extension::tracing::subscriber::filter::Targets::enabled
method
lambda_extension::tracing::subscriber::EnvFilter::on_exit
Informs the filter that the span with the provided id was …
method
lambda_extension::tracing::subscriber::layer::Filter::on_exit
Notifies this filter that a span with the given ID was …
method
lambda_extension::tracing::subscriber::EnvFilter::on_close
Informs the filter that the span with the provided id was …
method
lambda_extension::tracing::subscriber::layer::Filter::on_close
Notifies this filter that a span with the given ID has …
method
lambda_extension::tracing::subscriber::EnvFilter::on_enter
Informs the filter that the span with the provided id was …
method
lambda_extension::tracing::subscriber::layer::Filter::on_enter
Notifies this filter that a span with the given ID was …
method
lambda_extension::MakeIdentity::poll_ready
method
lambda_extension::SharedService::poll_ready
method
lambda_extension::tracing::subscriber::layer::Filter::event_enabled
Called before the filtered [Layer]'s [on_event…
method
lambda_extension::tracing::instrument::WithDispatch::poll
method
lambda_extension::tracing::instrument::Instrumented::poll
method
lambda_extension::tracing::subscriber::layer::Context::exists
Returns true if an active span exists for the given Id.
method
lambda_extension::tracing::subscriber::Layer::enabled
Returns true if this layer is interested in a span or …
method
lambda_extension::tracing::subscriber::layer::Layer::enabled
Returns true if this layer is interested in a span or …
method
lambda_extension::tracing::subscriber::prelude::Layer::enabled
Returns true if this layer is interested in a span or …
method
lambda_extension::tracing::subscriber::Layer::on_exit
Notifies this layer that the span with the given ID was …
method
lambda_extension::tracing::subscriber::layer::Layer::on_exit
Notifies this layer that the span with the given ID was …
method
lambda_extension::tracing::subscriber::prelude::Layer::on_exit
Notifies this layer that the span with the given ID was …
method
lambda_extension::tracing::subscriber::Layer::on_close
Notifies this layer that the span with the given ID has …
method
lambda_extension::tracing::subscriber::layer::Layer::on_close
Notifies this layer that the span with the given ID has …
method
lambda_extension::tracing::subscriber::prelude::Layer::on_close
Notifies this layer that the span with the given ID has …
method
lambda_extension::tracing::subscriber::Layer::on_enter
Notifies this layer that a span with the given ID was …
method
lambda_extension::tracing::subscriber::layer::Layer::on_enter
Notifies this layer that a span with the given ID was …
method
lambda_extension::tracing::subscriber::prelude::Layer::on_enter
Notifies this layer that a span with the given ID was …
method
lambda_extension::tracing::subscriber::Layer::on_event
Notifies this layer that an event has occurred.
method
lambda_extension::tracing::subscriber::layer::Layer::on_event
Notifies this layer that an event has occurred.
method
lambda_extension::tracing::subscriber::prelude::Layer::on_event
Notifies this layer that an event has occurred.
method
lambda_extension::tracing::subscriber::EnvFilter::on_record
Informs the filter that the span with the provided id …
method
lambda_extension::tracing::subscriber::layer::Filter::on_record
Notifies this filter that a span with the given Id …
method
lambda_extension::tracing::subscriber::EnvFilter::on_new_span
Informs the filter that a new span was created.
method
lambda_extension::tracing::subscriber::layer::Filter::on_new_span
Notifies this filter that a new span was constructed with …
method
lambda_extension::tracing::subscriber::Layer::on_id_change
Notifies this layer that a span ID has been cloned, and …
method
lambda_extension::tracing::subscriber::layer::Layer::on_id_change
Notifies this layer that a span ID has been cloned, and …
method
lambda_extension::tracing::subscriber::prelude::Layer::on_id_change
Notifies this layer that a span ID has been cloned, and …
method
lambda_extension::tracing::subscriber::Layer::event_enabled
Called before on_event, to determine if on_event should be …
method
lambda_extension::tracing::subscriber::layer::Layer::event_enabled
Called before on_event, to determine if on_event should be …
method
lambda_extension::tracing::subscriber::prelude::Layer::event_enabled
Called before on_event, to determine if on_event should be …
method
lambda_extension::tracing::subscriber::layer::Context::lookup_current
Returns stored data for the span that the wrapped …
method
lambda_extension::tracing::subscriber::Layer::on_follows_from
Notifies this layer that a span with the ID span recorded …
method
lambda_extension::tracing::subscriber::layer::Layer::on_follows_from
Notifies this layer that a span with the ID span recorded …
method
lambda_extension::tracing::subscriber::prelude::Layer::on_follows_from
Notifies this layer that a span with the ID span recorded …
method
lambda_extension::tracing::subscriber::layer::Context::fmt
method
lambda_extension::tracing::subscriber::layer::Context::span
Returns stored data for the span with the given id, if it …
method
lambda_extension::tracing::subscriber::filter::combinator::Not::enabled
method
lambda_extension::tracing::subscriber::reload::Layer::enabled
method
lambda_extension::tracing::subscriber::filter::combinator::Not::on_exit
method
lambda_extension::tracing::subscriber::reload::Layer::on_exit
method
lambda_extension::tracing::subscriber::layer::Context::metadata
Returns metadata for the span with the given id, if it …
method
lambda_extension::tracing::subscriber::filter::combinator::Not::on_close
method
lambda_extension::tracing::subscriber::reload::Layer::on_close
method
lambda_extension::tracing::subscriber::filter::combinator::Not::on_enter
method
lambda_extension::tracing::subscriber::reload::Layer::on_enter
method
lambda_extension::tracing::subscriber::reload::Layer::on_event
method
lambda_extension::tracing::subscriber::Layer::on_record
Notifies this layer that a span with the given Id recorded …
method
lambda_extension::tracing::subscriber::layer::Layer::on_record
Notifies this layer that a span with the given Id recorded …
method
lambda_extension::tracing::subscriber::prelude::Layer::on_record
Notifies this layer that a span with the given Id recorded …
method
lambda_extension::tracing::subscriber::layer::Context::event_span
Returns a SpanRef for the parent span of the given Event, …
method
lambda_extension::Identity::poll_ready
method
lambda_extension::tracing::subscriber::layer::Context::span_scope
Returns an iterator over the stored data for all the spans …
method
lambda_extension::tracing::subscriber::layer::Context::event_scope
Returns an iterator over the stored data for all the spans …
method
lambda_extension::tracing::subscriber::Layer::on_new_span
Notifies this layer that a new span was constructed with …
method
lambda_extension::tracing::subscriber::layer::Layer::on_new_span
Notifies this layer that a new span was constructed with …
method
lambda_extension::tracing::subscriber::prelude::Layer::on_new_span
Notifies this layer that a new span was constructed with …
method
lambda_extension::tracing::subscriber::reload::Layer::on_id_change
method
lambda_extension::tracing::subscriber::filter::combinator::Not::event_enabled
method
lambda_extension::tracing::subscriber::reload::Layer::event_enabled
method
lambda_extension::tracing::subscriber::reload::Layer::on_follows_from
method
lambda_extension::tracing::subscriber::filter::DynFilterFn::new
Constructs a Filter from a function or closure that …
method
lambda_extension::tracing::subscriber::filter::DynFilterFn::from
method
lambda_extension::tracing::subscriber::filter::FilterFn::enabled
method
lambda_extension::tracing::subscriber::filter::combinator::And::enabled
method
lambda_extension::tracing::subscriber::filter::combinator::Or::enabled
method
lambda_extension::tracing::subscriber::filter::combinator::And::on_exit
method
lambda_extension::tracing::subscriber::filter::combinator::Or::on_exit
method
lambda_extension::tracing::subscriber::filter::combinator::And::on_close
method
lambda_extension::tracing::subscriber::filter::combinator::Or::on_close
method
lambda_extension::tracing::subscriber::filter::combinator::And::on_enter
method
lambda_extension::tracing::subscriber::filter::combinator::Or::on_enter
method
lambda_extension::tracing::subscriber::filter::combinator::Not::on_record
method
lambda_extension::tracing::subscriber::reload::Layer::on_record
method
lambda_extension::tracing::subscriber::filter::combinator::Not::on_new_span
method
lambda_extension::tracing::subscriber::reload::Layer::on_new_span
method
lambda_extension::tracing::subscriber::filter::combinator::And::event_enabled
method
lambda_extension::tracing::subscriber::filter::combinator::Or::event_enabled
function
lambda_extension::tracing::subscriber::filter::dynamic_filter_fn
Constructs a DynFilterFn from a function or closure that …
method
lambda_extension::tracing::subscriber::layer::Layered::enabled
method
lambda_extension::tracing::subscriber::layer::Layered::on_exit
method
lambda_extension::tracing::subscriber::layer::Layered::on_close
method
lambda_extension::tracing::subscriber::layer::Layered::on_enter
method
lambda_extension::tracing::subscriber::layer::Layered::on_event
method
lambda_extension::tracing::subscriber::filter::combinator::And::on_record
method
lambda_extension::tracing::subscriber::filter::combinator::Or::on_record
method
lambda_extension::tracing::subscriber::filter::combinator::And::on_new_span
method
lambda_extension::tracing::subscriber::filter::combinator::Or::on_new_span
method
lambda_extension::tracing::subscriber::layer::Layered::on_id_change
method
lambda_extension::tracing::subscriber::layer::Layered::event_enabled
method
lambda_extension::tracing::subscriber::layer::Layered::on_follows_from
method
lambda_extension::tracing::subscriber::filter::DynFilterFn::enabled
method
lambda_extension::tracing::subscriber::layer::Layered::on_record
method
lambda_extension::tracing::subscriber::layer::Layered::on_new_span
method
lambda_extension::tracing::subscriber::filter::DynFilterFn::callsite_enabled
method
lambda_extension::tracing::subscriber::filter::Filtered::enabled
method
lambda_extension::tracing::subscriber::filter::Filtered::on_exit
method
lambda_extension::tracing::subscriber::filter::Filtered::on_close
method
lambda_extension::tracing::subscriber::filter::Filtered::on_enter
method
lambda_extension::tracing::subscriber::filter::Filtered::on_event
method
lambda_extension::tracing::subscriber::filter::Filtered::on_id_change
method
lambda_extension::tracing::subscriber::filter::Filtered::event_enabled
method
lambda_extension::tracing::subscriber::filter::Filtered::on_follows_from
method
lambda_extension::tracing::subscriber::filter::DynFilterFn::register_callsite
method
lambda_extension::tracing::subscriber::filter::DynFilterFn::with_callsite_filter
Adds a function for filtering callsites to this filter.
method
lambda_extension::tracing::subscriber::filter::Filtered::on_record
trait method
lambda_extension::Service::poll_ready
Returns Poll::Ready(Ok(())) when the service is able to …
method
lambda_extension::tracing::subscriber::filter::Filtered::on_new_span
method
lambda_extension::tracing::subscriber::filter::DynFilterFn::max_level_hint
method
lambda_extension::tracing::subscriber::filter::DynFilterFn::with_max_level_hint
Sets the highest verbosity Level the filter function will …
method
lambda_extension::tracing::subscriber::fmt::Layer::on_exit
method
lambda_extension::tracing::subscriber::fmt::Layer::on_close
method
lambda_extension::tracing::subscriber::fmt::Layer::on_enter
method
lambda_extension::tracing::subscriber::fmt::Layer::on_event
method
lambda_extension::tracing::subscriber::fmt::Layer::on_record
method
lambda_extension::tracing::subscriber::fmt::Layer::on_new_span
method
lambda_extension::tracing::subscriber::layer::Context::clone
method
lambda_extension::tracing::subscriber::filter::DynFilterFn::new
Constructs a Filter from a function or closure that …
method
lambda_extension::tracing::subscriber::filter::DynFilterFn::from
function
lambda_extension::tracing::subscriber::filter::dynamic_filter_fn
Constructs a DynFilterFn from a function or closure that …
method
lambda_extension::tracing::subscriber::filter::DynFilterFn::with_callsite_filter
Adds a function for filtering callsites to this filter.
method
lambda_extension::tracing::subscriber::filter::DynFilterFn::with_max_level_hint
Sets the highest verbosity Level the filter function will …