pub struct InterceptorContext<I = Input, O = Output, E = Error> { /* private fields */ }
Expand description

A container for the data currently available to an interceptor.

Different context is available based on which phase the operation is currently in. For example, context in the “before serialization” phase won’t have a request yet since the input hasn’t been serialized at that point. But once it gets into the “before transmit” phase, the request will be set.

Implementations§

source§

impl InterceptorContext

source

pub fn new(input: Input) -> InterceptorContext

Creates a new interceptor context in the “before serialization” phase.

source§

impl<I, O, E> InterceptorContext<I, O, E>

source

pub fn input(&self) -> Option<&I>

Retrieve the input for the operation being invoked.

Note: This method is intended for internal use only.

source

pub fn input_mut(&mut self) -> Option<&mut I>

Retrieve the input for the operation being invoked.

Note: This method is intended for internal use only.

source

pub fn take_input(&mut self) -> Option<I>

Takes ownership of the input.

Note: This method is intended for internal use only.

source

pub fn set_request(&mut self, request: Request)

Set the request for the operation being invoked.

Note: This method is intended for internal use only.

source

pub fn request(&self) -> Option<&Request>

Retrieve the transmittable request for the operation being invoked. This will only be available once request marshalling has completed.

Note: This method is intended for internal use only.

source

pub fn request_mut(&mut self) -> Option<&mut Request>

Retrieve the transmittable request for the operation being invoked. This will only be available once request marshalling has completed.

Note: This method is intended for internal use only.

source

pub fn take_request(&mut self) -> Option<Request>

Takes ownership of the request.

Note: This method is intended for internal use only.

source

pub fn set_response(&mut self, response: Response)

Set the response for the operation being invoked.

Note: This method is intended for internal use only.

source

pub fn response(&self) -> Option<&Response>

Returns the response.

Note: This method is intended for internal use only.

source

pub fn response_mut(&mut self) -> Option<&mut Response>

Returns a mutable reference to the response.

Note: This method is intended for internal use only.

source

pub fn set_output_or_error(&mut self, output: Result<O, OrchestratorError<E>>)

Set the output or error for the operation being invoked.

Note: This method is intended for internal use only.

source

pub fn output_or_error(&self) -> Option<Result<&O, &OrchestratorError<E>>>

Returns the deserialized output or error.

Note: This method is intended for internal use only.

source

pub fn output_or_error_mut( &mut self, ) -> Option<&mut Result<O, OrchestratorError<E>>>

Returns the mutable reference to the deserialized output or error.

Note: This method is intended for internal use only.

source

pub fn is_failed(&self) -> bool

Return true if this context’s output_or_error is an error. Otherwise, return false.

Note: This method is intended for internal use only.

source

pub fn enter_serialization_phase(&mut self)

Advance to the Serialization phase.

Note: This method is intended for internal use only.

source

pub fn enter_before_transmit_phase(&mut self)

Advance to the BeforeTransmit phase.

Note: This method is intended for internal use only.

source

pub fn enter_transmit_phase(&mut self)

Advance to the Transmit phase.

Note: This method is intended for internal use only.

source

pub fn enter_before_deserialization_phase(&mut self)

Advance to the BeforeDeserialization phase.

Note: This method is intended for internal use only.

source

pub fn enter_deserialization_phase(&mut self)

Advance to the Deserialization phase.

Note: This method is intended for internal use only.

source

pub fn enter_after_deserialization_phase(&mut self)

Advance to the AfterDeserialization phase.

Note: This method is intended for internal use only.

source

pub fn save_checkpoint(&mut self)

Set the request checkpoint. This should only be called once, right before entering the retry loop.

Note: This method is intended for internal use only.

source

pub fn rewind(&mut self, _cfg: &mut ConfigBag) -> RewindResult

Returns false if rewinding isn’t possible

Note: This method is intended for internal use only.

source§

impl<I, O, E> InterceptorContext<I, O, E>
where E: Debug,

source

pub fn into_parts( self, ) -> (Option<I>, Option<Result<O, OrchestratorError<E>>>, Option<Request>, Option<Response>)

Decomposes the context into its constituent parts.

Note: This method is intended for internal use only.

source

pub fn finalize(self) -> Result<O, SdkError<E, Response>>

Convert this context into the final operation result that is returned in client’s the public API.

Note: This method is intended for internal use only.

source

pub fn fail(&mut self, error: OrchestratorError<E>)

Mark this context as failed due to errors during the operation. Any errors already contained by the context will be replaced by the given error.

Note: This method is intended for internal use only.

Trait Implementations§

source§

impl<I, O, E> Debug for InterceptorContext<I, O, E>
where I: Debug, O: Debug, E: Debug,

source§

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

Formats the value using the given formatter. Read more
source§

impl<'a, I, O, E> From<&'a InterceptorContext<I, O, E>> for AfterDeserializationInterceptorContextRef<'a, I, O, E>

source§

fn from( inner: &'a InterceptorContext<I, O, E>, ) -> AfterDeserializationInterceptorContextRef<'a, I, O, E>

Converts to this type from the input type.
source§

impl<'a, I, O, E> From<&'a InterceptorContext<I, O, E>> for BeforeDeserializationInterceptorContextRef<'a, I, O, E>

source§

fn from( inner: &'a InterceptorContext<I, O, E>, ) -> BeforeDeserializationInterceptorContextRef<'a, I, O, E>

Converts to this type from the input type.
source§

impl<'a, I, O, E> From<&'a InterceptorContext<I, O, E>> for BeforeSerializationInterceptorContextRef<'a, I, O, E>

source§

fn from( inner: &'a InterceptorContext<I, O, E>, ) -> BeforeSerializationInterceptorContextRef<'a, I, O, E>

Converts to this type from the input type.
source§

impl<'a, I, O, E> From<&'a InterceptorContext<I, O, E>> for BeforeTransmitInterceptorContextRef<'a, I, O, E>

source§

fn from( inner: &'a InterceptorContext<I, O, E>, ) -> BeforeTransmitInterceptorContextRef<'a, I, O, E>

Converts to this type from the input type.
source§

impl<'a, I, O, E> From<&'a InterceptorContext<I, O, E>> for FinalizerInterceptorContextRef<'a, I, O, E>

source§

fn from( inner: &'a InterceptorContext<I, O, E>, ) -> FinalizerInterceptorContextRef<'a, I, O, E>

Converts to this type from the input type.
source§

impl<'a, I, O, E> From<&'a mut InterceptorContext<I, O, E>> for BeforeDeserializationInterceptorContextMut<'a, I, O, E>

source§

fn from( inner: &'a mut InterceptorContext<I, O, E>, ) -> BeforeDeserializationInterceptorContextMut<'a, I, O, E>

Converts to this type from the input type.
source§

impl<'a, I, O, E> From<&'a mut InterceptorContext<I, O, E>> for BeforeSerializationInterceptorContextMut<'a, I, O, E>

source§

fn from( inner: &'a mut InterceptorContext<I, O, E>, ) -> BeforeSerializationInterceptorContextMut<'a, I, O, E>

Converts to this type from the input type.
source§

impl<'a, I, O, E> From<&'a mut InterceptorContext<I, O, E>> for BeforeTransmitInterceptorContextMut<'a, I, O, E>

source§

fn from( inner: &'a mut InterceptorContext<I, O, E>, ) -> BeforeTransmitInterceptorContextMut<'a, I, O, E>

Converts to this type from the input type.
source§

impl<'a, I, O, E> From<&'a mut InterceptorContext<I, O, E>> for FinalizerInterceptorContextMut<'a, I, O, E>

source§

fn from( inner: &'a mut InterceptorContext<I, O, E>, ) -> FinalizerInterceptorContextMut<'a, I, O, E>

Converts to this type from the input type.

Auto Trait Implementations§

§

impl<I = Input, O = Output, E = Error> !Freeze for InterceptorContext<I, O, E>

§

impl<I = Input, O = Output, E = Error> !RefUnwindSafe for InterceptorContext<I, O, E>

§

impl<I, O, E> Send for InterceptorContext<I, O, E>
where I: Send, O: Send, E: Send,

§

impl<I, O, E> Sync for InterceptorContext<I, O, E>
where I: Sync, O: Sync, E: Sync,

§

impl<I, O, E> Unpin for InterceptorContext<I, O, E>
where I: Unpin, O: Unpin, E: Unpin,

§

impl<I = Input, O = Output, E = Error> !UnwindSafe for InterceptorContext<I, O, E>

Blanket Implementations§

source§

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

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

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

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

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

source§

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

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> Instrument for T

source§

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

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

fn in_current_span(self) -> Instrumented<Self>

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

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

source§

fn into(self) -> U

Calls U::from(self).

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

source§

impl<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

source§

fn into_shared(self) -> Shared

Creates a shared type from an unshared type.
source§

impl<T> Same for T

§

type Output = T

Should always be Self
source§

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

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

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

Performs the conversion.
source§

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.
source§

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

Performs the conversion.
source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

source§

fn vzip(self) -> V

source§

impl<T> WithSubscriber for T

source§

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
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

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