Worker 任务操作
在 BlockX 仓库中,api/grpc/worker/worker.proto 定义 Worker 服务,api/grpc/bundleworker/bundle_worker.proto 定义 bundle 服务身份。
执行期间保持 Watch 连接。其生命周期参与任务执行;见执行语义。
TaskInput
Go JSON 表示使用
functionCallConfig、resultHandler 和 taskTimeoutMs,与 protobuf 字段名不同。Plugin 配置保留自己的 JSON 键;见任务配置。
Coordinator 选址
CoordinatorService.ReserveWorkerSlot 与 BundleCoordinatorService.ReserveWorkerSlot 在对应部署预占容量。提供 task_id,再使用返回的 worker_addr 和 slot_id 提交。Coordinator 选择资源,Worker 执行任务并报告结果。
协议来源:api/grpc/coordinator/coordinator.proto 和 api/grpc/bundlecoordinator/bundle_coordinator.proto。
同步调用
定义位于api/grpc/syncinvoker/sync_invoker.proto。
function_id 与 inline_source 必须恰好选择一个。args_json 包含 JSON 数组。deadline_unix_ms 是绝对截止时间,与任务的时长字段不同。