Struct HttpFrontendRuntime 

pub struct HttpFrontendRuntime { /* private fields */ }

Authenticated HTTP implementation of FrontendRuntime.

It owns only an RPC/SSE connection. The remote RpcEngine remains the sole owner of the agent loop, transcript, scheduler, and persistence.

Implementations

impl HttpFrontendRuntime

pub async fn connect( base_url: impl Into<String>, token: impl Into<String>, ) -> Result<Arc<HttpFrontendRuntime>, SdkError>

Authenticate, verify the frontend descriptor, and establish the sequenced SSE stream before returning.

pub async fn connect_with_client_id( base_url: impl Into<String>, token: impl Into<String>, client_id: RuntimeClientId, ) -> Result<Arc<HttpFrontendRuntime>, SdkError>

Connect with a caller-owned stable client identity. Reconnect tests and external bindings use this to retain deterministic lease state.

pub async fn connect_with_authorization( base_url: impl Into<String>, token: impl Into<String>, client_id: RuntimeClientId, authorization: RuntimeAuthorization, ) -> Result<Arc<HttpFrontendRuntime>, SdkError>

Connect while requesting an exact subset of the bearer credential’s permissions. The server intersects this with the authenticated grant; this header can narrow authority but can never elevate it.

pub fn client_id(&self) -> &RuntimeClientId

Current authenticated client identity.

pub fn is_disconnected(&self) -> bool

Whether the remote event stream has already ended or this client explicitly detached/closed.

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

Explicitly acquire the controller lease, displacing another interactive client only through this named operation.

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

Renew observer activity and any controller lease owned by this client.

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

Read the coordinated ownership state.

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

Release observer and controller state without stopping the runtime.

Trait Implementations

impl SdkRuntime for HttpFrontendRuntime

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

where 'life0: 'async_trait, HttpFrontendRuntime: '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, HttpFrontendRuntime: 'async_trait,

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

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

where HttpFrontendRuntime: 'async_trait,

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

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

where HttpFrontendRuntime: '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, HttpFrontendRuntime: '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, HttpFrontendRuntime: '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, HttpFrontendRuntime: '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, HttpFrontendRuntime: '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, HttpFrontendRuntime: '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, HttpFrontendRuntime: '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, HttpFrontendRuntime: '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, HttpFrontendRuntime: '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, HttpFrontendRuntime: '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, HttpFrontendRuntime: '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, HttpFrontendRuntime: '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.