pub struct CallbackForwarder(/* private fields */);Expand description
Forwards run_graph requests; used to route these from a worker back to the
server (ancestor) which issued the run_function request (to that worker).
Implementations§
Source§impl CallbackForwarder
impl CallbackForwarder
Sourcepub async fn new_connect(
uri: &Uri,
interceptor: ClientInterceptor,
) -> Result<Self>
pub async fn new_connect( uri: &Uri, interceptor: ClientInterceptor, ) -> Result<Self>
Connects to a remote Tierkreis server in order to forward callbacks onto it
Sourcepub async fn signature(
&self,
location: Location,
) -> Result<ListFunctionsResponse>
pub async fn signature( &self, location: Location, ) -> Result<ListFunctionsResponse>
Gets the signature (list of known functions + namespaces) of the server
Sourcepub fn as_runtime_worker(&self) -> &dyn RuntimeWorker
pub fn as_runtime_worker(&self) -> &dyn RuntimeWorker
Allows running graphs (/typechecking) by forwarding requests
Auto Trait Implementations§
impl Freeze for CallbackForwarder
impl !RefUnwindSafe for CallbackForwarder
impl Send for CallbackForwarder
impl Sync for CallbackForwarder
impl Unpin for CallbackForwarder
impl UnsafeUnpin for CallbackForwarder
impl !UnwindSafe for CallbackForwarder
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> 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