类class io.agentscope.extensions.aistio.store 2.x

ControlPlaneAsyncToolRegistry

public final class ControlPlaneAsyncToolRegistry implements AsyncToolRegistry

源码Source io/agentscope/extensions/aistio/store/ControlPlaneAsyncToolRegistry.java:38–233

控制面异步工具注册表，承载智能体的部署、调度与服务化运行。位于 io.agentscope.extensions.aistio.store 包，实现 AsyncToolRegistry。核心成员包括 register、complete、fail、findStale、markTimeout。

Control-plane hosted AsyncToolRegistry over /api/v1/dp/async-tools/*.

方法摘要Method Summary

方法Method	说明Description
`public Mono<Void> register(AsyncToolRecord record)`	设置注册。 Performs the register operation.
`public Mono<Void> complete(String id, String result)`	执行 `complete` 方法。 Performs the complete operation.
`public Mono<Void> fail(String id, String error)`	执行 `fail` 方法。 Performs the fail operation.
`public Mono<List<AsyncToolRecord>> findStale(String sessionId, Duration ttl)`	查找过期。 Finds the stale.
`public Mono<Void> markTimeout(String id)`	设置该参数。 Performs the mark timeout operation.

方法详情Method Detail

register

public Mono<Void> register(AsyncToolRecord record)

设置注册。

Performs the register operation.

参数Parameters

名称Name	类型Type	说明Description
`record`	AsyncToolRecord	记录（类型 `AsyncToolRecord`）。The record.

返回Returns Mono<Void>

返回Mono。Returns mono.

源码Source io/agentscope/extensions/aistio/store/ControlPlaneAsyncToolRegistry.java:52–77

complete

public Mono<Void> complete(String id, String result)

执行 complete 方法。

Performs the complete operation.

参数Parameters

名称Name	类型Type	说明Description
`id`	String	标识（类型 `String`）。The id.
`result`	String	结果（类型 `String`）。The result.

返回Returns Mono<Void>

返回Mono。Returns mono.

源码Source io/agentscope/extensions/aistio/store/ControlPlaneAsyncToolRegistry.java:79–101

fail

public Mono<Void> fail(String id, String error)

执行 fail 方法。

Performs the fail operation.

参数Parameters

名称Name	类型Type	说明Description
`id`	String	标识（类型 `String`）。The id.
`error`	String	错误（类型 `String`）。The error.

返回Returns Mono<Void>

返回Mono。Returns mono.

源码Source io/agentscope/extensions/aistio/store/ControlPlaneAsyncToolRegistry.java:103–123

findStale

public Mono<List<AsyncToolRecord>> findStale(String sessionId, Duration ttl)

查找过期。

Finds the stale.

参数Parameters

名称Name	类型Type	说明Description
`sessionId`	String	会话标识（类型 `String`）。The session id.
`ttl`	Duration	存活时间（类型 `Duration`）。The ttl.

返回Returns Mono<List<AsyncToolRecord>>

返回Mono>。Returns mono.

源码Source io/agentscope/extensions/aistio/store/ControlPlaneAsyncToolRegistry.java:125–153

markTimeout

public Mono<Void> markTimeout(String id)

设置该参数。

Performs the mark timeout operation.

参数Parameters

名称Name	类型Type	说明Description
`id`	String	标识（类型 `String`）。The id.

返回Returns Mono<Void>

返回Mono。Returns mono.

源码Source io/agentscope/extensions/aistio/store/ControlPlaneAsyncToolRegistry.java:155–176