pub struct RequestResponseConfig {
    pub name: Cow<'static, str>,
    pub max_request_size: u64,
    pub max_response_size: u64,
    pub request_timeout: Duration,
    pub inbound_queue: Option<Sender<IncomingRequest>>,
}
Expand description

Configuration for a single request-response protocol.

Fields

name: Cow<'static, str>

Name of the protocol on the wire. Should be something like /foo/bar.

max_request_size: u64

Maximum allowed size, in bytes, of a request.

Any request larger than this value will be declined as a way to avoid allocating too much memory for it.

max_response_size: u64

Maximum allowed size, in bytes, of a response.

Any response larger than this value will be declined as a way to avoid allocating too much memory for it.

request_timeout: Duration

Duration after which emitted requests are considered timed out.

If you expect the response to come back quickly, you should set this to a smaller duration.

inbound_queue: Option<Sender<IncomingRequest>>

Channel on which the networking service will send incoming requests.

Every time a peer sends a request to the local node using this protocol, the networking service will push an element on this channel. The receiving side of this channel then has to pull this element, process the request, and send back the response to send back to the peer.

The size of the channel has to be carefully chosen. If the channel is full, the networking service will discard the incoming request send back an error to the peer. Consequently, the channel being full is an indicator that the node is overloaded.

You can typically set the size of the channel to T / d, where T is the request_timeout and d is the expected average duration of CPU and I/O it takes to build a response.

Can be None if the local node does not support answering incoming requests. If this is None, then the local node will not advertise support for this protocol towards other peers. If this is Some but the channel is closed, then the local node will advertise support for this protocol, but any incoming request will lead to an error being sent back.

Trait Implementations

Returns a copy of the value. Read more

Performs copy-assignment from source. Read more

Formats the value using the given formatter. Read more

Auto Trait Implementations

Blanket Implementations

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

Convert from a value of T into an equivalent instance of Option<Self>. Read more

Consume self to return Some equivalent value of Option<T>. Read more

Returns the argument unchanged.

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Get a reference to the inner from the outer.

Get a mutable reference to the inner from the outer.

The alignment of pointer.

The type for initializers.

Initializes a with the given initializer. Read more

Dereferences the given pointer. Read more

Mutably dereferences the given pointer. Read more

Drops the object pointed to by the given pointer. Read more

Should always be Self

Convert from a value of T into an equivalent instance of Self. Read more

Consume self to return an equivalent value of T. Read more

The resulting type after obtaining ownership.

Creates owned data from borrowed data, usually by cloning. Read more

🔬 This is a nightly-only experimental API. (toowned_clone_into)

Uses borrowed data to replace owned data, usually by cloning. Read more

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.

The counterpart to unchecked_from.

Consume self to return an equivalent value of T.

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more