Struct SyncBridgeApiClient 

pub struct SyncBridgeApiClient { /* private fields */ }

Synchronous bridge API client for simple use cases

Implementations

impl SyncBridgeApiClient

pub fn new( base_url: String, get_access_token: impl Fn() -> Option<String> + Send + Sync + 'static, runner_version: String, ) -> Self

pub fn with_trusted_device_token( self, getter: impl Fn() -> Option<String> + Send + Sync + 'static, ) -> Self

pub fn with_debug(self, debug: impl Fn(&str) + Send + Sync + 'static) -> Self

pub fn register_bridge_environment( &self, config: BridgeConfig, ) -> Result<RegistrationResponse, String>

Register this bridge environment

pub fn poll_for_work( &self, environment_id: &str, environment_secret: &str, reclaim_older_than_ms: Option<u64>, ) -> Result<Option<WorkResponse>, String>

Poll for work from the environment

pub fn acknowledge_work( &self, environment_id: &str, work_id: &str, session_token: &str, ) -> Result<(), String>

Acknowledge work receipt

pub fn stop_work( &self, environment_id: &str, work_id: &str, force: bool, ) -> Result<(), String>

Stop a work item

pub fn deregister_environment(&self, environment_id: &str) -> Result<(), String>

Deregister the environment

pub fn archive_session(&self, session_id: &str) -> Result<(), String>

Archive a session

pub fn reconnect_session( &self, environment_id: &str, session_id: &str, ) -> Result<(), String>

Reconnect a session

pub fn heartbeat_work( &self, environment_id: &str, work_id: &str, session_token: &str, ) -> Result<HeartbeatResponse, String>

Send heartbeat for a work item

pub fn send_permission_response_event( &self, session_id: &str, event: PermissionResponseEvent, session_token: &str, ) -> Result<(), String>

Send permission response event