Struct BithumbWebSocketTrader

pub struct BithumbWebSocketTrader { /* private fields */ }

Bithumb WebSocket Trading Client

Provides real-time market data and private account updates via WebSocket. Trading operations are handled through the REST API integration.

Implementations

impl BithumbWebSocketTrader

pub fn new(auth: Arc<BithumbAuth>) -> Self

Create a SmartString ID with the given prefix and a UUID suffix

This helper reduces boilerplate when creating unique identifiers for orders, tickets, and other entities that need UUID-based IDs.

Examples

let order_id = Self::create_smart_id("bithumb_order");
let ticket_id = Self::create_smart_id("bithumb");

Create a new Bithumb WebSocket trader instance

pub fn connection_state(&self) -> BithumbConnectionState

Get current connection state

pub fn is_connected(&self) -> bool

Check if currently connected and authenticated

pub fn is_authenticated(&self) -> bool

Check if WebSocket is authenticated

pub fn get_stats(&self) -> (u64, u64, u64)

Get connection statistics

pub fn get_connection_health(&self) -> BithumbConnectionHealth

Get detailed connection health information

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

Connect to Bithumb private WebSocket endpoint

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

Disconnect from WebSocket

Trait Implementations

impl Clone for BithumbWebSocketTrader

fn clone(&self) -> Self

Returns a duplicate of the value.

const fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Exchange for BithumbWebSocketTrader

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