Skip to main content

PooledClient

lambda_runtime_api_client

Struct PooledClient

pub struct PooledClient {
    pub base: Uri,
    /* private fields */
}

Expand description

API client to interact with the AWS Lambda Runtime API, with support for rebuilding its connection pool after a SnapStart VM restore.

Fields§

§base: Uri

The runtime API URI

Implementations§

impl PooledClient

pub fn builder() -> PooledClientBuilder

Create a builder struct to configure the client.

pub fn call( &self, req: Request<Body>, ) -> BoxFuture<'static, Result<Response<Incoming>, BoxError>>

Send a given request to the Runtime API. Use the client’s base URI to ensure the API endpoint is correct.

pub fn reset_pool(&self)

Reset the internal connection pool by building a fresh hyper client that subsequent calls will use.

This is useful after a SnapStart VM restore where existing connections to the Lambda Runtime API (RAPID) are stale and must be discarded. It is called exactly once during the restore lifecycle, before concurrent polling starts, so the underlying OnceLock write never races.

Trait Implementations§

impl Debug for PooledClient

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

Formats the value using the given formatter. Read more

impl RuntimeApiClient for PooledClient

fn call( &self, req: Request<Body>, ) -> BoxFuture<'static, Result<Response<Incoming>, BoxError>>

Send a given request to the Runtime API.

Auto Trait Implementations§

impl !Freeze for PooledClient

impl !RefUnwindSafe for PooledClient

impl !UnwindSafe for PooledClient

impl Send for PooledClient

impl Sync for PooledClient

impl Unpin for PooledClient

impl UnsafeUnpin for PooledClient

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self> ⓘ

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more