Struct Transport 

pub struct Transport { /* private fields */ }

Lock-free WebSocket transport.

All state is stored in atomics or ArcSwap. The WS write half is owned by a dedicated writer task; callers send through a channel.

Implementations

impl Transport

pub fn new(opts: TransportOptions, emitter: SpiderEventEmitter) -> Arc<Self>

pub fn browser(&self) -> String

pub fn is_connected(&self) -> bool

pub fn get_stealth_level(&self) -> u32

pub fn set_stealth_level(&self, level: u32)

pub fn upgrade_credits(&self) -> Option<f64>

pub fn session_credits_used(&self) -> Option<f64>

pub fn command_timeout_ms(&self) -> u64

pub async fn take_message_rx(&self) -> Option<UnboundedReceiver<String>>

Take the message receiver (can only be called once).

pub fn send(&self, data: String) -> Result<()>

Send a raw JSON string through the WebSocket channel.

pub async fn connect(self: &Arc<Self>, max_attempts: u32) -> Result<()>

Connect to the Spider WebSocket with retry.

pub async fn reconnect(self: &Arc<Self>, browser: &str) -> Result<()>

Reconnect with a different browser type.

pub fn close(&self)

Close the WebSocket connection.