Struct CoordinatedRuntimeClient 

pub struct CoordinatedRuntimeClient { /* private fields */ }

Authenticated client projection of one coordinated SDK runtime.

Implementations

impl CoordinatedRuntimeClient

pub fn client_id(&self) -> &RuntimeClientId

Opaque authenticated identity used by lease snapshots and transports.

pub fn observe(&self) -> Result<RuntimeLeaseSnapshot, SdkError>

Attach or refresh this observer and return current ownership state.

pub fn take_control(&self) -> Result<RuntimeLeaseSnapshot, SdkError>

Explicitly take the controller lease from another interactive client.

pub fn heartbeat(&self) -> Result<RuntimeLeaseSnapshot, SdkError>

Refresh this client’s observer activity and controller lease when it currently owns control.

pub fn detach(&self) -> RuntimeLeaseSnapshot

Release observation and controller ownership without closing the SDK-owned runtime.

pub fn lease_snapshot(&self) -> Result<RuntimeLeaseSnapshot, SdkError>

Current ownership state, visible only to observers.

Trait Implementations

impl SdkRuntime for CoordinatedRuntimeClient

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

where 'life0: 'async_trait, CoordinatedRuntimeClient: 'async_trait,

Describe runtime identity, modules, commands, actions, and state.

fn attach<'life0, 'async_trait>( &'life0 self, history_limit: usize, ) -> Pin<Box<dyn Future<Output = Result<FrontendAttachment, SdkError>> + Send + 'async_trait>>

where 'life0: 'async_trait, CoordinatedRuntimeClient: 'async_trait,

Atomically attach at the canonical history/live-event boundary.

fn send_input<'async_trait>( self: Arc<CoordinatedRuntimeClient>, prompt: String, ) -> Pin<Box<dyn Future<Output = Result<(), SdkError>> + Send + 'async_trait>>

where CoordinatedRuntimeClient: 'async_trait,

Atomically accept a new user turn and return once ownership is claimed.

fn send_input_with_images<'async_trait>( self: Arc<CoordinatedRuntimeClient>, prompt: String, image_urls: Vec<String>, ) -> Pin<Box<dyn Future<Output = Result<(), SdkError>> + Send + 'async_trait>>

where CoordinatedRuntimeClient: 'async_trait,

Atomically accept a multimodal user turn and return once ownership is claimed. Implementations must preserve images natively or reject the action; silently folding them into text is never allowed.

fn submit<'life0, 'async_trait>( &'life0 self, prompt: String, ) -> Pin<Box<dyn Future<Output = Result<String, SdkError>> + Send + 'async_trait>>

where 'life0: 'async_trait, CoordinatedRuntimeClient: 'async_trait,

Submit a new user turn.

fn submit_with_images<'life0, 'async_trait>( &'life0 self, prompt: String, image_urls: Vec<String>, ) -> Pin<Box<dyn Future<Output = Result<String, SdkError>> + Send + 'async_trait>>

where 'life0: 'async_trait, CoordinatedRuntimeClient: 'async_trait,

Submit a new user turn with canonical multimodal image inputs.

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

where 'life0: 'async_trait, CoordinatedRuntimeClient: 'async_trait,

Interrupt an active turn.

fn steer<'life0, 'async_trait>( &'life0 self, prompt: String, ) -> Pin<Box<dyn Future<Output = Result<(), SdkError>> + Send + 'async_trait>>

where 'life0: 'async_trait, CoordinatedRuntimeClient: 'async_trait,

Queue a steering instruction when supported.

fn respond<'life0, 'async_trait>( &'life0 self, response: FrontendResponse, ) -> Pin<Box<dyn Future<Output = Result<(), SdkError>> + Send + 'async_trait>>

where 'life0: 'async_trait, CoordinatedRuntimeClient: 'async_trait,

Answer a typed runtime request when supported.

fn invoke<'life0, 'async_trait>( &'life0 self, operation: FrontendOperationInvocation, ) -> Pin<Box<dyn Future<Output = Result<FrontendOperationResult, SdkError>> + Send + 'async_trait>>

where 'life0: 'async_trait, CoordinatedRuntimeClient: 'async_trait,

Invoke one operation from the descriptor’s explicit catalog.

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

where 'life0: 'async_trait, CoordinatedRuntimeClient: 'async_trait,

Read the one-controller/many-observer ownership state.

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

where 'life0: 'async_trait, CoordinatedRuntimeClient: 'async_trait,

Explicitly acquire the controller lease from another interactive client. Ordinary mutations never perform an implicit takeover.

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

where 'life0: 'async_trait, CoordinatedRuntimeClient: 'async_trait,

Refresh observer activity and a controller lease owned by this client.

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

where 'life0: 'async_trait, CoordinatedRuntimeClient: 'async_trait,

Release this client’s observer/controller state without stopping the runtime.

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

where 'life0: 'async_trait, CoordinatedRuntimeClient: 'async_trait,

Explicitly close the SDK-owned runtime when the negotiated descriptor grants that owner-level action. Dropping an attachment is always a detach and never calls this operation implicitly.