Struct DispatchConfig 

pub struct DispatchConfig {
    pub max_request_body_size: usize,
    pub body_read_timeout: Duration,
    pub max_query_string_length: usize,
    pub sse_keep_alive_interval: Duration,
    pub sse_channel_capacity: usize,
    pub max_batch_size: usize,
}

Configuration for dispatch-layer limits shared by both JSON-RPC and REST dispatchers.

All fields have sensible defaults. Create with DispatchConfig::default() and override individual values as needed.

Example

use a2a_protocol_server::dispatch::DispatchConfig;

let config = DispatchConfig::default()
    .with_max_request_body_size(8 * 1024 * 1024)
    .with_body_read_timeout(std::time::Duration::from_secs(60));

Fields

max_request_body_size: usize

Maximum request body size in bytes. Default: 4 MiB.

body_read_timeout: Duration

Timeout for reading the full request body. Default: 30 seconds.

max_query_string_length: usize

Maximum query string length (REST only). Default: 4096.

sse_keep_alive_interval: Duration

SSE keep-alive interval. Default: 30 seconds.

Periodic : keep-alive comments are sent at this interval to prevent proxies and load balancers from closing idle SSE connections.

sse_channel_capacity: usize

SSE response body channel capacity. Default: 64.

Controls backpressure between the event reader task and the HTTP response body. Higher values buffer more SSE frames in memory.

max_batch_size: usize

Maximum number of requests allowed in a JSON-RPC batch. Default: 100.

Batches exceeding this limit are rejected with a parse error before any individual request is dispatched.

Implementations

impl DispatchConfig

pub const fn with_max_request_body_size(self, size: usize) -> Self

Sets the maximum request body size in bytes.

pub const fn with_body_read_timeout(self, timeout: Duration) -> Self

Sets the timeout for reading request bodies.

pub const fn with_max_query_string_length(self, length: usize) -> Self

Sets the maximum query string length (REST only).

pub const fn with_sse_keep_alive_interval(self, interval: Duration) -> Self

Sets the SSE keep-alive interval.

pub const fn with_sse_channel_capacity(self, capacity: usize) -> Self

Sets the SSE response body channel capacity.

pub const fn with_max_batch_size(self, size: usize) -> Self

Sets the maximum JSON-RPC batch size.

Trait Implementations

impl Clone for DispatchConfig

fn clone(&self) -> DispatchConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DispatchConfig

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

Formats the value using the given formatter.

impl Default for DispatchConfig

fn default() -> Self

Returns the “default value” for a type.