Struct tsukuyomi::server::Server

pub struct Server<S, M = Identity, L = SocketAddr, A = (), R = Runtime> { /* private fields */ }

An HTTP server.

Implementations

impl<S> Server<S>where
    S: NewService,

pub fn new(new_service: S) -> Self

Create a new Server with the specified NewService and default configuration.

impl<S, M, L, A, R> Server<S, M, L, A, R>

pub fn bind<L2>(self, listener: L2) -> Server<S, M, L2, A, R>where
    L2: Listener,

Sets the transport used by the server.

By default, a TCP transport with the listener address "127.0.0.1:4000" is set.

pub fn acceptor<A2>(self, acceptor: A2) -> Server<S, M, L, A2, R>where
    L: Listener,
    A2: Acceptor<L::Conn>,

Sets the instance of Acceptor to the server.

By default, the raw acceptor is set, which returns the incoming I/Os directly.

pub fn protocol(self, protocol: Http) -> Self

Sets the HTTP-level configuration to this server.

Note that the executor will be overwritten by the launcher.

pub fn modify_service<M2>(self, modify_service: M2) -> Server<S, M2, L, A, R>where
    S: NewService,
    M2: ModifyService<S::Service>,

Sets the middleware to this server.

pub fn tower_middleware<M2>(
    self,
    middleware: M2
) -> Server<S, Compat<M2>, L, A, R>where
    S: NewService,
    M2: Middleware<S::Service>,

pub fn runtime<R2>(self, runtime: R2) -> Server<S, M, L, A, R2>

Sets the instance of runtime to the specified runtime.

pub fn current_thread(self) -> Server<S, M, L, A, Runtime>

Switches the runtime to be used to current_thread::Runtime.

impl<S, M, T, A> Server<S, M, T, A, Runtime>where
    S: MakeHttpService + Send + 'static,
    S::Future: Send + 'static,
    M: ModifyHttpService<S::Service> + Send + Sync + 'static,
    M::Service: Send + 'static,
    <M::Service as HttpService>::Future: Send + 'static,
    T: Listener,
    T::Incoming: Send + 'static,
    A: Acceptor<T::Conn> + Send + 'static,
    A::Conn: Send + 'static,
    A::Error: Into<Box<dyn Error + Send + Sync + 'static>>,
    <A::Conn as Connection>::Info: Send + 'static,
    <A::Conn as Connection>::Error: Into<Box<dyn Error + Send + Sync + 'static>>,
    A::Accept: Send + 'static,

pub fn run(self) -> Result<()>

pub fn into_test_server(self) -> Result<Server<S, M>>

Convert itself into a TestServer.

impl<S, M, T, A> Server<S, M, T, A, Runtime>where
    S: MakeHttpService,
    S::Future: 'static,
    M: ModifyHttpService<S::Service> + 'static,
    M::Service: 'static,
    <M::Service as HttpService>::Future: 'static,
    T: Listener,
    T::Incoming: 'static,
    A: Acceptor<T::Conn> + 'static,
    A::Conn: Send + 'static,
    A::Error: Into<Box<dyn Error + Send + Sync + 'static>>,
    <A::Conn as Connection>::Info: 'static,
    <A::Conn as Connection>::Error: Into<Box<dyn Error + Send + Sync + 'static>>,
    A::Accept: 'static,

pub fn run(self) -> Result<()>

pub fn into_test_server(self) -> Result<Server<S, M, Runtime>>

Convert itself into a TestServer.

Trait Implementations

impl<S: Debug, M: Debug, L: Debug, A: Debug, R: Debug> Debug for Server<S, M, L, A, R>

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

Formats the value using the given formatter.