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.