[][src]Struct jsonrpc_http_server::ServerBuilder

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

Convenient JSON-RPC HTTP Server builder.

Methods

impl<M: Metadata + Default, S: Middleware<M>> ServerBuilder<M, S>[src]

pub fn new<T>(handler: T) -> Self where
    T: Into<MetaIoHandler<M, S>>, 
[src]

Creates new ServerBuilder for given IoHandler.

By default:

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

impl<M: Metadata, S: Middleware<M>> ServerBuilder<M, S>[src]

pub fn with_meta_extractor<T, E>(handler: T, extractor: E) -> Self where
    T: Into<MetaIoHandler<M, S>>,
    E: MetaExtractor<M>, 
[src]

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[src]

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[src]

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>, 
[src]

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[src]

Enables or disables HTTP keep-alive.

Default is true.

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

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
[src]

Configures a list of allowed CORS origins.

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

Configure CORS AccessControlMaxAge header returned.

Passing Some(millis) informs the client that the CORS preflight request is not necessary for at least millis ms. Disabled by default.

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

Configure the CORS AccessControlAllowHeaders header which are allowed.

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

Configures request middleware

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

Configures metadata extractor

pub fn allow_only_bind_host(self) -> Self[src]

Allow connections only with Host header set to binding address.

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

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

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

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

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

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

Auto Trait Implementations

impl<M, S> Unpin for ServerBuilder<M, S>

impl<M, S> Sync for ServerBuilder<M, S>

impl<M, S> Send for ServerBuilder<M, S>

impl<M = (), S = Noop> !UnwindSafe for ServerBuilder<M, S>

impl<M = (), S = Noop> !RefUnwindSafe for ServerBuilder<M, S>

Blanket Implementations

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> Any for T where
    T: 'static + ?Sized
[src]