pub struct RpcClientUDiscovery { /* private fields */ }Expand description
A UDiscovery client implementation for invoking operations of a local uDiscovery service.
The client requires an RpcClient for performing the remote procedure calls.
Implementations§
Trait Implementations§
Source§impl Debug for RpcClientUDiscovery
impl Debug for RpcClientUDiscovery
Source§impl UDiscovery for RpcClientUDiscovery
impl UDiscovery for RpcClientUDiscovery
Source§fn find_services<'life0, 'async_trait>(
&'life0 self,
uri_pattern: UUri,
recursive: bool,
) -> Pin<Box<dyn Future<Output = Result<Vec<UUri>, UStatus>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn find_services<'life0, 'async_trait>(
&'life0 self,
uri_pattern: UUri,
recursive: bool,
) -> Pin<Box<dyn Future<Output = Result<Vec<UUri>, UStatus>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Finds service instances based on search criteria. Read more
Source§fn get_service_topics<'life0, 'async_trait>(
&'life0 self,
topic_pattern: UUri,
recursive: bool,
) -> Pin<Box<dyn Future<Output = Result<Vec<TopicInfo>, UStatus>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_service_topics<'life0, 'async_trait>(
&'life0 self,
topic_pattern: UUri,
recursive: bool,
) -> Pin<Box<dyn Future<Output = Result<Vec<TopicInfo>, UStatus>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Gets information about topic(s) that a service (instance) publishes messages to. Read more
Auto Trait Implementations§
impl Freeze for RpcClientUDiscovery
impl !RefUnwindSafe for RpcClientUDiscovery
impl Send for RpcClientUDiscovery
impl Sync for RpcClientUDiscovery
impl Unpin for RpcClientUDiscovery
impl !UnwindSafe for RpcClientUDiscovery
Blanket Implementations§
§impl<T> AnySync for T
impl<T> AnySync for T
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
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<TCore> UWithNativePrefixWire for TCore
impl<TCore> UWithNativePrefixWire for TCore
Source§fn into_native_prefix_wire_transport<W>(
self,
wire: W,
) -> UWireTransport<TCore, W, NativePrefixFrameMetadataCodec>where
W: UWire,
fn into_native_prefix_wire_transport<W>(
self,
wire: W,
) -> UWireTransport<TCore, W, NativePrefixFrameMetadataCodec>where
W: UWire,
Wraps this core with an external or custom selected wire using canonical metadata.
Source§fn into_protobuf_transport(
self,
) -> UWireTransport<TCore, ProtobufWire, NativePrefixFrameMetadataCodec>
fn into_protobuf_transport( self, ) -> UWireTransport<TCore, ProtobufWire, NativePrefixFrameMetadataCodec>
Wraps this core with the Protocol Buffers selected-wire profile.
Source§fn into_stable_container_transport(
self,
) -> UWireTransport<TCore, StableContainerWireFormat, NativePrefixFrameMetadataCodec>
fn into_stable_container_transport( self, ) -> UWireTransport<TCore, StableContainerWireFormat, NativePrefixFrameMetadataCodec>
Wraps this core with the stable-container selected-wire profile.