Struct RequestHandlerBuilder 

pub struct RequestHandlerBuilder { /* private fields */ }

Fluent builder for RequestHandler.

Required

• executor: Any AgentExecutor implementation (passed as a concrete type; the builder erases it to Arc<dyn AgentExecutor> during build).

Optional (with defaults)

• task_store: defaults to InMemoryTaskStore.
• push_config_store: defaults to InMemoryPushConfigStore.
• push_sender: defaults to None.
• interceptors: defaults to an empty chain.
• agent_card: defaults to None.

Implementations

impl RequestHandlerBuilder

pub fn new(executor: impl AgentExecutor) -> Self

Creates a new builder with the given executor.

The executor is type-erased to Arc<dyn AgentExecutor>.

pub fn with_task_store(self, store: impl TaskStore + 'static) -> Self

Sets a custom task store.

pub const fn with_task_store_config(self, config: TaskStoreConfig) -> Self

Configures the default InMemoryTaskStore with custom TTL and capacity settings.

This is ignored if a custom task store is set via with_task_store.

pub fn with_push_config_store( self, store: impl PushConfigStore + 'static, ) -> Self

Sets a custom push configuration store.

pub fn with_push_sender(self, sender: impl PushSender + 'static) -> Self

Sets a push notification sender.

pub fn with_interceptor( self, interceptor: impl ServerInterceptor + 'static, ) -> Self

Adds a server interceptor to the chain.

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

Sets a timeout for executor execution.

If the executor does not complete within this duration, the task is marked as failed with a timeout error.

pub fn with_agent_card(self, card: AgentCard) -> Self

Sets the agent card for discovery responses.

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

Sets the event queue channel capacity for streaming.

Defaults to 64 items. Higher values allow more events to be buffered before backpressure is applied.

pub const fn with_max_event_size(self, max_event_size: usize) -> Self

Sets the maximum serialized event size in bytes.

Events exceeding this size are rejected to prevent OOM conditions. Defaults to 16 MiB.

pub const fn with_max_concurrent_streams(self, max: usize) -> Self

Sets the maximum number of concurrent streaming event queues.

Limits memory usage from concurrent streams. When the limit is reached, new streaming requests will fail.

pub fn with_metrics(self, metrics: impl Metrics + 'static) -> Self

Sets a metrics observer for handler activity.

Defaults to NoopMetrics which discards all events.

pub fn build(self) -> ServerResult<RequestHandler>

Builds the RequestHandler.

Errors

Returns ServerError::InvalidParams if the configuration is invalid:

• Agent card with empty supported_interfaces
• Zero executor timeout (would cause immediate timeouts)

Trait Implementations

impl Debug for RequestHandlerBuilder

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

Formats the value using the given formatter.