Struct K256WebSocketClient 

pub struct K256WebSocketClient { /* private fields */ }

K256 WebSocket client for real-time Solana liquidity data.

Implementations

impl K256WebSocketClient

pub fn new(config: Config) -> Self

Create a new WebSocket client with the given configuration.

pub fn on_pool_update<F>(&self, callback: F)

where F: Fn(PoolUpdate) + Send + Sync + 'static,

Register a callback for pool updates.

pub fn on_priority_fees<F>(&self, callback: F)

where F: Fn(PriorityFees) + Send + Sync + 'static,

Register a callback for priority fee updates.

pub fn on_blockhash<F>(&self, callback: F)

where F: Fn(Blockhash) + Send + Sync + 'static,

Register a callback for blockhash updates.

pub fn on_quote<F>(&self, callback: F)

where F: Fn(Quote) + Send + Sync + 'static,

Register a callback for quote updates.

pub fn on_heartbeat<F>(&self, callback: F)

where F: Fn(Heartbeat) + Send + Sync + 'static,

Register a callback for heartbeat messages.

pub fn on_error<F>(&self, callback: F)

where F: Fn(String) + Send + Sync + 'static,

Register a callback for errors.

pub async fn connect(&self) -> Result<(), Box<dyn Error + Send + Sync>>

Connect to the K256 WebSocket.

pub async fn subscribe( &self, request: SubscribeRequest, ) -> Result<(), Box<dyn Error + Send + Sync>>

Subscribe to channels.

pub async fn unsubscribe(&self) -> Result<(), Box<dyn Error + Send + Sync>>

Unsubscribe from all channels.