Struct CodexAppServerClient 

pub struct CodexAppServerClient<T: AppServerLineTransport> { /* private fields */ }

Drives the pure transcript state machine through an injected line transport.

Implementations

impl CodexAppServerClient<OwnedAppServerTransport>

pub fn spawn( config: &OwnedAppServerConfig, ) -> Result<Self, AppServerProcessError>

pub fn spawn_with_tool_policy( config: &OwnedAppServerConfig, tool_policy: CodexToolPolicy, ) -> Result<Self, AppServerProcessError>

impl<T: AppServerLineTransport> CodexAppServerClient<T>

pub fn new( transport: T, operation_timeout: Duration, ) -> Result<Self, AppServerProcessError>

pub fn new_with_tool_policy( transport: T, operation_timeout: Duration, tool_policy: CodexToolPolicy, ) -> Result<Self, AppServerProcessError>

pub fn require_reviewed_cli_version(&mut self)

Require the exact reviewed standalone CLI version during initialize. Injected transcript transports use this same guard as owned processes.

pub fn require_app_server_version( &mut self, version: &str, ) -> Result<(), AppServerProcessError>

Requires the already pinned executable’s reviewed app-server version. This is intentionally a closed string supplied by the owned-child configuration, never by a provider response or request payload.

pub fn initialize(&mut self) -> Result<(), AppServerProcessError>

pub fn discover( &mut self, ) -> Result<AppServerDiscoveryReceipt, AppServerProcessError>

pub fn start_turn( &mut self, client_message_id: &str, text: &str, model: &str, effort: ReasoningEffort, ) -> Result<ActiveCodexTurn, AppServerProcessError>

pub fn start_turn_with_instructions( &mut self, client_message_id: &str, text: &str, base_instructions: Option<&str>, developer_instructions: Option<&str>, model: &str, effort: ReasoningEffort, ) -> Result<ActiveCodexTurn, AppServerProcessError>

pub fn wait_for_terminal( &mut self, turn: &ActiveCodexTurn, ) -> Result<TurnRunReceipt, AppServerProcessError>

pub fn wait_for_terminal_with_cancellation( &mut self, turn: &ActiveCodexTurn, cancelled: impl Fn() -> bool, ) -> Result<TurnRunReceipt, AppServerProcessError>

Wait for a terminal while honoring the caller’s one cancellation authority. Cancellation after turn/start sends turn/interrupt on the same owned client and joins the terminal lifecycle before returning.

pub fn interrupt( &mut self, turn: &ActiveCodexTurn, ) -> Result<TurnRunReceipt, AppServerProcessError>

pub fn shutdown(&mut self) -> Result<ShutdownReceipt, AppServerProcessError>

pub fn into_transport(self) -> T

Trait Implementations

impl<T: AppServerLineTransport> Debug for CodexAppServerClient<T>

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.