Functions — github.com/SorellaLabs/cex-exchanges

hub / github.com/SorellaLabs/cex-exchanges / functions

Functions449 in github.com/SorellaLabs/cex-exchanges

⨍ Functions 449◇ Types & classes 157

↓ 38 callersFunctioninit_test_tracing

()

tests/utils.rs:123

↓ 26 callersMethodnormalize

(&self)

src/exchanges/okex/pairs.rs:19

↓ 21 callersMethodadd_channel

(&mut self, channel: KucoinWsChannel)

src/exchanges/kucoin/ws/subscription.rs:18

↓ 15 callersMethodbuild_many_packed

(self, connections_per_stream: Option<usize>)

src/exchanges/okex/ws/builder.rs:101

↓ 13 callersMethodget_normalized_pair

(&self, exchange: CexExchange)

src/exchanges/normalized/types/pairs.rs:141

↓ 12 callersMethodwith_first_update_id

(mut self, first_update_id: u64)

src/exchanges/normalized/types/l2.rs:72

↓ 12 callersMethodwith_time

(mut self, time: DateTime<Utc>)

src/exchanges/normalized/types/l2.rs:67

↓ 11 callersMethodpair

(&self)

src/exchanges/normalized/types/pairs.rs:42

↓ 10 callersFunctionmutlistream_util

(builder: MultiWsStreamBuilder<E>, iterations: usize)

tests/utils.rs:37

↓ 9 callersMethoddelimiter

(&self)

src/exchanges/normalized/types/pairs.rs:58

↓ 9 callersMethodtake_instruments

(self, active_only: bool)

src/exchanges/okex/rest_api/response.rs:27

↓ 7 callersMethodbase_quote

(&self)

src/exchanges/normalized/types/pairs.rs:46

↓ 7 callersMethodbuild_multistream_unconnected

(self, config: WsStreamConfig)

src/clients/ws/mutli.rs:107

↓ 7 callersMethodhandle_retry

(&mut self, msg: CombinedWsMessage)

src/clients/ws/single.rs:90

↓ 7 callersMethodreconnect

(&mut self, cx: &mut Context<'_>)

src/clients/ws/single.rs:50

↓ 6 callersMethodnormalized_with_exchange

(self, exchange: CexExchange, raw_message: Option<String>)

src/clients/ws/errors.rs:22

↓ 6 callersMethodspawn_multithreaded

(self, num_threads: usize, config: WsStreamConfig)

src/clients/ws/mutli.rs:127

↓ 5 callersMethodadd_channel

(mut self, channel: Self::WsChannel)

src/exchanges/binance/ws/builder.rs:67

↓ 5 callersMethodadd_channel

(mut self, channel: Self::WsChannel)

src/exchanges/coinbase/ws/builder.rs:61

↓ 5 callersMethodadd_channel

(mut self, channel: Self::WsChannel)

src/exchanges/kucoin/ws/builder.rs:66

↓ 5 callersMethodadd_channel

(mut self, channel: Self::WsChannel)

src/exchanges/bybit/ws/builder.rs:62

↓ 5 callersMethodadd_channel

(mut self, channel: Self::WsChannel)

src/exchanges/okex/ws/builder.rs:70

↓ 5 callersMethodbuild_many_distributed

(self)

src/exchanges/okex/ws/builder.rs:82

↓ 5 callersMethodbuild_multistream_unconnected_raw

(self, config: WsStreamConfig)

src/clients/ws/mutli.rs:120

↓ 5 callersMethodbuild_single

(self)

src/exchanges/okex/ws/builder.rs:75

↓ 5 callersMethodis_err

(&self)

src/exchanges/normalized/ws/message.rs:57

↓ 5 callersFunctionmutlithreaded_util

(builder: MultiWsStreamBuilder<E>, iterations: usize)

tests/utils.rs:61

↓ 5 callersFunctionstream_util

(exchange: E, iterations: usize)

tests/utils.rs:14

↓ 5 callersMethodtake_currencies

(self)

src/exchanges/okex/rest_api/response.rs:20

↓ 4 callersMethodadd_pairs_all_channels

adds trading pairs to all channels

src/exchanges/normalized/ws/builder.rs:86

↓ 4 callersFunctionbinance_util

(builder: BinanceWsBuilder, iterations: usize)

tests/ws.rs:236

↓ 4 callersMethodis_ok

(&self)

src/exchanges/normalized/ws/message.rs:53

↓ 4 callersMethodnew_reconnect

(&mut self)

src/clients/ws/single.rs:218

↓ 3 callersMethodcombine_wrapped_assets

takes a wrapped currency and a vec of unwrapped currencies returns either: - an unwrapped currency with the `blockchains.wrapped_currency` field updat

src/exchanges/normalized/types/currencies.rs:57

↓ 3 callersMethodget_all_instruments

(&self, web_client: &reqwest::Client)

src/exchanges/okex/mod.rs:62

↓ 3 callersMethodmake_many_single

(self)

src/exchanges/normalized/ws/channels.rs:40

↓ 3 callersMethodmake_pair

(&self)

src/exchanges/normalized/types/pairs.rs:62

↓ 3 callersMethodnew_timeout_rx

(&mut self)

src/clients/ws/single.rs:223

↓ 2 callersMethodadd_pairs

(&mut self, pairs: Vec<KucoinTradingPair>)

src/exchanges/kucoin/ws/subscription.rs:63

↓ 2 callersMethodadd_pairs

(&mut self, exchange: CexExchange, pairs: &[RawTradingPair])

src/exchanges/normalized/ws/channels.rs:79

↓ 2 callersMethodadd_pairs_single_channel

adds trading pairs to a channel

src/exchanges/normalized/ws/builder.rs:99

↓ 2 callersFunctionbybit_util

(builder: BybitWsBuilder, iterations: usize)

tests/ws.rs:418

↓ 2 callersFunctioncoinbase_util

(builder: CoinbaseWsBuilder, iterations: usize)

tests/ws.rs:23

↓ 2 callersMethodconnect

(&mut self)

src/clients/ws/single.rs:41

↓ 2 callersMethodfilter_matches

(&self, vals: &mut Vec<T>)

src/exchanges/traits/filter.rs:4

↓ 2 callersMethodget_all_instruments

gets the normalized instruments from the different exchange endpoints ex: BNB-ETH, ETHBTC, BTC/USDC if calling without a filter: ``` CexExchange::Oke

src/exchanges/mod.rs:257

↓ 2 callersMethodis_reconnecting

(&self)

src/clients/ws/single.rs:231

↓ 2 callersFunctionkucoin_util

(builder: KucoinWsBuilder, iterations: usize)

tests/ws.rs:336

↓ 2 callersMethodmake_subscription_url

(&self)

src/exchanges/binance/ws/subscription.rs:58

↓ 2 callersMethodmake_ws_connection

(&self)

src/exchanges/okex/mod.rs:105

↓ 2 callersMethodnormalize

(self)

src/exchanges/coinbase/rest_api/endpoints/products.rs:21

↓ 2 callersMethodnormalize

(self)

src/exchanges/kucoin/rest_api/endpoints/symbols.rs:20

↓ 2 callersMethodnormalize

(self)

src/exchanges/bybit/rest_api/endpoints/instruments.rs:21

↓ 2 callersMethodnormalize_with

(&self, base: &str, quote: &str)

src/exchanges/binance/pairs.rs:23

↓ 2 callersFunctionnormalized_mutlithreaded_util

(builder: NormalizedExchangeBuilder, iterations: usize)

tests/utils.rs:85

↓ 2 callersFunctionokex_util

(builder: OkexWsBuilder, iterations: usize)

tests/ws.rs:131

↓ 2 callersMethodparse_blockchain

(&self)

src/exchanges/binance/rest_api/endpoints/symbols.rs:125

↓ 2 callersMethodparse_blockchain

(&self)

src/exchanges/bybit/rest_api/endpoints/proxy_coins.rs:72

↓ 2 callersMethodparse_blockchain_address

(self)

src/exchanges/bybit/rest_api/endpoints/coins.rs:122

↓ 2 callersMethodparse_blockchains

(&self)

src/exchanges/coinbase/rest_api/endpoints/currencies.rs:97

↓ 2 callersMethodrun_with_sender

(mut self, tx: UnboundedSender<CombinedWsMessage>)

src/clients/ws/mutli.rs:40

↓ 2 callersMethodwith_last_update_id

(mut self, last_update_id: u64)

src/exchanges/normalized/types/l2.rs:77

↓ 1 callersMethodadd_channels_one_exchange

(mut self, exchange: CexExchange, channels: &[NormalizedWsChannelKinds])

src/exchanges/normalized/ws/builder.rs:30

↓ 1 callersMethodall_subscriptions

(self)

src/exchanges/kucoin/ws/subscription.rs:33

↓ 1 callersMethodbad_pair

(self, msg: String)

src/exchanges/mod.rs:337

↓ 1 callersMethodbuild_all_multithreaded

builds the multithreaded multistream ws client

src/exchanges/normalized/ws/builder.rs:146

↓ 1 callersMethodbuild_multistream_unconnected_raw_ws_from_normalized

( self, map: Vec<NormalizedWsChannels>, exch_currency_proxy: Option<CexExchange>,

src/exchanges/mod.rs:158

↓ 1 callersMethodbuild_multistream_ws_from_normalized

( self, map: Vec<NormalizedWsChannels>, config: WsStreamConfig, connections_pe

src/exchanges/mod.rs:79

↓ 1 callersMethodcombine_other

(self, other: Self)

src/clients/ws/mutli.rs:19

↓ 1 callersMethodextra_data

(&self)

src/exchanges/normalized/types/pairs.rs:78

↓ 1 callersMethodget_all_symbols

( &'a self, web_client: &'a reqwest::Client )

src/exchanges/okex/mod.rs:47

↓ 1 callersMethodget_token

(&self)

src/exchanges/kucoin/ws/subscription.rs:127

↓ 1 callersMethodget_ws_endpoint

(&self)

src/exchanges/kucoin/ws/subscription.rs:118

↓ 1 callersMethodhandle_bad_pair

Some(true) => subscription is empty Some(false) => subscription is not empty None => no bad pair found

src/clients/ws/single.rs:113

↓ 1 callersMethodhas_blockchain

checks if the currency is found in a certain blockchain

src/exchanges/normalized/types/currencies.rs:83

↓ 1 callersMethodis_gateway_timeout

(&self)

src/clients/rest_api/errors.rs:13

↓ 1 callersMethodis_timed_out

(&mut self, cx: &mut Context<'_>)

src/clients/ws/single.rs:235

↓ 1 callersMethodkind

channel kind (without values)

src/exchanges/traits/ws_channel.rs:25

↓ 1 callersMethodmake_critical

(&mut self, msg: String)

src/exchanges/okex/ws/message.rs:114

↓ 1 callersMethodmake_owned_ws_connection

(self)

src/exchanges/mod.rs:397

↓ 1 callersMethodmatches

(&self, _val: &T)

src/exchanges/traits/filter.rs:13

↓ 1 callersMethodneeds_business_ws

(&self)

src/exchanges/okex/ws/subscription.rs:21

↓ 1 callersMethodnormalize

(self)

src/exchanges/binance/rest_api/endpoints/instruments.rs:21

↓ 1 callersMethodnormalize

(self)

src/exchanges/binance/ws/channels/partial_book_depth.rs:21

↓ 1 callersMethodnormalize

(self)

src/exchanges/binance/ws/channels/diff_depth.rs:34

↓ 1 callersMethodnormalize

(self)

src/exchanges/binance/ws/channels/book_ticker.rs:36

↓ 1 callersMethodnormalize

(self)

src/exchanges/binance/ws/channels/trades.rs:31

↓ 1 callersMethodnormalize

(self)

src/exchanges/coinbase/ws/channels/matches.rs:28

↓ 1 callersMethodnormalize

(self)

src/exchanges/coinbase/ws/channels/ticker.rs:44

↓ 1 callersMethodnormalize

(self)

src/exchanges/kucoin/ws/channels/matches.rs:19

↓ 1 callersMethodnormalize

(self)

src/exchanges/kucoin/ws/channels/ticker.rs:23

↓ 1 callersMethodnormalize

(&self)

src/exchanges/bybit/pairs.rs:19

↓ 1 callersMethodnormalize

(self)

src/exchanges/bybit/ws/channels/orderbook.rs:26

↓ 1 callersMethodnormalize

(self)

src/exchanges/bybit/ws/channels/trades.rs:23

↓ 1 callersMethodnormalize

(self)

src/exchanges/normalized/ws/message.rs:34

↓ 1 callersMethodnormalize

(self)

src/exchanges/okex/rest_api/endpoints/instruments.rs:21

↓ 1 callersMethodnormalize

(self)

src/exchanges/okex/ws/channels/tickers.rs:74

↓ 1 callersMethodnormalize

(self)

src/exchanges/okex/ws/channels/trades.rs:31

↓ 1 callersMethodnormalize_with

(&self, base: &str, quote: &str)

src/exchanges/bybit/pairs.rs:23

↓ 1 callersMethodparse_for_bad_pair

(&mut self)

src/exchanges/coinbase/ws/message.rs:64

next →1–100 of 449, ranked by callers