Struct teaclave_rpc::transport::server::Router

source · [−]

pub struct Router<L = Identity> { /* private fields */ }

Expand description

A stack based Service router.

Implementations

source

impl<L> Router<L>

source

pub fn add_service<S>(self, svc: S) -> Router<L>where
S: 'static + Service<Request<Body>, Response = Response<UnsyncBoxBody<Bytes, Status>>, Error = Infallible> + NamedService + Clone + Send,
<S as Service<Request<Body>>>::Future: 'static + Send,

Add a new service to this router.

source

pub fn add_optional_service<S>(self, svc: Option<S>) -> Router<L>where
S: 'static + Service<Request<Body>, Response = Response<UnsyncBoxBody<Bytes, Status>>, Error = Infallible> + NamedService + Clone + Send,
<S as Service<Request<Body>>>::Future: 'static + Send,

Add a new optional service to this router.

Note

Even when the argument given is None this will capture all requests to this service name. As a result, one cannot use this to toggle between two identically named implementations.

source

pub async fn serve<ResBody>(
 self,
 addr: SocketAddr
) -> impl Future<Output = Result<(), Error>>where
 L: Layer<Routes>,
 <L as Layer<Routes>>::Service: 'static + Service<Request<Body>, Response = Response<ResBody>> + Clone + Send,
 <<L as Layer<Routes>>::Service as Service<Request<Body>>>::Future: 'static + Send,
 <<L as Layer<Routes>>::Service as Service<Request<Body>>>::Error: Into<Box<dyn Error + Sync + Send + 'static, Global>> + Send,
 ResBody: 'static + Body<Data = Bytes> + Send,
 <ResBody as Body>::Error: Into<Box<dyn Error + Sync + Send + 'static, Global>>,

Consume this Server creating a future that will execute the server on tokio’s default executor.

source

pub async fn serve_with_shutdown<F, ResBody>(
 self,
 addr: SocketAddr,
 signal: F
) -> impl Future<Output = Result<(), Error>>where
 F: Future<Output = ()>,
 L: Layer<Routes>,
 <L as Layer<Routes>>::Service: 'static + Service<Request<Body>, Response = Response<ResBody>> + Clone + Send,
 <<L as Layer<Routes>>::Service as Service<Request<Body>>>::Future: 'static + Send,
 <<L as Layer<Routes>>::Service as Service<Request<Body>>>::Error: Into<Box<dyn Error + Sync + Send + 'static, Global>> + Send,
 ResBody: 'static + Body<Data = Bytes> + Send,
 <ResBody as Body>::Error: Into<Box<dyn Error + Sync + Send + 'static, Global>>,

Consume this Server creating a future that will execute the server on tokio’s default executor. And shutdown when the provided signal is received.

source

pub async fn serve_with_incoming<I, IO, IE, ResBody>(
 self,
 incoming: I
) -> impl Future<Output = Result<(), Error>>where
 I: Stream<Item = Result<IO, IE>>,
 IO: 'static + AsyncRead + AsyncWrite + Connected + Unpin + Send,
 <IO as Connected>::ConnectInfo: 'static + Clone + Send + Sync,
 IE: Into<Box<dyn Error + Sync + Send + 'static, Global>>,
 L: Layer<Routes>,
 <L as Layer<Routes>>::Service: 'static + Service<Request<Body>, Response = Response<ResBody>> + Clone + Send,
 <<L as Layer<Routes>>::Service as Service<Request<Body>>>::Future: 'static + Send,
 <<L as Layer<Routes>>::Service as Service<Request<Body>>>::Error: Into<Box<dyn Error + Sync + Send + 'static, Global>> + Send,
 ResBody: 'static + Body<Data = Bytes> + Send,
 <ResBody as Body>::Error: Into<Box<dyn Error + Sync + Send + 'static, Global>>,

Consume this Server creating a future that will execute the server on the provided incoming stream of AsyncRead + AsyncWrite.

source

pub async fn serve_with_incoming_shutdown<I, IO, IE, F, ResBody>(
 self,
 incoming: I,
 signal: F
) -> impl Future<Output = Result<(), Error>>where
 I: Stream<Item = Result<IO, IE>>,
 IO: 'static + AsyncRead + AsyncWrite + Connected + Unpin + Send,
 <IO as Connected>::ConnectInfo: 'static + Clone + Send + Sync,
 IE: Into<Box<dyn Error + Sync + Send + 'static, Global>>,
 F: Future<Output = ()>,
 L: Layer<Routes>,
 <L as Layer<Routes>>::Service: 'static + Service<Request<Body>, Response = Response<ResBody>> + Clone + Send,
 <<L as Layer<Routes>>::Service as Service<Request<Body>>>::Future: 'static + Send,
 <<L as Layer<Routes>>::Service as Service<Request<Body>>>::Error: Into<Box<dyn Error + Sync + Send + 'static, Global>> + Send,
 ResBody: 'static + Body<Data = Bytes> + Send,
 <ResBody as Body>::Error: Into<Box<dyn Error + Sync + Send + 'static, Global>>,

Consume this Server creating a future that will execute the server on the provided incoming stream of AsyncRead + AsyncWrite. Similar to serve_with_shutdown this method will also take a signal future to gracefully shutdown the server.

source