Struct PlainRpcAcceptor

pub struct PlainRpcAcceptor {
    service: Mutex<Routes>,
}

An acceptor for plaintext (unencrypted) RPC calls. Supports gRPC over unencrypted HTTP/2.

Fields

service: Mutex<Routes>

Implementations

impl PlainRpcAcceptor

pub fn new( config: &'static Config, current_store: &'static Current, ) -> &'static Self

Create a new PlainRpcAcceptor with the provided Config and Current

Memory

This function leaks memory, and should therefore not be called an unbounded number of times

Trait Implementations

impl Acceptor<TcpStream> for PlainRpcAcceptor

fn accept<'life0, 'async_trait>( &'life0 self, stream: TcpStream, local_addr: SocketAddr, remote_addr: SocketAddr, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Accept an incoming connection in stream from remote_addr to local_addr. This function should spawn a task to handle the request using this acceptor’s associated handler.

fn protocol(&self) -> Protocol

Get the Protocol that this acceptor processes

impl Debug for PlainRpcAcceptor

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

Formats the value using the given formatter.