Struct RealtimeClient 

pub struct RealtimeClient { /* private fields */ }

Supabase Realtime WebSocket client

Implementations

impl RealtimeClient

pub fn new(config: RealtimeConfig) -> Self

Create a new Realtime client

pub async fn state(&self) -> RealtimeState

Get current connection state

pub async fn is_ready(&self) -> bool

Check if connected and subscribed

pub async fn connect( &mut self, shutdown_rx: Receiver<()>, heartbeat_rx: Receiver<HeartbeatData>, stream_rx: Receiver<(String, StreamChunkType, String)>, command_tx: Sender<BackendCommand>, ) -> Result<()>

Connect to Supabase Realtime and run the message loop

• shutdown_rx: Signal to gracefully shut down
• heartbeat_rx: Receives heartbeat data (with hostname, os, version) to broadcast to frontend
• stream_rx: Receives stream messages (agent_id, chunk_type, content) to broadcast
• command_tx: Channel to send commands received from frontend for processing

pub async fn send(&self, msg: RemoteRealtimeMessage) -> Result<()>

Send a message via the outgoing channel (for bridge use)

pub async fn send_heartbeat(&self, heartbeat_data: HeartbeatData) -> Result<()>

Send heartbeat with agent status

pub async fn send_stream( &self, agent_id: String, chunk_type: StreamChunkType, content: String, ) -> Result<()>

Send stream chunk

pub async fn send_command_result( &self, command_id: String, success: bool, result: Option<Value>, error: Option<String>, ) -> Result<()>

Send command result