Struct GrpcConfig 

pub struct GrpcConfig {
    pub max_message_size: usize,
    pub concurrency_limit: usize,
    pub stream_channel_capacity: usize,
    pub require_version_header: bool,
}

Configuration for the gRPC dispatcher.

Controls message size limits, compression, and concurrency settings.

Example

use a2a_protocol_server::dispatch::grpc::GrpcConfig;

let config = GrpcConfig::default()
    .with_max_message_size(8 * 1024 * 1024)
    .with_concurrency_limit(128);

Fields

max_message_size: usize

Maximum inbound message size in bytes. Default: 4 MiB.

concurrency_limit: usize

Maximum number of concurrent gRPC requests. Default: 256.

stream_channel_capacity: usize

Channel capacity for streaming responses. Default: 64.

require_version_header: bool

Whether to reject a request whose a2a-version metadata is absent or empty. Per spec §3.6.2 an absent value is interpreted as protocol 0.3, which this 1.x server does not support, so the strict default (true) rejects it with VersionNotSupported — matching the JSON-RPC, REST and WebSocket bindings. Set false only to admit versionless legacy clients. Default: true.

Implementations

impl GrpcConfig

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

Sets the maximum inbound message size.

pub const fn with_concurrency_limit(self, limit: usize) -> Self

Sets the maximum number of concurrent gRPC requests.

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

Sets the channel capacity for streaming responses.

pub const fn with_require_version_header(self, require: bool) -> Self

Sets whether an absent/empty a2a-version is rejected (see the field).

Trait Implementations

impl Clone for GrpcConfig

fn clone(&self) -> GrpcConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GrpcConfig

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

Formats the value using the given formatter.

impl Default for GrpcConfig

fn default() -> Self

Returns the “default value” for a type.