包package 2.x
service-scheduler
AgentScope Java - Service Scheduler · 2.0.4
Scheduler plane: hands workers, IM channel adapters, outbound delivery
| groupIdGroupId | io.agentscope |
|---|---|
| 版本Version | 2.0.4 |
| 版本线Line | 2.x |
| 分类Category | service |
| 包Packages | 7 |
| 类型Types | 16 top-level / 17 total |
包Packages
类型Types
| 类型Type | 种类Kind | 包Package | 说明Description |
|---|---|---|---|
SchedulerApp | 类class | io.agentscope.builder | 调度器应用,承载智能体的部署、调度与服务化运行。 Entry point for the builder **scheduler plane**. |
SchedulerGateway | 类class | io.agentscope.builder.runtime | 调度器网关,承载智能体的部署、调度与服务化运行。 Scheduler transport gateway. |
OutboundController | 类class | io.agentscope.builder.runtime.outbound | 出站控制器,承载智能体的部署、调度与服务化运行。 HTTP entry point for agent-initiated / external outbound messages. |
OutboundRequest | 记录record | io.agentscope.builder.runtime.outbound | 承载出站请求数据的记录类型。 Agent-initiated outbound message request. |
OutboundService | 类class | io.agentscope.builder.runtime.outbound | 出站服务,承载智能体的部署、调度与服务化运行。 Translates an `OutboundRequest` into an `OutboundAddress` + `Msg` and pushes
it through the `ChannelManager`. |
OutboundTool | 类class | io.agentscope.builder.runtime.outbound | 出站工具,封装可被智能体调用的能力。 Agent-facing tool for proactive outbound delivery into any registered channel (DingTalk, WeCom,
...). |
ChannelRuntimeCatalog | 类class | io.agentscope.builder.web.config | 渠道运行时目录,承载智能体的部署、调度与服务化运行。 In-memory snapshot of channel configs last fetched from the control plane. |
SchedulerChannelRuntime | 类class | io.agentscope.builder.web.config | 调度器渠道运行时,承载智能体的部署、调度与服务化运行。 Scheduler channel runtime: owns the live set of IM channel adapters, refreshes config from the
control plane on an interval, and reports per-channel started/error status. |
SchedulerConfig | 类class | io.agentscope.builder.web.config | 调度器配置,保存相关配置项。 Bean assembly for the builder scheduler plane. |
SchedulerSecurityConfig | 类class | io.agentscope.builder.web.config | 调度器 Security 配置,保存相关配置项。 WebFlux Security configuration for the builder scheduler plane. |
ChannelExternalKeys | 类class | io.agentscope.builder.web.managed | 渠道外部密钥,承载智能体的部署、调度与服务化运行。 Builds stable `externalKey` values for managed-session find-or-create, aligned with
channel `dmScope`:
- MAIN DMs → `{channelId}|main`
- PER_PEER DMs / groups → `{channelId}|{peerKind}|{peerId}` from the outbound address
- Groups always use the group peer id even under MAIN (so group and DM never share a slot) |
ChannelWorkBridge | 类class | io.agentscope.builder.web.managed | 渠道 Work Bridge,承载智能体的部署、调度与服务化运行。 Authenticated, durable work intake. |
CronDeploymentScheduler | 类class | io.agentscope.builder.web.managed | Cron 部署调度器,承载智能体的部署、调度与服务化运行。 Scheduler-plane cron loop: every minute, finds due cron deployments, acquires a shared fire
lease, and asks the control plane to fire (create session + kick data-plane turn). |
ManagedSessionChannelBridge | 类class | io.agentscope.builder.web.managed | 托管会话渠道 Bridge,承载智能体的部署、调度与服务化运行。 Bridges inbound IM channel turns (DingTalk, Feishu, WeCom, GitHub, GitLab, ...) into the
managed-session model across plane boundaries:
- `POST /api/internal/sessions/find-or-create` on the **control plane** resolves
(or creates and version-pins) the session for the channel conversation;
- `POST /api/sessions/{id}/events` on the **data plane** posts the user message,
which schedules the harness turn asynchronously;
- `GET /api/sessions/{id}/events?after=seq` on the **data plane** is polled until
the turn reaches a terminal status, and the last `agent.message` text is returned
as the channel reply. |
LocalHandsToolExecutor | 类class | io.agentscope.builder.web.managed.selfhosted | 本地 Hands 工具执行器,承载智能体的部署、调度与服务化运行。 Executes the self-hosted hands toolset against a local workspace directory. |
HandsWorkerMain | 类class | io.agentscope.builder.worker | Hands 工作进程主,承载智能体的部署、调度与服务化运行。 Standalone Environment Worker for production self-hosted Hands fleets (Claude-style outbound). |