Crate crypto_crawler[−][src]
A rock-solid cryprocurrency crawler.
Crawl realtime trades
use std::sync::{Arc, Mutex}; use crypto_crawler::{crawl_trade, MarketType, Message}; let on_msg = Arc::new(Mutex::new(|msg: Message| { println!("{}", msg); })); // Crawl BitMEX inverse_swap market, for all symbols, only run for 5 seconds crawl_trade("bitmex", MarketType::InverseSwap, None, on_msg, Some(5));
Crawl level2 orderbook update events
use std::sync::{Arc, Mutex}; use crypto_crawler::{crawl_l2_event, MarketType, Message}; let on_msg = Arc::new(Mutex::new(|msg: Message| { println!("{}", msg); })); // Crawl BitMEX inverse_swap market, for all symbols, only run for 5 seconds crawl_l2_event("bitmex", MarketType::InverseSwap, None, on_msg, Some(5));
Crawl level2 orderbook snapshots
use std::sync::{Arc, Mutex}; use crypto_crawler::{crawl_l2_snapshot, MarketType, Message}; let on_msg = Arc::new(Mutex::new(|msg: Message| { println!("{}", msg); })); // Crawl BitMEX inverse_swap market level2 orderbook snapshots every 60 seconds, for all symbols, only run for 5 seconds crawl_l2_snapshot("bitmex", MarketType::InverseSwap, None, on_msg, Some(60), Some(5));
Crawl level3 orderbook update events
use std::sync::{Arc, Mutex}; use crypto_crawler::{crawl_l3_event, MarketType, Message}; let on_msg = Arc::new(Mutex::new(|msg: Message| { println!("{}", msg); })); // Crawl CoinbasePro spot market, for all symbols, only run for 5 seconds crawl_l3_event("coinbase_pro", MarketType::Spot, None, on_msg, Some(5));
Crawl level3 orderbook snapshots
use std::sync::{Arc, Mutex}; use crypto_crawler::{crawl_l3_snapshot, MarketType, Message}; let on_msg = Arc::new(Mutex::new(|msg: Message| { println!("{}", msg); })); // Crawl CoinbasePro spot market level2 orderbook snapshots every 60 seconds, for all symbols, only run for 5 seconds crawl_l3_snapshot("coinbase_pro", MarketType::Spot, None, on_msg, Some(60), Some(5));
Structs
Message | Message represents messages received by crawlers. |
Enums
MarketType | Market type. |
MessageType | The type of a message |
Functions
crawl_l2_event | Crawl level2 orderbook update events. |
crawl_l2_snapshot | Crawl level2 orderbook snapshots through RESTful APIs. |
crawl_l3_event | Crawl level3 orderbook update events. |
crawl_l3_snapshot | Crawl level3 orderbook snapshots through RESTful APIs. |
crawl_trade | Crawl realtime trades. |