A secure, async Rust library for cryptocurrency exchange APIs and real-time market data
| Exchange | Market Data | WebSocket | Trading | Account | Status |
|---|---|---|---|---|---|
| Binance Spot | ✅ | ✅ | ✅ | ✅ | Complete |
| Binance Perpetual | ✅ | ✅ | ✅ | ✅ | Complete |
| Bybit Spot | ✅ | ✅ | ✅ | ✅ | Complete |
| Bybit Perpetual | ✅ | ✅ | ✅ | ✅ | Complete |
| Hyperliquid | ✅ | ✅ | ✅ | ✅ | Complete |
| Backpack | ✅ | ✅ | ✅ | ✅ | Complete |
| Paradex | ✅ | ✅ | ✅ | ✅ | Complete |
[dependencies]
lotusx = { path = ".", features = ["env-file"] }
tokio = { version = "1.0", features = ["full"] }use lotusx::exchanges::binance::BinanceBuilder;
use lotusx::core::config::ExchangeConfig;
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
// Load configuration from environment
let config = ExchangeConfig::from_env("BINANCE")?;
let binance = BinanceBuilder::new().build(config).await?;
// Get markets
let markets = binance.get_markets().await?;
println!("Found {} markets", markets.len());
Ok(())
}Create a .env file:
# Binance
BINANCE_API_KEY=your_api_key_here
BINANCE_SECRET_KEY=your_secret_key_here
BINANCE_TESTNET=true
# Bybit
BYBIT_API_KEY=your_bybit_api_key_here
BYBIT_SECRET_KEY=your_bybit_secret_key_here
BYBIT_TESTNET=true
# Hyperliquid
HYPERLIQUID_PRIVATE_KEY=your_private_key_here
HYPERLIQUID_TESTNET=true
# Backpack
BACKPACK_API_KEY=your_backpack_api_key_here
BACKPACK_SECRET_KEY=your_backpack_secret_key_here
# Paradex
PARADEX_API_KEY=your_paradex_api_key_here
PARADEX_SECRET_KEY=your_paradex_secret_key_here
PARADEX_TESTNET=true- 🏗️ Multi-Exchange: Unified API across 7 major exchanges
- ⚡ Async: Built with tokio for high performance
- 🔒 Secure: Memory-protected credentials with automatic redaction
- 🔗 WebSocket: Real-time market data streaming with auto-reconnection
- 🧪 Testnet: Full testnet support for safe development
- 📊 Performance Testing: Built-in latency analysis and HFT metrics
- 🛡️ Type Safe: Strong typing for all API responses
- 🎯 Kernel Architecture: Unified transport layer with modular design
use lotusx::core::types::*;
use lotusx::exchanges::binance::BinanceBuilder;
// Create exchange connector
let binance = BinanceBuilder::new().build(config).await?;
let order = OrderRequest {
symbol: "BTCUSDT".to_string(),
side: OrderSide::Buy,
order_type: OrderType::Limit,
quantity: "0.001".to_string(),
price: Some("30000.0".to_string()),
time_in_force: Some(TimeInForce::GTC),
stop_price: None,
};
let response = binance.place_order(order).await?;use lotusx::exchanges::binance::BinanceBuilder;
// Create exchange connector
let binance = BinanceBuilder::new().build(config).await?;
let symbols = vec!["BTCUSDT".to_string()];
let subscription_types = vec![SubscriptionType::Ticker];
let mut receiver = binance
.subscribe_market_data(symbols, subscription_types, None)
.await?;
while let Some(data) = receiver.recv().await {
match data {
MarketDataType::Ticker(ticker) => {
println!("{}@{} ({}%)", ticker.symbol, ticker.price, ticker.price_change_percent);
}
_ => {}
}
}Run comprehensive latency analysis across all exchanges:
# Quick test (reduced sample size)
cargo run --example latency_test -- --quick
# Full analysis with all exchanges
cargo run --example latency_test -- --all
# Comprehensive testing (larger sample sizes)
cargo run --example latency_test -- --comprehensiveExample Output:
🚀 HFT Exchange Latency Analysis
================================
📊 Testing 7 exchanges...
📊 CRITICAL PERFORMANCE METRICS
--------------------------------------------------------------------------------
Exchange P99 (μs) P95 (μs) Mean (μs) Jitter (μs) Reliability (%)
--------------------------------------------------------------------------------
Binance Spot 620116 606453 551639 34336 93.8
Binance Perp 67895 46585 43988 6055 86.2
Bybit Spot 541927 502592 226296 165441 26.9
Bybit Perp 45832 41203 38945 4521 91.5
Hyperliquid 313108 39672 27732 67718 100.0
Backpack 82451 71238 64192 8834 88.7
Paradex 156789 142356 128974 19845 95.2
⚡ HFT-SPECIFIC METRICS
--------------------------------------------------------------------------------
Exchange Tick-to-Trade (μs) Market Impact (bps) Liquidity Score
--------------------------------------------------------------------------------
Binance Perp 51030 1.38 13.6
Hyperliquid 11480 5.00 1.4
Backpack 67543 2.15 8.9
Paradex 134589 3.42 5.2
use lotusx::utils::exchange_factory::*;
use lotusx::utils::latency_testing::*;
use lotusx::exchanges::binance::BinanceBuilder;
// Build custom test configuration
let configs = ExchangeTestConfigBuilder::new()
.add_exchange(ExchangeType::Binance, false)
.add_exchange(ExchangeType::Hyperliquid, false)
.build();
// Run tests with custom configuration
let tester = LatencyTester::with_config(LatencyTestConfig::comprehensive());
// ... run tests# Basic usage
cargo run --example basic_usage
# Exchange-specific examples
cargo run --example bybit_example
cargo run --example hyperliquid_example
cargo run --example backpack_streams_example
cargo run --example paradex_example
# Performance testing
cargo run --example latency_test
cargo run --example custom_latency_test
# WebSocket streaming
cargo run --example websocket_example- Always test with testnet first:
BINANCE_TESTNET=true - Start with small amounts in production
- Keep your API keys secure
- Review all order parameters carefully
Contributions welcome! The modular architecture makes it easy to add new exchanges or improve existing functionality.
- All code must pass
cargo clippywith zero warnings - Comprehensive testing across supported platforms
- Follow established patterns for consistency
MIT License. Please review the code before using in production.