多智能体并发调用 superalsrk/omni-agent-invoke-go

Omni Agent Invoke Go：Codex、Claude Code、OpenClaw 与 DeepSeek Harness

在 Go 里调用 Codex、Claude Code（CC）、OpenClaw、DeepSeek Harness（DSH）以及其他受支持的智能体 harness。由 Octo Runtime 驱动。

这是一个小巧、独立的 Go 客户端，也是可运行的 playboard，面向单独安装的 Octo Runtime Kernel。它提供一套本地执行 API，支持流式输出、显式 Context、原生输出、取消操作和并发 harness 调用。

Octo Runtime 是基础

Octo Runtime 把一组智能体 harness 变成可复用的本地基础设施。 它受监管的 Kernel、执行 worker 和 Provider 适配器为应用提供统一的执行契约，同时让 Provider 特有的能力依然可用。

这正是这个库的价值所在：你的 Go 应用可以通过一个服务边界，对接多个成熟的 harness。规范事件提供统一格式；原生 payload 保留 Provider 特有的细节。业务数据和用户体验归你的应用所有，执行基础由 Octo Runtime 提供。

去 Octo Runtime 看看，给它点个 star，读一读它的文档，再逛逛它的适配器生态。

独立服务，独立客户端

Go application / playboard
| JSON-RPC 2.0 + NDJSON over a Unix socket
v
Independently installed Octo Runtime Kernel
v
Codex / Claude Code / OpenClaw / DeepSeek Harness / ...

这个库不依赖上游 Runtime 源码或 SDK 包。它实现公开的 Kernel IPC，并自带生成的协议身份声明。它不启动 Runtime，也不安装或认证 Provider。独立的 Runtime 服务需要 Node.js；Go 客户端使用自己的语言工具链。

这是一个独立的社区项目，不是官方 Octo Runtime SDK。0.1 版本面向 macOS/Linux 的 Unix socket。

安装与运行

要求：Go 1.25+，以及单独安装的 Runtime 和已认证的 Provider。

Install and start the foundation service independently.
npm install -g @mininglamp-oss/octo-runtime
octo-runtime executor-kernel start

git clone https://github.com/superalsrk/omni-agent-invoke-go.git
cd omni-agent-invoke-go
mkdir -p .tmp
go build -o .tmp/playboard ./cmd/playboard

Use your actual endpoint for custom Runtime Homes/profiles.
export OCTO_KERNEL_ENDPOINT="$HOME/.octo-runtime/sockets/octo-runtime-executor-kernel.sock"
.tmp/playboard status
.tmp/playboard list
.tmp/playboard playboard --adapter codex --mode canonical \
--prompt 'Reply with OK without using tools.' --receipt .tmp/first-run.json
已经在运行 Kernel？跳过安装和启动，让客户端指向它现有的 socket。每个服务商单独认证；Runtime 不会替你登录。

Go API

import omni "github.com/superalsrk/omni-agent-invoke-go"

client := omni.Attach(os.Getenv("OCTO_KERNEL_ENDPOINT"))
defer client.Close()
stream, err := client.Invoke("codex", "Say hello.")
if err != nil { return err }
defer stream.Close()
for {
frame, err := stream.Next()
if err == io.EOF { break }
if err != nil { return err }
fmt.Println(frame)
}

完整可运行的程序见 examples，其中包含 import 和终态检查。

四个入口把上下文和模式显式区分开：

client.Invoke("codex", prompt)
client.InvokeWithContext("codex", prompt, context)
client.InvokeNative("codex", prompt)
client.InvokeNativeWithContext("codex", prompt, context)

前两个选 canonical 模式，native 变体选 native 模式。它们都返回完整的 HostFrame：canonical 内容在 frame.event，native 内容在 frame.payload，执行终态在 frame.control。把一次执行当作成功之前，务必先消费并检查终态。

Context 指 Octo 的执行/后台信封。显式条目会与选中的 Adapter 以及默认的 ask 审批策略合并。类型化 Context、纯文本 Input 和图片 Input 的示例见 examples/README.md。图片辅助工具提供 base64、字节长度和 SHA-256 元数据。

DeepSeek Harness 与其他服务商

DeepSeek Harness（DSH） 使用 Adapter ID dsh：

.tmp/playboard playboard --adapter dsh --mode canonical --prompt 'Reply with OK.'
.tmp/playboard playboard --adapter claude-code --mode canonical --prompt 'Reply with OK.'
.tmp/playboard playboard --request examples/openclaw-request.json

DSH 必须先安装并配置好，再由独立运行的 Runtime 注册。参见 上游 DSH Adapter 指南。只有选中的 Adapter 声明支持时，才能用 native 模式。OpenClaw 用一个 Context 条目选中已有的 Gateway Agent，例如 provider_agent_id: "main"。

共用一套执行 API 不代表各服务商能力相同。查 list 和上游指南。对 Codex 做过实机验证，不等于每个服务商都测过。

并发调用 Harness

go run ./examples/concurrent codex claude-code openclaw dsh

本地只有 Codex？把 Adapter 参数换成 codex codex，就能跑两个独立的并发调用。示例会等待所有任务结束，并逐个报告失败。

Playboard 与显式控制

.tmp/playboard playboard --adapter codex --mode native --prompt 'Say hello.' --context examples/context.json
.tmp/playboard submit --adapter codex --prompt 'Say hello.' --receipt .tmp/submitted-run.json
.tmp/playboard get --ref .tmp/submitted-run.json
.tmp/playboard subscribe --ref .tmp/submitted-run.json --after 0
.tmp/playboard cancel --ref .tmp/submitted-run.json --reason user_cancelled
.tmp/playboard respond --ref .tmp/submitted-run.json --response answer.json
.tmp/playboard native-respond --ref .tmp/submitted-run.json --response native-answer.json

stdout 输出 NDJSON。保存完整 RunRef，方便恢复。回执写入新文件，不覆盖旧文件。--timeout 是执行截止时间，单位为秒；超时后 playboard 请求取消，并观察一小段收尾。关闭观察，或客户端断开，都不会停止 Kernel，也不会自动取消已受理的运行。

受理 ACK 丢失后，只能按原始身份查询来恢复。结果未知时，控制操作绝不自动重放。身份校验、分帧、恢复与生命周期限制，见协议设计。

本地验证

go test -race ./...
go vet ./...
node scripts/live-smoke.mjs

显式 live smoke 使用现有 Kernel 和已认证的 Codex，验证规范调用与原生调用、回执查询和重放。它不安装也不停止 Runtime。证据记录在 docs/live-smoke.json，不含服务商原始输出。不添加 GitHub workflow，也不加 CI 门禁。平台与 live 服务商的限制记录在验证。

生态与许可

Octo Runtime 是独立的基础服务。其他客户端库：Rust、TypeScript、Python、Go。

MIT License。协议类型独立生成，未内置上游实现。各项目与服务商厂商相互独立，不构成任何背书。