Struct CodexRunner 

pub struct CodexRunner;

Adapter for OpenAI Codex CLI (codex binary).

Headless invocation: codex exec –json “”

Stream format: NDJSON with event types:

• { type: “thread.started”, thread_id }
• { type: “turn.started” }
• { type: “item.started”, item: { id, type: “command_execution”, command, status: “in_progress”, … } }
• { type: “item.completed”, item: { id, type: “agent_message”|“command_execution”|“reasoning”, … } }
• { type: “turn.completed”, usage: { input_tokens, cached_input_tokens, output_tokens } }
• { type: “turn.failed”, error }
• { type: “error”, message }

Trait Implementations

impl AgentRunner for CodexRunner

fn name(&self) -> &str

Human-readable name of this agent backend.

fn is_available(&self) -> bool

Check whether the agent binary is available on the system.

fn binary_path(&self, config: &TaskConfig) -> Result<PathBuf>

Resolve the binary path (user override or PATH lookup).

fn build_args(&self, config: &TaskConfig) -> Vec<String>

Build the command-line arguments for the agent process.

fn build_env(&self, _config: &TaskConfig) -> Vec<(String, String)>

Build the environment variables for the agent process.

fn run<'life0, 'life1, 'async_trait>( &'life0 self, config: &'life1 TaskConfig, cancel_token: Option<CancellationToken>, ) -> Pin<Box<dyn Future<Output = Result<StreamHandle>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Run the task and return a StreamHandle with event stream and cancel token.

fn capabilities(&self) -> AgentCapabilities

What features this agent supports.

fn version(&self, config: &TaskConfig) -> Option<String>

Get the version of the installed agent binary.

fn validate_config(&self, config: &TaskConfig) -> Vec<ConfigWarning>

Validate config against this agent’s capabilities.