crypto-crawler
A rock-solid cryprocurrency crawler.
Crawl realtime trades
use std::sync::{Arc, Mutex};
use crypto_crawler::{crawl_trade, MarketType, Message};
fn main() {
let on_msg = Arc::new(Mutex::new(|msg: Message| {
println!("{}", msg);
}));
crawl_trade("bitmex", MarketType::InverseSwap, None, on_msg, None);
}
Crawl level2 orderbook update events
use std::sync::{Arc, Mutex};
use crypto_crawler::{crawl_l2_event, MarketType, Message};
fn main() {
let on_msg = Arc::new(Mutex::new(|msg: Message| {
println!("{}", msg);
}));
crawl_l2_event("bitmex", MarketType::InverseSwap, None, on_msg, None);
}
Crawl level2 orderbook snapshots
use std::sync::{Arc, Mutex};
use crypto_crawler::{crawl_l2_snapshot, MarketType, Message};
fn main() {
let on_msg = Arc::new(Mutex::new(|msg: Message| {
println!("{}", msg);
}));
crawl_l2_snapshot("bitmex", MarketType::InverseSwap, None, on_msg, Some(60), None);
}
Crawl level3 orderbook update events
use std::sync::{Arc, Mutex};
use crypto_crawler::{crawl_l3_event, MarketType, Message};
fn main() {
let on_msg = Arc::new(Mutex::new(|msg: Message| {
println!("{}", msg);
}));
crawl_l3_event("coinbase_pro", MarketType::Spot, None, on_msg, None);
}
Crawl level3 orderbook snapshots
use std::sync::{Arc, Mutex};
use crypto_crawler::{crawl_l3_snapshot, MarketType, Message};
fn main() {
let on_msg = Arc::new(Mutex::new(|msg: Message| {
println!("{}", msg);
}));
crawl_l3_snapshot("coinbase_pro", MarketType::Spot, None, on_msg, Some(60), None);
}