Struct TtrpcServer 

pub struct TtrpcServer { /* private fields */ }

Available on crate feature ttrpc only.

A ttRPC server as a rama Service: it serves one ServerConnection per accepted stream, so it can be handed straight to a rama listener (rama-tcp, rama-unix, …) instead of writing the per-connection loop by hand.

For a single, already-established connection (e.g. one virtual stream of an NRI mux), use the lower-level ServerConnection directly instead.

Implementations

impl TtrpcServer

pub fn new() -> TtrpcServer

Create a new, empty TtrpcServer.

pub fn with_max_concurrent_streams(self, max: usize) -> TtrpcServer

Set the maximum number of concurrently-executing request handlers per connection. Past this, requests are rejected with RESOURCE_EXHAUSTED. Defaults to DEFAULT_MAX_CONCURRENT_STREAMS.

pub fn set_max_concurrent_streams(&mut self, max: usize) -> &mut TtrpcServer

Set the maximum number of concurrently-executing request handlers per connection. Past this, requests are rejected with RESOURCE_EXHAUSTED. Defaults to DEFAULT_MAX_CONCURRENT_STREAMS.

pub fn with_close_connection_on_oversized_frame( self, enabled: bool, ) -> TtrpcServer

Treat an oversized inbound frame as a fatal protocol error: close the connection (failing all its in-flight calls) instead of the default Go-parity behaviour of discarding the payload and answering that stream with RESOURCE_EXHAUSTED (containerd/ttrpc channel.go). Opt in for untrusted peers, where reading up to ~4 GiB of declared garbage per bad frame is wasted work.

pub fn set_close_connection_on_oversized_frame( &mut self, enabled: bool, ) -> &mut TtrpcServer

Treat an oversized inbound frame as a fatal protocol error: close the connection (failing all its in-flight calls) instead of the default Go-parity behaviour of discarding the payload and answering that stream with RESOURCE_EXHAUSTED (containerd/ttrpc channel.go). Opt in for untrusted peers, where reading up to ~4 GiB of declared garbage per bad frame is wasted work.

pub fn register(self, service: impl Service) -> TtrpcServer

Register a (generated) ttRPC service’s methods on this server.

Trait Implementations

impl Clone for TtrpcServer

fn clone(&self) -> TtrpcServer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for TtrpcServer

fn default() -> TtrpcServer

Returns the “default value” for a type.

impl<IO> Service<IO> for TtrpcServer

where IO: Io,

type Output = ()

The type of the output returned by the service.

type Error = Error

The type of error returned by the service.

async fn serve( &self, stream: IO, ) -> Result<<TtrpcServer as Service<IO>>::Output, <TtrpcServer as Service<IO>>::Error>

Serve an output or an error for the given input

fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>

Box this service to allow for dynamic dispatch.