Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/SorellaLabs/cex-exchanges
/ functions
Functions
449 in github.com/SorellaLabs/cex-exchanges
⨍
Functions
449
◇
Types & classes
157
↓ 1 callers
Function
parse_month_digit
(month: String)
src/exchanges/bybit/rest_api/endpoints/instruments.rs:290
↓ 1 callers
Function
parse_stream_to_pair
(stream: String)
src/exchanges/binance/ws/message.rs:128
↓ 1 callers
Method
remove_bad_pair
(&mut self, bad_pair: NormalizedTradingPair)
src/exchanges/okex/mod.rs:100
↓ 1 callers
Method
remove_pair
(&mut self, pair: &Self::TradingPair)
src/exchanges/binance/ws/subscription.rs:44
↓ 1 callers
Method
remove_pair
(&mut self, pair: &Self::TradingPair)
src/exchanges/coinbase/ws/subscription.rs:39
↓ 1 callers
Method
remove_pair
(&mut self, pair: &Self::TradingPair)
src/exchanges/kucoin/ws/subscription.rs:76
↓ 1 callers
Method
remove_pair
(&mut self, pair: &Self::TradingPair)
src/exchanges/bybit/ws/subscription.rs:29
↓ 1 callers
Method
remove_pair
(&mut self, pair: &Self::TradingPair)
src/exchanges/okex/ws/subscription.rs:43
↓ 1 callers
Method
rest_api_call
(&self, web_client: &reqwest::Client, api_channel: NormalizedRestApiRequest)
src/exchanges/bybit/mod.rs:123
↓ 1 callers
Method
spawn_on_new_thread
(self, tx: UnboundedSender<CombinedWsMessage>)
src/clients/ws/mutli.rs:29
↓ 1 callers
Method
take_symbols
(self)
src/exchanges/binance/rest_api/response.rs:22
↓ 1 callers
Method
try_single_subscription
(&self)
src/exchanges/binance/ws/subscription.rs:20
↓ 1 callers
Method
with_max_retries
(mut self, max_retries: u64)
src/clients/ws/config.rs:11
↓ 1 callers
Method
wrapped
(&mut self, is_wrapped: bool)
src/exchanges/normalized/types/currencies.rs:98
Method
add_channel
(&mut self, channel: Self::WsChannel)
src/exchanges/binance/ws/subscription.rs:39
Method
add_channel
(&mut self, channel: Self::WsChannel)
src/exchanges/coinbase/ws/subscription.rs:35
Method
add_channel
(&mut self, channel: Self::WsChannel)
src/exchanges/bybit/ws/subscription.rs:24
Method
add_channel
(&mut self, channel: Self::WsChannel)
src/exchanges/okex/ws/subscription.rs:38
Method
add_channels_all_exchanges
(mut self, channels: &[NormalizedWsChannelKinds])
src/exchanges/normalized/ws/builder.rs:41
Method
add_pairs_all_channels_all_exchanges
adds trading pairs to all channels for all exchanges
src/exchanges/normalized/ws/builder.rs:67
Method
add_pairs_single_channel_all_exchanges
adds trading pairs to a channels in all exchanges
src/exchanges/normalized/ws/builder.rs:79
Method
all_currencies
(&self)
src/clients/rest_api/mod.rs:16
Method
all_instruments
(&self)
src/clients/rest_api/mod.rs:22
Method
bad_pair
(&self)
src/exchanges/normalized/ws/message.rs:61
Method
base
(&self)
src/exchanges/normalized/types/pairs.rs:50
Method
base_and_quote
(b: String, q: String)
src/exchanges/normalized/types/instruments.rs:109
Method
base_only
(v: String)
src/exchanges/normalized/types/instruments.rs:113
Method
base_or_quote
(v: String)
src/exchanges/normalized/types/instruments.rs:105
Method
build_all_multistream
builds the multistream ws client
src/exchanges/normalized/ws/builder.rs:123
Method
build_from_all_instruments
( channels: &'a [<Self::WsChannel as crate::traits::SpecificWsChannel>::ChannelKind], streams_
src/exchanges/binance/ws/builder.rs:120
Method
build_from_all_instruments
( channels: &'a [<Self::WsChannel as crate::traits::SpecificWsChannel>::ChannelKind], streams_
src/exchanges/coinbase/ws/builder.rs:112
Method
build_from_all_instruments
( channels: &'a [<Self::WsChannel as crate::traits::SpecificWsChannel>::ChannelKind], streams_
src/exchanges/kucoin/ws/builder.rs:120
Method
build_from_all_instruments
( channels: &'a [<Self::WsChannel as crate::traits::SpecificWsChannel>::ChannelKind], streams_
src/exchanges/bybit/ws/builder.rs:116
Method
build_from_all_instruments
( channels: &'a [<Self::WsChannel as crate::traits::SpecificWsChannel>::ChannelKind], streams_
src/exchanges/okex/ws/builder.rs:121
Method
build_from_all_instruments_util
(channels: &[BinanceWsChannelKind], streams_per_connection: Option<usize>)
src/exchanges/binance/ws/builder.rs:19
Method
build_from_all_instruments_util
(channels: &[CoinbaseWsChannelKind], streams_per_connection: Option<usize>)
src/exchanges/coinbase/ws/builder.rs:19
Method
build_from_all_instruments_util
(channels: &[KucoinWsChannelKind], streams_per_connection: Option<usize>)
src/exchanges/kucoin/ws/builder.rs:24
Method
build_from_all_instruments_util
(channels: &[BybitWsChannelKind], streams_per_connection: Option<usize>)
src/exchanges/bybit/ws/builder.rs:19
Method
build_from_all_instruments_util
( channels: &[OkexWsChannelKind], streams_per_connection: Option<usize>, proxy: Option
src/exchanges/okex/ws/builder.rs:26
Method
build_from_raw
(raw_streams: Vec<Pin<Box<dyn Stream<Item = CombinedWsMessage> + Send>>>)
src/clients/ws/mutli.rs:48
Method
build_many_distributed
(self)
src/exchanges/binance/ws/builder.rs:82
Method
build_many_distributed
(self)
src/exchanges/coinbase/ws/builder.rs:73
Method
build_many_distributed
(self)
src/exchanges/kucoin/ws/builder.rs:81
Method
build_many_distributed
(self)
src/exchanges/bybit/ws/builder.rs:77
Method
build_many_packed
(self, connections_per_stream: Option<usize>)
src/exchanges/binance/ws/builder.rs:100
Method
build_many_packed
(self, connections_per_stream: Option<usize>)
src/exchanges/coinbase/ws/builder.rs:92
Method
build_many_packed
(self, connections_per_stream: Option<usize>)
src/exchanges/kucoin/ws/builder.rs:100
Method
build_many_packed
(self, connections_per_stream: Option<usize>)
src/exchanges/bybit/ws/builder.rs:96
Method
build_multistream
(self, config: WsStreamConfig)
src/clients/ws/mutli.rs:88
Method
build_multithreaded_multistream_ws_from_normalized
( self, map: Vec<NormalizedWsChannels>, exch_currency_proxy: Option<CexExchange>,
src/exchanges/mod.rs:118
Method
build_single
(self)
src/exchanges/binance/ws/builder.rs:72
Method
build_single
(self)
src/exchanges/coinbase/ws/builder.rs:66
Method
build_single
(self)
src/exchanges/kucoin/ws/builder.rs:71
Method
build_single
(self)
src/exchanges/bybit/ws/builder.rs:67
Method
count_entries
(&self)
src/exchanges/binance/ws/channels/mod.rs:104
Method
count_entries
(&self)
src/exchanges/coinbase/ws/channels/mod.rs:74
Method
count_entries
(&self)
src/exchanges/kucoin/ws/channels/mod.rs:69
Method
count_entries
(&self)
src/exchanges/bybit/ws/channels/mod.rs:69
Method
count_entries
(&self)
src/exchanges/okex/ws/channels/mod.rs:67
Method
default
()
src/exchanges/binance/ws/subscription.rs:30
Method
default
()
src/exchanges/coinbase/ws/subscription.rs:16
Method
default
()
src/exchanges/okex/mod.rs:131
Method
default
()
src/exchanges/okex/ws/subscription.rs:15
Method
denormalize_raw_trading_pair
converts a normalized trading pair back into the native exchange's pair
src/exchanges/mod.rs:304
Method
deserialize
(deserializer: D)
src/exchanges/binance/pairs.rs:44
Method
deserialize
(deserializer: D)
src/exchanges/binance/rest_api/endpoints/instruments.rs:59
Method
deserialize
(deserializer: D)
src/exchanges/binance/rest_api/endpoints/symbols.rs:71
Method
deserialize
(deserializer: D)
src/exchanges/binance/ws/message.rs:21
Method
deserialize
(deserializer: D)
src/exchanges/coinbase/pairs.rs:38
Method
deserialize
(deserializer: D)
src/exchanges/coinbase/rest_api/endpoints/currencies.rs:33
Method
deserialize
(deserializer: D)
src/exchanges/coinbase/rest_api/endpoints/products.rs:30
Method
deserialize
(deserializer: D)
src/exchanges/kucoin/pairs.rs:33
Method
deserialize
(deserializer: D)
src/exchanges/kucoin/ws/message.rs:40
Method
deserialize
(deserializer: D)
src/exchanges/bybit/pairs.rs:44
Method
deserialize
(deserializer: D)
src/exchanges/bybit/rest_api/endpoints/instruments.rs:30
Method
deserialize
(deserializer: D)
src/exchanges/bybit/rest_api/endpoints/coins.rs:26
Method
deserialize
(deserializer: D)
src/exchanges/bybit/ws/message.rs:56
Method
deserialize
(deserializer: D)
src/exchanges/bybit/ws/channels/orderbook.rs:104
Method
deserialize
(deserializer: D)
src/exchanges/normalized/types/instruments.rs:48
Method
deserialize
(deserializer: D)
src/exchanges/normalized/types/blockchain.rs:92
Method
deserialize
(deserializer: D)
src/exchanges/okex/pairs.rs:52
Method
deserialize
(deserializer: D)
src/exchanges/okex/ws/message.rs:61
Method
display_ws_subscription
(&self)
src/exchanges/binance/mod.rs:190
Method
display_ws_subscription
(&self)
src/exchanges/coinbase/mod.rs:113
Method
display_ws_subscription
(&self)
src/exchanges/kucoin/mod.rs:109
Method
display_ws_subscription
(&self)
src/exchanges/bybit/mod.rs:132
Method
display_ws_subscription
(&self)
src/exchanges/okex/mod.rs:125
Method
eq
(&self, other: &NormalizedRestApiDataTypes)
src/exchanges/binance/rest_api/response.rs:49
Method
eq
(&self, other: &NormalizedRestApiDataTypes)
src/exchanges/binance/rest_api/endpoints/instruments.rs:30
Method
eq
(&self, other: &NormalizedRestApiDataTypes)
src/exchanges/binance/rest_api/endpoints/symbols.rs:36
Method
eq
(&self, other: &NormalizedWsDataTypes)
src/exchanges/binance/ws/message.rs:46
Method
eq
(&self, other: &NormalizedL2)
src/exchanges/binance/ws/channels/partial_book_depth.rs:41
Method
eq
(&self, other: &NormalizedL2)
src/exchanges/binance/ws/channels/diff_depth.rs:57
Method
eq
(&self, other: &NormalizedQuote)
src/exchanges/binance/ws/channels/book_ticker.rs:52
Method
eq
(&self, other: &NormalizedTrade)
src/exchanges/binance/ws/channels/trades.rs:45
Method
eq
(&self, other: &NormalizedRestApiDataTypes)
src/exchanges/coinbase/rest_api/response.rs:49
Method
eq
(&self, other: &NormalizedRestApiDataTypes)
src/exchanges/coinbase/rest_api/endpoints/currencies.rs:44
Method
eq
(&self, other: &NormalizedRestApiDataTypes)
src/exchanges/coinbase/rest_api/endpoints/products.rs:41
Method
eq
(&self, other: &NormalizedWsDataTypes)
src/exchanges/coinbase/ws/message.rs:35
Method
eq
(&self, other: &NormalizedTrade)
src/exchanges/coinbase/ws/channels/matches.rs:42
← previous
next →
101–200 of 449, ranked by callers