Struct EnvLessBridgeHandle 

pub struct EnvLessBridgeHandle {
    pub session_id: RwLock<String>,
    pub environment_id: RwLock<String>,
    pub session_ingress_url: RwLock<String>,
    pub transport: RwLock<Option<Box<dyn ReplBridgeTransport>>>,
    pub credentials: RwLock<Option<RemoteCredentials>>,
    pub torn_down: RwLock<bool>,
    pub auth_recovery_in_flight: RwLock<bool>,
    /* private fields */
}

Handle for the env-less bridge.

Fields

session_id: RwLock<String>

The bridge session ID (cse_* form).

environment_id: RwLock<String>

The environment ID (empty for env-less).

session_ingress_url: RwLock<String>

The session ingress URL.

transport: RwLock<Option<Box<dyn ReplBridgeTransport>>>

The transport.

credentials: RwLock<Option<RemoteCredentials>>

Current credentials (for refresh).

torn_down: RwLock<bool>

Teardown flag.

auth_recovery_in_flight: RwLock<bool>

Auth recovery in flight flag.

Implementations

impl EnvLessBridgeHandle

pub fn new( session_id: String, environment_id: String, session_ingress_url: String, params: EnvLessBridgeParams, ) -> Self

Create a new env-less bridge handle.

pub async fn write_messages(&self, messages: Vec<SDKMessage>)

Write messages to the bridge.

pub async fn write_sdk_messages(&self, messages: Vec<SDKMessage>)

Write SDK messages directly.

pub async fn send_control_request(&self, request: BridgeControlRequest)

Send a control request.

pub async fn send_control_response(&self, response: BridgeControlResponse)

Send a control response.

pub async fn send_control_cancel_request(&self, request_id: &str)

Send a control cancel request.

pub async fn send_result(&self)

Send a result message.

pub async fn teardown(&self)

Tear down the bridge.