agentscope.rpc.rpc_agent_client module
Client of rpc agent server
- class agentscope.rpc.rpc_agent_client.RpcAgentClient(host: str, port: int, agent_id: str | None = None)[源代码]
基类:
object
A client of Rpc agent server
- __init__(host: str, port: int, agent_id: str | None = None) 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.
None. (Defaults to)
- call_agent_func(func_name: str, value: str | None = None, timeout: int = 300) str [源代码]
Call the specific function of an agent running on the server.
- 参数:
func_name (str) – The name of the function being called.
value (str, optional) – The serialized function input value.
None. (Defaults to)
timeout (int, optional) – The timeout for the RPC call in seconds.
300. (Defaults to)
- 返回:
serialized return data.
- 返回类型:
str
- is_alive() bool [源代码]
Check if the agent server is alive.
- 返回:
Indicate whether the server is alive.
- 返回类型:
bool
- create_agent(agent_configs: dict, agent_id: str | None = None) bool [源代码]
Create a new agent for this client.
- 参数:
agent_configs (dict) – Init configs of the agent, generated by
_AgentMeta.
agent_id (str) – agent_id of the created agent.
- 返回:
Indicate whether the creation is successful
- 返回类型:
bool
- delete_agent(agent_id: str | None = None) bool [源代码]
Delete agents with the specific agent_id.
- 参数:
agent_id (str) – id of the agent to be deleted.
- 返回:
Indicate whether the deletion is successful
- 返回类型:
bool
- clone_agent(agent_id: str) str | None [源代码]
Clone a new agent instance from the origin instance.
- 参数:
agent_id (str) – The agent_id of the agent to be cloned.
- 返回:
The agent_id of the generated agent.
- 返回类型:
str
- update_placeholder(task_id: int) str [源代码]
Update the placeholder value.
- 参数:
task_id (int) – task_id of the PlaceholderMessage.
- 返回:
Whether the update is successful. str: Serialized message value.
- 返回类型:
bool
- get_agent_list() Sequence[dict] [源代码]
Get the summary of all agents on the server as a list.
- 返回:
list of agent summary information.
- 返回类型:
Sequence[str]
- class agentscope.rpc.rpc_agent_client.ResponseStub[源代码]
基类:
object
A stub used to save the response of a rpc call in a sub-thread.
- agentscope.rpc.rpc_agent_client.call_in_thread(client: RpcAgentClient, value: str, func_name: str) ResponseStub [源代码]
Call rpc function in a sub-thread.
- 参数:
client (RpcAgentClient) – The rpc client.
value (str) – The value of the request.
func_name (str) – The name of the function being called.
- 返回:
A stub to get the response.
- 返回类型:
ResponseStub