Crates.io | paradex |
lib.rs | paradex |
version | |
source | src |
created_at | 2025-01-21 18:48:42.584943 |
updated_at | 2025-02-06 11:05:35.77171 |
description | Paradex client library |
homepage | |
repository | https://github.com/snow-avocado/paradex-rs |
max_upload_size | |
id | 1525222 |
Cargo.toml error: | TOML parse error at line 17, column 1 | 17 | autolib = false | ^^^^^^^ unknown field `autolib`, expected one of `name`, `version`, `edition`, `authors`, `description`, `readme`, `license`, `repository`, `homepage`, `documentation`, `build`, `resolver`, `links`, `default-run`, `default_dash_run`, `rust-version`, `rust_dash_version`, `rust_version`, `license-file`, `license_dash_file`, `license_file`, `licenseFile`, `license_capital_file`, `forced-target`, `forced_dash_target`, `autobins`, `autotests`, `autoexamples`, `autobenches`, `publish`, `metadata`, `keywords`, `categories`, `exclude`, `include` |
size | 0 |
A simple, yet high performance client library for paradex
Both websocket and rest connectivity are supported. Currently a sub-set of the most important APIs are supported.
The benchmark uses mimalloc as I notice a 10-20% speedup using a mimalloc vs default allocator. Suggest benchmarking on your system / environment.
See here for full examples.
#[tokio::main]
async fn main() {
let symbol: String = "BTC-USD-PERP".into();
let manager = paradex::ws::WebsocketManager::new(paradex::url::URL::Testnet, None).await;
let summary_id = manager
.subscribe(
paradex::ws::Channel::MarketSummary,
Box::new(|message| info!("Received message {message:?}")),
)
.await
.unwrap();
let bbo_id = manager
.subscribe(
paradex::ws::Channel::BBO {
market_symbol: symbol.clone(),
},
Box::new(|message| info!("Received message {message:?}")),
)
.await
.unwrap();
let trades_id = manager
.subscribe(
paradex::ws::Channel::Trades {
market_symbol: symbol.clone(),
},
Box::new(|message| info!("Received message {message:?}")),
)
.await
.unwrap();
let orderbook_id = manager
.subscribe(
paradex::ws::Channel::OrderBook {
market_symbol: symbol.clone(),
refresh_rate: "50ms".into(),
price_tick: None,
},
Box::new(|message| info!("Received message {message:?}")),
)
.await
.unwrap();
let orderbook_deltas_id = manager
.subscribe(
paradex::ws::Channel::OrderBookDeltas {
market_symbol: symbol.clone(),
},
Box::new(|message| info!("Received message {message:?}")),
)
.await
.unwrap();
let funding_id = manager
.subscribe(
paradex::ws::Channel::FundingData {
market_symbol: None,
},
Box::new(|message| info!("Received message {message:?}")),
)
.await
.unwrap();
tokio::time::sleep(Duration::from_secs(120)).await;
for id in [
summary_id,
bbo_id,
trades_id,
orderbook_id,
orderbook_deltas_id,
funding_id,
] {
manager.unsubscribe(id).await.unwrap();
}
tokio::time::sleep(Duration::from_secs(5)).await;
manager.stop().await.unwrap();
}