Functions — github.com/crypto-crawler/carbonbot

CodeHub MCPcopy Create free account

hub / github.com/crypto-crawler/carbonbot / functions

Functions19 in github.com/crypto-crawler/carbonbot

⨍ Functions 19 ◇ Types & classes 2

↓ 12 callersMethodclose

src/writers/file_writer.rs:52

↓ 6 callersFunctioncreate_conversion_thread

create a thread to convert Sender<Message> Sender<String>

src/misc_crawlers/utils.rs:8

↓ 2 callersFunctioncreate_file_writer_thread

If there are no messages coming in for `timeout` seconds, exit the process.

src/writers/mod.rs:22

↓ 2 callersFunctioncreate_redis_writer_thread

(rx: Receiver<Message>, redis_url: String)

src/writers/mod.rs:100

↓ 2 callersFunctionopen

src/writers/file_writer.rs:16

↓ 2 callersMethodwrite

(&mut self, s: &str)

src/writers/file_writer.rs:46

↓ 1 callersFunctionconnect_redis

(redis_url: &str)

src/writers/mod.rs:75

↓ 1 callersFunctioncrawl

( exchange: &'static str, market_type: MarketType, msg_type: MessageType, data_dir: Option<Str

src/main.rs:110

↓ 1 callersFunctioncrawl_other

(exchange: &str, market_type: MarketType, tx: Sender<Message>)

src/misc_crawlers/mod.rs:15

↓ 1 callersFunctioncreate_writer_threads

( rx: Receiver<Message>, data_dir: Option<String>, redis_url: Option<String>, timeout_secs: u6

src/writers/mod.rs:116

↓ 1 callersFunctionget_message_gap

(exchange: &'static str, market_type: MarketType, msg_type: MessageType)

Functioncrawl_other

(tx: Sender<Message>)

src/misc_crawlers/okx.rs:9

Functioncrawl_other

(market_type: MarketType, tx: Sender<Message>)

src/misc_crawlers/binance.rs:9

Functioncrawl_other

(market_type: MarketType, tx: Sender<Message>)

src/misc_crawlers/coinbase_pro.rs:9

Functioncrawl_other

(market_type: MarketType, tx: Sender<Message>)

src/misc_crawlers/bybit.rs:9

Functioncrawl_other

(market_type: MarketType, tx: Sender<Message>)

src/misc_crawlers/bitmex.rs:9

Functioncrawl_other

(market_type: MarketType, tx: Sender<Message>)

src/misc_crawlers/huobi.rs:9

src/main.rs:187

src/writers/file_writer.rs:32