Struct GrpcDispatcher 

pub struct GrpcDispatcher { /* private fields */ }

gRPC dispatcher that routes A2A requests to a RequestHandler.

Implements the tonic A2aService trait using JSON-over-gRPC payloads. Create via GrpcDispatcher::new and serve with GrpcDispatcher::serve or build a tonic Router with GrpcDispatcher::into_service.

Implementations

impl GrpcDispatcher

pub const fn new( handler: Arc<RequestHandler>, config: GrpcConfig, ) -> GrpcDispatcher

Creates a new gRPC dispatcher wrapping the given handler.

pub async fn serve(self, addr: impl ToSocketAddrs) -> Result<(), Error>

Starts a gRPC server on the given address.

Blocks until the server shuts down. Uses the configured message size limits and concurrency settings.

Errors

Returns std::io::Error if binding fails.

pub async fn serve_with_addr( self, addr: impl ToSocketAddrs, ) -> Result<SocketAddr, Error>

Starts a gRPC server and returns the bound SocketAddr.

Like serve, but returns the address immediately and runs the server in a background task. Useful for tests.

Errors

Returns std::io::Error if binding fails.

pub fn serve_with_listener( self, listener: TcpListener, ) -> Result<SocketAddr, Error>

Starts a gRPC server on a pre-bound TcpListener.

This is the recommended approach when you need to know the server address before constructing the handler (e.g., for agent cards with correct URLs). Pre-bind the listener, extract the address, build your handler, then pass the listener here.

Returns the local address and runs the server in a background task.

Errors

Returns std::io::Error if the listener’s local address cannot be read.

pub fn into_service(&self) -> A2aServiceServer<GrpcServiceImpl>

Builds the tonic service for use with a custom server setup.

Returns an A2aServiceServer that can be added to a tonic::transport::Server via add_service.

Trait Implementations

impl Debug for GrpcDispatcher

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

Formats the value using the given formatter.