crypto-crawler

A rock-solid cryprocurrency crawler.

Crawl realtime trades

```rust use cryptocrawler::{crawltrade, MarketType, Message};

let (tx, rx) = std::sync::mpsc::channel(); std::thread::spawn(move || { for msg in rx { println!("{}", msg); } });

// Crawl realtime trades for all symbols of binance inverseswap markets crawltrade("binance", MarketType::InverseSwap, None, tx, None); ```

Crawl realtime level2 orderbook incremental updates

```rust use cryptocrawler::{crawll2_event, MarketType, Message};

let (tx, rx) = std::sync::mpsc::channel(); std::thread::spawn(move || { for msg in rx { println!("{}", msg); } });

// Crawl realtime level2 incremental updates for all symbols of binance inverseswap markets crawll2_event("binance", MarketType::InverseSwap, None, tx, None); ```

Crawl level2 orderbook full snapshots from RESTful API

```rust use cryptocrawler::{crawll2_snapshot, MarketType, Message};

let (tx, rx) = std::sync::mpsc::channel(); std::thread::spawn(move || { for msg in rx { println!("{}", msg); } });

// Crawl level2 full snapshots for all symbols of binance inverseswap markets crawll2_snapshot("binance", MarketType::InverseSwap, None, tx, None); ```

Crawl realtime level2 orderbook top-K snapshots

```rust use cryptocrawler::{crawll2_topk, MarketType, Message};

let (tx, rx) = std::sync::mpsc::channel(); std::thread::spawn(move || { for msg in rx { println!("{}", msg); } });

// Crawl realtime level2 top-k snapshots for all symbols of binance inverseswap markets crawll2_topk("binance", MarketType::InverseSwap, None, tx, None); ```

Crawl realtime level3 orderbook incremental updates

```rust use cryptocrawler::{crawll3_event, MarketType, Message};

let (tx, rx) = std::sync::mpsc::channel(); std::thread::spawn(move || { for msg in rx { println!("{}", msg); } });

// Crawl realtime level3 updates for all symbols of CoinbasePro spot market crawll3event("coinbase_pro", MarketType::Spot, None, tx, None); ```

Crawl level3 orderbook full snapshots from RESTful API

```rust use cryptocrawler::{crawll3_snapshot, MarketType, Message};

let (tx, rx) = std::sync::mpsc::channel(); std::thread::spawn(move || { for msg in rx { println!("{}", msg); } });

// Crawl level3 orderbook full snapshots for all symbols of CoinbasePro spot markets crawll3snapshot("coinbase_pro", MarketType::Spot, None, tx, None); ```

Crawl realtime BBO

```rust use cryptocrawler::{crawlbbo, MarketType, Message};

let (tx, rx) = std::sync::mpsc::channel(); std::thread::spawn(move || { for msg in rx { println!("{}", msg); } });

// Crawl realtime best bid and ask messages for all symbols of binance COIN-margined perpetual markets crawl_bbo("binance", MarketType::InverseSwap, None, tx, None); ```

Crawl 24hr rolling window tickers

```rust use cryptocrawler::{crawlticker, MarketType, Message};

let (tx, rx) = std::sync::mpsc::channel(); std::thread::spawn(move || { for msg in rx { println!("{}", msg); } });

// Crawl 24hr rolling window tickers for all symbols of binance COIN-margined perpetual markets crawl_ticker("binance", MarketType::InverseSwap, None, tx, None); ```

Crawl candlesticks(i.e., OHLCV)

```rust use cryptocrawler::{crawlcandlestick, MarketType, Message};

let (tx, rx) = std::sync::mpsc::channel(); std::thread::spawn(move || { for msg in rx { println!("{}", msg); } });

// Crawl candlesticks from 1 minute to 3 minutes for all symbols of binance COIN-margined perpetual markets crawl_candlestick("binance", MarketType::InverseSwap, None, tx, None); ```

Crawl funding rates

```rust use cryptocrawler::{crawlfunding_rate, MarketType, Message};

let (tx, rx) = std::sync::mpsc::channel(); std::thread::spawn(move || { for msg in rx { println!("{}", msg); } });

// Crawl funding rates for all symbols of binance COIN-margined perpetual markets crawlfundingrate("binance", MarketType::InverseSwap, None, tx, None); ```