pub struct WrpcClient { /* private fields */ }Trait Implementations§
Source§impl Clone for WrpcClient
impl Clone for WrpcClient
Source§fn clone(&self) -> WrpcClient
fn clone(&self) -> WrpcClient
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 moreSource§impl Invoke for WrpcClient
impl Invoke for WrpcClient
Source§impl Serve for WrpcClient
impl Serve for WrpcClient
Auto Trait Implementations§
impl Freeze for WrpcClient
impl !RefUnwindSafe for WrpcClient
impl Send for WrpcClient
impl Sync for WrpcClient
impl Unpin for WrpcClient
impl !UnwindSafe for WrpcClient
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> GetSetFdFlags for T
impl<T> GetSetFdFlags for T
Source§fn get_fd_flags(&self) -> Result<FdFlags, Error>where
T: AsFilelike,
fn get_fd_flags(&self) -> Result<FdFlags, Error>where
T: AsFilelike,
Query the “status” flags for the
self file descriptor.Source§fn new_set_fd_flags(&self, fd_flags: FdFlags) -> Result<SetFdFlags<T>, Error>where
T: AsFilelike,
fn new_set_fd_flags(&self, fd_flags: FdFlags) -> Result<SetFdFlags<T>, Error>where
T: AsFilelike,
Source§fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error>where
T: AsFilelike,
fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error>where
T: AsFilelike,
Set the “status” flags for the
self file descriptor. Read moreSource§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::RequestSource§impl<T> InvokeExt for Twhere
T: Invoke,
impl<T> InvokeExt for Twhere
T: Invoke,
Source§fn invoke_values<P, Params, Results>(
&self,
cx: Self::Context,
instance: &str,
func: &str,
params: Params,
paths: impl AsRef<[P]> + Send,
) -> impl Future<Output = Result<(Results, Option<impl Future<Output = Result<(), Error>> + Send + 'static>), Error>> + Sendwhere
P: AsRef<[Option<usize>]> + Send + Sync,
Params: TupleEncode<Self::Outgoing> + Send,
Results: TupleDecode<Self::Incoming> + Send,
<<Params as Encode<Self::Outgoing>>::Encoder as Encoder<Params>>::Error: Error + Send + Sync + 'static,
<<Results as Decode<Self::Incoming>>::Decoder as Decoder>::Error: Error + Send + Sync + 'static,
fn invoke_values<P, Params, Results>(
&self,
cx: Self::Context,
instance: &str,
func: &str,
params: Params,
paths: impl AsRef<[P]> + Send,
) -> impl Future<Output = Result<(Results, Option<impl Future<Output = Result<(), Error>> + Send + 'static>), Error>> + Sendwhere
P: AsRef<[Option<usize>]> + Send + Sync,
Params: TupleEncode<Self::Outgoing> + Send,
Results: TupleDecode<Self::Incoming> + Send,
<<Params as Encode<Self::Outgoing>>::Encoder as Encoder<Params>>::Error: Error + Send + Sync + 'static,
<<Results as Decode<Self::Incoming>>::Decoder as Decoder>::Error: Error + Send + Sync + 'static,
Invoke function
func on instance instance using typed Params and ResultsSource§fn invoke_values_blocking<P, Params, Results>(
&self,
cx: Self::Context,
instance: &str,
func: &str,
params: Params,
paths: impl AsRef<[P]> + Send,
) -> impl Future<Output = Result<Results, Error>> + Sendwhere
P: AsRef<[Option<usize>]> + Send + Sync,
Params: TupleEncode<Self::Outgoing> + Send,
Results: TupleDecode<Self::Incoming> + Send,
<<Params as Encode<Self::Outgoing>>::Encoder as Encoder<Params>>::Error: Error + Send + Sync + 'static,
<<Results as Decode<Self::Incoming>>::Decoder as Decoder>::Error: Error + Send + Sync + 'static,
fn invoke_values_blocking<P, Params, Results>(
&self,
cx: Self::Context,
instance: &str,
func: &str,
params: Params,
paths: impl AsRef<[P]> + Send,
) -> impl Future<Output = Result<Results, Error>> + Sendwhere
P: AsRef<[Option<usize>]> + Send + Sync,
Params: TupleEncode<Self::Outgoing> + Send,
Results: TupleDecode<Self::Incoming> + Send,
<<Params as Encode<Self::Outgoing>>::Encoder as Encoder<Params>>::Error: Error + Send + Sync + 'static,
<<Results as Decode<Self::Incoming>>::Decoder as Decoder>::Error: Error + Send + Sync + 'static,
Invoke function
func on instance instance using typed Params and Results
This is like Self::invoke_values, but it only results once all I/O is doneSource§fn timeout(&self, timeout: Duration) -> Timeout<'_, Self>
fn timeout(&self, timeout: Duration) -> Timeout<'_, Self>
Returns a
Timeout, wrapping Self with an implementation of Invoke, which will
error, if call to Invoke::invoke does not return within a supplied timeoutSource§fn timeout_owned(self, timeout: Duration) -> TimeoutOwned<Self>where
Self: Sized,
fn timeout_owned(self, timeout: Duration) -> TimeoutOwned<Self>where
Self: Sized,
Source§impl<T> InvokeIncomingHandler for Twhere
T: Invoke,
impl<T> InvokeIncomingHandler for Twhere
T: Invoke,
fn invoke_handle_http<E>( &self, cx: Self::Context, request: Request<impl Body<Data = Bytes, Error = E> + Send + 'static>, ) -> impl Future<Output = Result<(Result<Response<HttpBody>, ErrorCode>, impl Stream<Item = HttpBodyError<E>> + 'static, Option<impl Future<Output = Result<(), Error>> + 'static>), Error>>
Source§impl<T> InvokeOutgoingHandler for Twhere
T: Invoke,
impl<T> InvokeOutgoingHandler for Twhere
T: Invoke,
fn invoke_handle_wasmtime(
&self,
cx: Self::Context,
request: Request<BoxBody<Bytes, ErrorCode>>,
options: OutgoingRequestConfig,
) -> impl Future<Output = Result<(Result<Response<BoxBody<Bytes, ErrorCode>>, ErrorCode>, impl Stream<Item = HttpBodyError<ErrorCode>> + 'static, Option<impl Future<Output = Result<(), Error>> + 'static>), Error>>where
Self: Sized,
Source§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<T> ServeExt for Twhere
T: Serve,
impl<T> ServeExt for Twhere
T: Serve,
Source§fn serve_values<Params, Results>(
&self,
instance: &str,
func: &str,
paths: impl Into<Arc<[Box<[Option<usize>]>]>> + Send,
) -> impl Future<Output = Result<impl Stream<Item = Result<(Self::Context, Params, Option<impl Future<Output = Result<(), Error>> + Send + Unpin + 'static>, impl FnOnce(Results) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send>> + Send + 'static), Error>> + Send + 'static, Error>> + Sendwhere
Params: TupleDecode<Self::Incoming> + Send + 'static,
Results: TupleEncode<Self::Outgoing> + Send + 'static,
<<Params as Decode<Self::Incoming>>::Decoder as Decoder>::Error: Error + Send + Sync + 'static,
<<Results as Encode<Self::Outgoing>>::Encoder as Encoder<Results>>::Error: Error + Send + Sync + 'static,
fn serve_values<Params, Results>(
&self,
instance: &str,
func: &str,
paths: impl Into<Arc<[Box<[Option<usize>]>]>> + Send,
) -> impl Future<Output = Result<impl Stream<Item = Result<(Self::Context, Params, Option<impl Future<Output = Result<(), Error>> + Send + Unpin + 'static>, impl FnOnce(Results) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send>> + Send + 'static), Error>> + Send + 'static, Error>> + Sendwhere
Params: TupleDecode<Self::Incoming> + Send + 'static,
Results: TupleEncode<Self::Outgoing> + Send + 'static,
<<Params as Decode<Self::Incoming>>::Decoder as Decoder>::Error: Error + Send + Sync + 'static,
<<Results as Encode<Self::Outgoing>>::Encoder as Encoder<Results>>::Error: Error + Send + Sync + 'static,
Serve function
func from instance instance using typed Params and Results