Struct BybitWebSocketTrader

pub struct BybitWebSocketTrader { /* private fields */ }

Bybit WebSocket Trading Client

Implementations

impl BybitWebSocketTrader

pub fn new( auth: Arc<BybitAuth>, testnet: bool, instrument_registry: Arc<dyn InstrumentRegistry>, ) -> Self

Create a new Bybit WebSocket trader

pub fn get_connection_health(&self) -> ConnectionHealth

Get connection health status

pub fn is_ready(&self) -> bool

Check if connected and authenticated

pub async fn connect(&self, report_tx: Sender<ExecutionReport>) -> Result<()>

Connect to Bybit WebSocket trading endpoint

pub async fn create_order(&self, order: &BybitOrderRequest) -> Result<()>

Create a single order with tracking

pub async fn create_batch_orders( &self, batch: &BybitBatchOrderRequest, ) -> Result<()>

Create multiple orders in a batch with tracking

pub async fn cancel_order( &self, category: BybitCategory, order_id: &str, ) -> Result<()>

Cancel a single order with tracking

pub async fn cancel_batch_orders( &self, category: BybitCategory, order_ids: &[&str], ) -> Result<()>

Cancel multiple orders in a batch with tracking

pub async fn amend_order(&self, request: &BybitAmendOrderRequest) -> Result<()>

Amend an existing order

pub async fn cancel_all_orders_internal( &self, request: &BybitCancelAllRequest, ) -> Result<()>

Cancel all orders for a category

pub async fn send_ping(&self) -> Result<()>

Send JSON ping to test connection

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

Disconnect from WebSocket

Trait Implementations

impl Exchange for BybitWebSocketTrader

fn venue(&self) -> Venue

Returns the venue this exchange connects to

fn place_order<'life0, 'async_trait>( &'life0 self, order: Order, report_sender: Sender<ExecutionReport>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Places a new order on the exchange

fn cancel_order<'life0, 'async_trait>( &'life0 self, order_id: SmartString, report_sender: Sender<ExecutionReport>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Cancels an existing order

fn modify_order<'life0, 'async_trait>( &'life0 self, order_id: SmartString, new_price: Option<Decimal>, new_quantity: Option<Decimal>, report_sender: Sender<ExecutionReport>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Modifies an existing order

fn cancel_all_orders<'life0, 'async_trait>( &'life0 self, instrument_id: Option<InstrumentId>, report_sender: Sender<ExecutionReport>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Cancels all open orders, optionally filtered by instrument

fn get_order_status<'life0, 'life1, 'async_trait>( &'life0 self, order_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<OrderStatus>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieves the status of an order

fn connect<'life0, 'async_trait>( &'life0 self, report_sender: Sender<ExecutionReport>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Connects to the exchange

fn disconnect<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Disconnects from the exchange

fn is_connected<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Checks if connected to the exchange

fn get_instruments<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<SmallVec<[InstrumentId; 32]>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Gets a list of instruments supported by this exchange

fn send_fix_message<'life0, 'async_trait>( &'life0 self, _message: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends a FIX message to the exchange

fn receive_fix_message<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Receives a FIX message from the exchange