agentscope.rpc

Import all rpc related modules in the package.

class agentscope.rpc.RpcAgentClient(host: str, port: int, agent_id: str = '')

基类：object

A client of Rpc agent server

__init__(host: str, port: int, agent_id: str = '') → None

Init a rpc agent client

参数:

• host (str) – the hostname of the rpc agent server which the

• connected. (is)

• port (int) – the port of the rpc agent server which the client

• connected.

• agent_id (str) – the agent id of the agent being called.

call_func(func_name: str, value: str | None = None, timeout: int = 300) → str

Call the specific function of rpc server.

参数:

• func_name (str) – the name of the function being called.

• x (str, optional) – the seralized input value. Defaults to None.

返回:

serialized return data.

返回类型:

str

create_agent(agent_configs: dict) → None

Create a new agent for this client.

delete_agent() → None

Delete the agent created by this client.

class agentscope.rpc.ResponseStub

基类：object

A stub used to save the response of an rpc call in a sub-thread.

__init__() → None

set_response(response: str) → None

Set the message.

get_response() → str

Get the message.

class agentscope.rpc.RpcMsg

基类：Message, Message

DESCRIPTOR = <google._upb._message.Descriptor object>

class agentscope.rpc.RpcAgentServicer

基类：object

Servicer for rpc agent server

call_func(request, context)

Missing associated documentation comment in .proto file.

class agentscope.rpc.RpcAgentStub(channel)

基类：object

Servicer for rpc agent server

__init__(channel)

Constructor.

参数:

channel – A grpc.Channel.

agentscope.rpc.call_in_thread(client: RpcAgentClient, value: str, func_name: str) → ResponseStub

Call rpc function in a sub-thread.

参数:

• client (RpcAgentClient) – the rpc client.

• x (str) – the value of the reqeust.

• func_name (str) – the name of the function being called.

返回:

a stub to get the response.

返回类型:

ResponseStub

agentscope.rpc.add_RpcAgentServicer_to_server(servicer, server)