Documentation
¶
Overview ¶
Package broker is a thin REST→ws codex v2 JSON-RPC adapter inside CXG. It owns no business logic: it converts a single /api/turns REST call into a turn lifecycle on a loopback ws to a codex app-server subprocess, returning the resulting codex Turn object verbatim.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Conn ¶
type Conn struct {
// contains filtered or unexported fields
}
Conn is one loopback ws to a codex app-server subprocess. Safe for concurrent Turn() / StartThread() calls — internally serializes writes and demuxes responses + turn/completed notifications.
func Dial ¶
Dial opens a fresh ws, performs the codex initialize / initialized handshake, and starts the reader goroutine. Caller must Close().
func (*Conn) StartThread ¶
StartThread issues thread/start with empty params and returns the new thread id. Other ThreadStartResponse fields are discarded — CXG only owns the loopback, agentserver tracks per-conversation state.
func (*Conn) Turn ¶
func (c *Conn) Turn(ctx context.Context, threadID string, callerParams json.RawMessage, timeout time.Duration) (json.RawMessage, error)
Turn sends turn/start and blocks until the matching turn/completed notification arrives or timeout elapses. Returns the raw codex Turn JSON for verbatim REST passthrough.
type Pool ¶
type Pool struct {
// contains filtered or unexported fields
}
Pool caches one *Conn per workspace id. Connections idle for longer than idleTTL are reaped and closed. Safe for concurrent use.
func NewPool ¶
func NewPool(resolver WSURLResolver, idleTTL time.Duration) *Pool
NewPool starts a background reaper goroutine. Caller must Close().
func (*Pool) Close ¶
func (p *Pool) Close()
Close stops the reaper and closes all live connections. It is safe to call Close more than once; subsequent calls are no-ops.
type TimeoutError ¶
type TimeoutError struct {
ThreadID, TurnID string
}
TimeoutError is returned when timeoutMs elapses without turn/completed.
func (*TimeoutError) Error ¶
func (e *TimeoutError) Error() string
type TurnRPCError ¶
type TurnRPCError struct {
Code int
Message string
Data json.RawMessage
}
TurnRPCError is returned by Turn when codex returns a JSON-RPC error in response to turn/start (rare; usually means malformed request).
func (*TurnRPCError) Error ¶
func (e *TurnRPCError) Error() string
Source Files