pub struct FunctionForwarder(/* private fields */);Expand description
A link in a forwarding chain - forwards run_function calls to a destination,
passing a Location which uniquely identifies the chain and the next link therein
(typically by the location being unique to each source/caller).
Implementations§
Source§impl FunctionForwarder
impl FunctionForwarder
Sourcepub async fn new(
uri: &Uri,
interceptor: ClientInterceptor,
loc: Location,
) -> Result<Self>
pub async fn new( uri: &Uri, interceptor: ClientInterceptor, loc: Location, ) -> Result<Self>
Creates a new instance that forwards requests to a Uri, identifying itself with a Location
Sourcepub async fn fwd_run_function(
&self,
function: FunctionName,
inputs: HashMap<Label, Value>,
loc: Location,
callback: Callback,
node_trace: Option<NodeTrace>,
) -> Result<HashMap<Label, Value>>
pub async fn fwd_run_function( &self, function: FunctionName, inputs: HashMap<Label, Value>, loc: Location, callback: Callback, node_trace: Option<NodeTrace>, ) -> Result<HashMap<Label, Value>>
Forwards a call to run a function up the chain.
loc specifies the Location relative to the root of the forwarding chain.
Trait Implementations§
Source§impl Clone for FunctionForwarder
impl Clone for FunctionForwarder
Source§fn clone(&self) -> FunctionForwarder
fn clone(&self) -> FunctionForwarder
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for FunctionForwarder
impl !RefUnwindSafe for FunctionForwarder
impl Send for FunctionForwarder
impl Sync for FunctionForwarder
impl Unpin for FunctionForwarder
impl UnsafeUnpin for FunctionForwarder
impl !UnwindSafe for FunctionForwarder
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request