Struct hyperdriver::discovery::RegistryTransport

pub struct RegistryTransport { /* private fields */ }

Available on crate feature discovery only.

A connection transport which uses roomservice’s internal service registry.

Implementations

impl RegistryTransport

pub fn builder(registry: ServiceRegistry) -> TransportBuilder

Create a new RegistryTransport builder with the given service registry.

The builder can be used to add custom schemes to the transport.

pub fn with_default_schemes(registry: ServiceRegistry) -> Self

Create a new RegistryTransport with the given service registry and default schemes.

The default schemes are svc and grpc, which follow the conventions of the svc protocol (using the host to determine the service) and the gRPC protocol (using the first path component to determine the service).

pub fn registry(&self) -> &ServiceRegistry

The inner service registry

Trait Implementations

impl Clone for RegistryTransport

fn clone(&self) -> RegistryTransport

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RegistryTransport

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

Formats the value using the given formatter.

impl Service<Uri> for RegistryTransport

type Response = TransportStream<Stream>

Responses given by the service.

type Error = ConnectionError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<RegistryTransport as Service<Uri>>::Response, <RegistryTransport as Service<Uri>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: Uri) -> Self::Future

Process the request and return the response asynchronously.