Struct TonicParameters 

pub struct TonicParameters {
    pub keepalive_interval: Duration,
    pub connection_buffer_size: usize,
    pub excessive_message_size: usize,
    pub message_size_limit: usize,
    pub max_concurrent_streams: u32,
    pub request_timeout: Duration,
    pub max_inbound_message_size: usize,
    pub admission: AdmissionParameters,
}

Fields

keepalive_interval: Duration

Keepalive interval and timeouts for both client and server.

If unspecified, this will default to 5s.

connection_buffer_size: usize

Size of various per-connection buffers.

If unspecified, this will default to 32MiB.

excessive_message_size: usize

Messages over this size threshold will increment a counter.

If unspecified, this will default to 16MiB.

message_size_limit: usize

Hard message size limit for both requests and responses. This value is higher than strictly necessary, to allow overheads. Message size targets and soft limits are computed based on this value.

If unspecified, this will default to 1GiB.

max_concurrent_streams: u32

Maximum number of concurrent HTTP/2 streams a peer may open on a single connection. Bounds per-connection request fan-out.

0 (the default) disables the limit, leaving the transport default.

request_timeout: Duration

Server-side fallback deadline for requests that omit a grpc-timeout header. The long-lived block-subscription stream is always exempt.

A zero duration (the default) disables the fallback deadline.

max_inbound_message_size: usize

Hard size limit for inbound (decoded) requests. Consensus requests are small (ref lists); large payloads belong to responses, bounded by message_size_limit. A smaller inbound bound shrinks the memory a single in-flight request can pin before its handler runs.

0 (the default) falls back to message_size_limit.

admission: AdmissionParameters

Per-peer, per-RPC admission caps for the inbound consensus server.

Implementations

impl TonicParameters

pub fn apply_protective(&mut self)

Fills the inbound resource bounds that are still at their inert defaults with the protective preset (sized for ~100-validator committees). Bounds an operator configured explicitly are kept, as are the transport settings the preset does not cover (keepalive, buffers, message_size_limit). A bound explicitly configured to its inert value still receives the preset; running without a bound requires disabling the preset itself (CONSENSUS_GRPC_PROTECTIVE_LIMITS=0).

pub fn protective() -> Self

The inert defaults with the protective bounds applied.

Trait Implementations

impl Clone for TonicParameters

fn clone(&self) -> TonicParameters

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TonicParameters

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

Formats the value using the given formatter.

impl Default for TonicParameters

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for TonicParameters

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TonicParameters

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.