Struct AgentServer 

pub struct AgentServer<A: Agent> { /* private fields */ }

Agent gRPC server.

Wraps an Agent implementation and exposes it as a gRPC service.

Implementations

impl<A: Agent> AgentServer<A>

pub fn new(agent: A) -> Self

Create a new agent server.

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

Start serving on the given address.

Example

AgentServer::new(MyAgent)
    .serve("0.0.0.0:50051")
    .await
    .unwrap();

pub fn into_service(self) -> AgentServiceServer<AgentServiceImpl<A>>

Get the gRPC service for custom server configuration.