pub struct GrpcConfig {
pub max_message_size: usize,
pub concurrency_limit: usize,
pub stream_channel_capacity: usize,
}Expand description
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: usizeMaximum inbound message size in bytes. Default: 4 MiB.
concurrency_limit: usizeMaximum number of concurrent gRPC requests. Default: 256.
stream_channel_capacity: usizeChannel capacity for streaming responses. Default: 64.
Implementations§
Source§impl GrpcConfig
impl GrpcConfig
Sourcepub const fn with_max_message_size(self, size: usize) -> GrpcConfig
pub const fn with_max_message_size(self, size: usize) -> GrpcConfig
Sets the maximum inbound message size.
Sourcepub const fn with_concurrency_limit(self, limit: usize) -> GrpcConfig
pub const fn with_concurrency_limit(self, limit: usize) -> GrpcConfig
Sets the maximum number of concurrent gRPC requests.
Sourcepub const fn with_stream_channel_capacity(self, capacity: usize) -> GrpcConfig
pub const fn with_stream_channel_capacity(self, capacity: usize) -> GrpcConfig
Sets the channel capacity for streaming responses.
Trait Implementations§
Source§impl Clone for GrpcConfig
impl Clone for GrpcConfig
Source§fn clone(&self) -> GrpcConfig
fn clone(&self) -> GrpcConfig
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for GrpcConfig
impl Debug for GrpcConfig
Source§impl Default for GrpcConfig
impl Default for GrpcConfig
Source§fn default() -> GrpcConfig
fn default() -> GrpcConfig
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for GrpcConfig
impl RefUnwindSafe for GrpcConfig
impl Send for GrpcConfig
impl Sync for GrpcConfig
impl Unpin for GrpcConfig
impl UnsafeUnpin for GrpcConfig
impl UnwindSafe for GrpcConfig
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request