Struct ServerBuilder

pub struct ServerBuilder<M: Metadata = (), S: Middleware<M> = Noop> { /* private fields */ }

Convenient JSON-RPC HTTP Server builder.

Implementations

impl<M, S: Middleware<M>> ServerBuilder<M, S>

where S::Future: Unpin, S::CallFuture: Unpin, M: Unpin + Metadata + Default,

pub fn new<T>(handler: T) -> Self

where T: Into<MetaIoHandler<M, S>>,

Creates new ServerBuilder for given IoHandler.

By default:

1. Server is not sending any CORS headers.
2. Server is validating Host header.

impl<M, S: Middleware<M>> ServerBuilder<M, S>

where S::Future: Unpin, S::CallFuture: Unpin, M: Unpin + Metadata,

pub fn with_meta_extractor<T, E>(handler: T, extractor: E) -> Self

where T: Into<MetaIoHandler<M, S>>, E: MetaExtractor<M>,

Creates new ServerBuilder for given IoHandler.

By default:

1. Server is not sending any CORS headers.
2. Server is validating Host header.

pub fn event_loop_executor(self, executor: TaskExecutor) -> Self

Utilize existing event loop executor to poll RPC results.

Applies only to 1 of the threads. Other threads will spawn their own Event Loops.

pub fn rest_api(self, rest_api: RestApi) -> Self

Enable the REST -> RPC converter.

Allows you to invoke RPCs by sending POST /<method>/<param1>/<param2> requests (with no body). Disabled by default.

pub fn health_api<A, B, T>(self, health_api: T) -> Self

where T: Into<Option<(A, B)>>, A: Into<String>, B: Into<String>,

Enable health endpoint.

Allows you to expose one of the methods under GET /<path> The method will be invoked with no parameters. Error returned from the method will be converted to status 500 response.

Expects a tuple with (<path>, <rpc-method-name>).

pub fn keep_alive(self, val: bool) -> Self

Enables or disables HTTP keep-alive.

Default is true.

pub fn threads(self, threads: usize) -> Self

Sets number of threads of the server to run.

Panics when set to 0. The first thread will use provided Executor instance and all other threads will use UninitializedExecutor to spawn a new runtime for futures. So it’s also possible to run a multi-threaded server by passing the default tokio::runtime executor to this builder and setting threads to 1.

pub fn cors( self, cors_domains: DomainsValidation<AccessControlAllowOrigin>, ) -> Self

Configures a list of allowed CORS origins.

pub fn cors_max_age<T: Into<Option<u32>>>(self, cors_max_age: T) -> Self

Configure CORS AccessControlMaxAge header returned.

Informs the client that the CORS preflight request is not necessary for cors_max_age seconds. Disabled by default.

pub fn cors_allow_headers( self, allowed_headers: AccessControlAllowHeaders, ) -> Self

Configure the CORS AccessControlAllowHeaders header which are allowed.

pub fn request_middleware<T: RequestMiddleware>(self, middleware: T) -> Self

Configures request middleware

pub fn meta_extractor<T: MetaExtractor<M>>(self, extractor: T) -> Self

Configures metadata extractor

pub fn allow_only_bind_host(self) -> Self

Allow connections only with Host header set to binding address.

pub fn allowed_hosts(self, allowed_hosts: DomainsValidation<Host>) -> Self

Specify a list of valid Host headers. Binding address is allowed automatically.

pub fn max_request_body_size(self, val: usize) -> Self

Sets the maximum size of a request body in bytes (default is 5 MiB).

pub fn start_http(self, addr: &SocketAddr) -> Result<Server>

Start this JSON-RPC HTTP server trying to bind to specified SocketAddr.