Struct AppServerImageProvider 

pub struct AppServerImageProvider { /* private fields */ }

Provider backed by one initialized app-server connection.

Implementations

impl AppServerImageProvider

pub fn new( rpc: Arc<AppServerRpc>, sessions: Arc<dyn SessionBindingStore>, config: AppServerProviderConfig, ) -> Self

Creates a provider over an existing initialized connection.

pub fn new_with_inputs( rpc: Arc<AppServerRpc>, sessions: Arc<dyn SessionBindingStore>, config: AppServerProviderConfig, reference_inputs: AppServerReferenceInputs, ) -> Self

Creates a provider over an existing connection with secure references.

pub fn with_process( process: Arc<CodexProcess>, sessions: Arc<dyn SessionBindingStore>, config: AppServerProviderConfig, ) -> Self

Creates a provider that owns and shuts down its Codex child process.

pub fn with_process_and_inputs( process: Arc<CodexProcess>, sessions: Arc<dyn SessionBindingStore>, config: AppServerProviderConfig, reference_inputs: AppServerReferenceInputs, ) -> Self

Creates an owned provider with secure bridge-staged reference inputs.

Trait Implementations

impl Debug for AppServerImageProvider

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

Formats the value using the given formatter.

impl ImageProvider for AppServerImageProvider

fn descriptor(&self) -> ProviderDescriptor

Returns stable provider identity.

fn capabilities<'life0, 'life1, 'async_trait>( &'life0 self, model: Option<&'life1 str>, ) -> Pin<Box<dyn Future<Output = Result<ProviderCapabilities, BridgeError>> + Send + 'async_trait>>

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

Returns current capabilities for an optional model.

fn execute<'life0, 'async_trait>( &'life0 self, request: ImageRequest, context: ProviderContext, ) -> Pin<Box<dyn Future<Output = Result<ImageResponse, BridgeError>> + Send + 'async_trait>>

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

Executes one normalized request without exposing incremental events.

fn check_ready<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), BridgeError>> + Send + 'async_trait>>

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

Performs a non-generating auth/readiness check.

fn get_session<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<SessionMetadata, BridgeError>> + Send + 'async_trait>>

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

Looks up caller-visible persistent session metadata when supported.

fn delete_session<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), BridgeError>> + Send + 'async_trait>>

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

Deletes a persistent session binding when supported.

fn restart_count(&self) -> Option<u64>

Returns the number of supervised provider process restarts when exposed.

fn shutdown<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), BridgeError>> + Send + 'async_trait>>

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

Releases provider resources during graceful shutdown.

fn execute_stream<'life0, 'async_trait>( &'life0 self, _request: ImageRequest, _context: ProviderContext, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<ProviderEvent, BridgeError>> + Send>>, BridgeError>> + Send + 'async_trait>>

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

Starts a request with incremental events when supported.