Struct DeribitWebSocketClient

pub struct DeribitWebSocketClient {
    pub config: Arc<WebSocketConfig>,
    pub session: Arc<WebSocketSession>,
    /* private fields */
}

WebSocket client for Deribit

Fields

config: Arc<WebSocketConfig>

WebSocket configuration

session: Arc<WebSocketSession>

WebSocket session

Implementations

impl DeribitWebSocketClient

pub fn new(config: &WebSocketConfig) -> Result<Self, WebSocketError>

Create a new WebSocket client

pub fn new_with_url(ws_url: String) -> Result<Self, WebSocketError>

Create a new WebSocket client with default configuration

pub fn new_testnet() -> Result<Self, WebSocketError>

Create a new WebSocket client for testnet

pub fn new_production() -> Result<Self, WebSocketError>

Create a new WebSocket client for production

pub async fn connect(&self) -> Result<(), WebSocketError>

Connect to the WebSocket server

pub async fn disconnect(&self) -> Result<(), WebSocketError>

Disconnect from the WebSocket server

pub async fn is_connected(&self) -> bool

Check if connected

pub async fn authenticate( &self, client_id: &str, client_secret: &str, ) -> Result<JsonRpcResponse, WebSocketError>

Authenticate with the server

pub async fn subscribe( &self, channels: Vec<String>, ) -> Result<JsonRpcResponse, WebSocketError>

Subscribe to channels

pub async fn unsubscribe( &self, channels: Vec<String>, ) -> Result<JsonRpcResponse, WebSocketError>

Unsubscribe from channels

pub async fn send_request( &self, request: JsonRpcRequest, ) -> Result<JsonRpcResponse, WebSocketError>

Send a JSON-RPC request

pub async fn send_message(&self, message: String) -> Result<(), WebSocketError>

Send a raw message

pub async fn receive_message(&self) -> Result<String, WebSocketError>

Receive a message

pub async fn get_subscriptions(&self) -> Vec<String>

Get active subscriptions

pub async fn test_connection(&self) -> Result<JsonRpcResponse, WebSocketError>

Test connection

pub async fn get_time(&self) -> Result<JsonRpcResponse, WebSocketError>

Get server time

pub async fn mass_quote( &self, request: MassQuoteRequest, ) -> Result<MassQuoteResult, WebSocketError>

Place mass quotes

pub async fn cancel_quotes( &self, request: CancelQuotesRequest, ) -> Result<CancelQuotesResponse, WebSocketError>

Cancel quotes

pub async fn set_mmp_config( &self, config: MmpGroupConfig, ) -> Result<(), WebSocketError>

Set MMP group configuration

pub async fn get_mmp_config( &self, mmp_group: Option<String>, ) -> Result<Vec<MmpGroupConfig>, WebSocketError>

Get MMP group configuration

pub async fn reset_mmp( &self, mmp_group: Option<String>, ) -> Result<(), WebSocketError>

Reset MMP group

pub async fn get_open_orders( &self, currency: Option<String>, kind: Option<String>, type_filter: Option<String>, ) -> Result<Vec<QuoteInfo>, WebSocketError>

Get open orders (including quotes)

pub fn set_message_handler<F, E>( &mut self, message_callback: F, error_callback: E, )

where F: Fn(&str) -> Result<(), WebSocketError> + Send + Sync + 'static, E: Fn(&str, &WebSocketError) + Send + Sync + 'static,

Set message handler with callbacks The message_callback processes each incoming message and returns Result<(), Error> The error_callback is called only when message_callback returns an error

pub fn set_message_handler_builder(&mut self, handler: MessageHandler)

Set message handler using builder pattern

pub fn clear_message_handler(&mut self)

Remove the current message handler

pub fn has_message_handler(&self) -> bool

Check if message handler is set

pub async fn receive_and_process_message(&self) -> Result<(), WebSocketError>

Receive and process a message using the registered callbacks This method will:

1. Receive a message from the WebSocket
2. Call the primary callback with the message
3. If primary callback returns error, call error callback with message and error

pub async fn start_message_processing_loop(&self) -> Result<(), WebSocketError>

Start message processing loop with callbacks This will continuously receive messages and process them using the registered callbacks The loop will continue until an error occurs or the connection is closed

Trait Implementations

impl Debug for DeribitWebSocketClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for DeribitWebSocketClient

fn default() -> Self

Returns the “default value” for a type.