Struct FastCgiServer 

pub struct FastCgiServer<S> { /* private fields */ }

Available on crate feature fastcgi only.

FastCGI server that accepts connections and dispatches requests to an inner service.

The inner service S must implement Service<FastCgiRequest> with Output = FastCgiResponse. Each accepted connection is handled synchronously: one request per connection at a time (multiplexed requests are not supported). A second concurrent FCGI_BEGIN_REQUEST is replied to with FCGI_END_REQUEST{CantMpxConn} (see ServerOptions::respond_cant_mpx_conn).

All three FastCGI roles are dispatched to the inner service: Role::Responder, Role::Authorizer, and Role::Filter. The service inspects req.role to handle each case appropriately.

Implementations

impl<S> FastCgiServer<S>

pub fn new(inner: S) -> FastCgiServer<S>

Create a new FastCgiServer wrapping the given inner service.

pub fn with_options(self, options: ServerOptions) -> FastCgiServer<S>

Replace the ServerOptions used for parsing connections.

pub fn options(&self) -> &ServerOptions

Get a reference to the current ServerOptions.

pub fn get_ref(&self) -> &S

Gets a reference to the underlying service.

pub fn into_inner(self) -> S

Consumes self, returning the underlying service.

impl<S> FastCgiServer<S>

pub async fn serve_connection<IO>(&self, stream: IO) -> Result<(), Error>

where IO: AsyncRead + AsyncWrite + Unpin + Send + 'static, S: Service<FastCgiRequest, Output = FastCgiResponse>, <S as Service<FastCgiRequest>>::Error: Into<Box<dyn Error + Send + Sync>>,

Handle a single FastCGI connection.

The IO stream is split into independent read and write halves so that the inner service can stream the request body while the response is written concurrently. A background task reads FCGI_STDIN (and FCGI_DATA for Filter requests) records and forwards them to the service via an in-memory channel. If the web server sends FCGI_ABORT_REQUEST the body stream signals an io::ErrorKind::ConnectionAborted error to the service and the connection is closed after the response is written.

Trait Implementations

impl<S> Clone for FastCgiServer<S>

where S: Clone,

fn clone(&self) -> FastCgiServer<S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S> Debug for FastCgiServer<S>

where S: Debug,

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

Formats the value using the given formatter.

impl<S, IO> Service<IO> for FastCgiServer<S>

where S: Service<FastCgiRequest, Output = FastCgiResponse>, <S as Service<FastCgiRequest>>::Error: Into<Box<dyn Error + Send + Sync>>, IO: Io + Unpin + Send + 'static,

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<<FastCgiServer<S> as Service<IO>>::Output, <FastCgiServer<S> 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.