Struct Server 

pub struct Server { /* private fields */ }

Implementations

impl Server

where Self: Protocol,

pub fn new<P: Into<Box<Path>>>( root: P, uid_map: ServerUidMap, gid_map: ServerGidMap, ) -> Result<Server>

pub fn with_config(cfg: Config) -> Result<Server>

pub fn keep_fds(&self) -> Vec<RawFd>

Trait Implementations

impl Protocol for Server

const VERSION: &'static str = "9P2000.L"

const NAME: &'static str = "9p"

type Error = Error

type Request = Tmessage

type Response = Rmessage

fn tcancel(_oldtag: u16, _binding: u64) -> Option<Self::Request>

r[impl jetstream.subscription.cancel] The cancellation request for a subscription on this lane, if this protocol has subscriptions to cancel.

impl Server for Server

async fn rpc( &mut self, _context: Context, frame: Frame<Self::Request>, ) -> Result<Frame<Self::Response>, Self::Error>

The main RPC method that handles incoming requests and produces responses.

fn version(client_version: Version) -> Result<Version, Error>

Negotiate the protocol version to use.

fn is_streaming(_message_type: u8) -> bool

r[impl jetstream.subscription.surface.declared] Whether a request of this message type opens a subscription. The declaration is the protocol’s, not the call site’s, so the dispatcher can route before it moves the frame.

fn cancel_target(_frame: &Frame<Self::Request>) -> Option<u16>

r[impl jetstream.subscription.dispatch.declared] r[impl jetstream.subscription.cancel] Whether this request is a cancellation, and which subscription it names. Cancellation travels as an ordinary request under a fresh tag, so the dispatcher has to be told how to recognise one — the message id is global, but decoding the payload is the protocol’s.

fn cancel_ack(_oldtag: u16) -> Option<Self::Response>

r[impl jetstream.subscription.dispatch.declared] r[impl jetstream.subscription.cancel] The acknowledgement for a cancelled subscription, sent under the cancellation’s tag once the subscription has stopped emitting.

fn cancelled_terminator(_method: u8) -> Option<Self::Response>

r[impl jetstream.subscription.dispatch.terminator] r[impl jetstream.subscription.termination] The terminator for a subscription that was cut short. A producer stopped by cancellation returns from its stream without saying anything, and a subscription that ends with no terminator leaves the caller’s tag in flight for the life of the lane — see r[jetstream.subscription.identity] for why it cannot simply be released. The dispatcher supplies one, and the protocol says what value it has.

fn rpc_stream( &mut self, context: Context, frame: Frame<Self::Request>, cancel: CancellationToken, ) -> impl Future<Output = Pin<Box<dyn Stream<Item = Result<Frame<Self::Response>, Self::Error>> + Send>>> + Send + Sync

where Self::Response: 'static, Self::Error: 'static,

r[impl jetstream.subscription.overview] Serve a subscription: one request, many responses.