1 viewer
rust 1,860,549 · typescript 235,540 · javascript 132,956 · python 20,426 · 6,408 files · digest f04d4637f52b · built in 1.5 s · crystals off
crates/cre8-app-provider/src/socket.rs
Items
type ProviderSocket struct ResolvedStream struct StreamHandle struct StreamState static STREAMS enum StreamAttempt struct KeepAlive impl KeepAlive const KUCOIN_BULLET_SCHEME enum SocketMessageAction type StreamNormalizer const STREAM_NORMALIZERS const PROVIDER_ALIAS_GROUPS
Functions
By call-graph weight (PageRank; 1.0 is the average function). 125 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| market_recordsrc/socket.rs:1537 | fn | 20 | 1 | 11 | 0 | 3.4 | |
| test_streamsrc/socket.rs:1858 | fn | 17 | 1 | 12 | 0 | 2.8 | |
| resolve_streamsrc/socket.rs:552 | fn | 13 | 3 | 7 | 9 | 2.5 | |
| field_stringsrc/socket.rs:1558 | fn | 10 | 4 | 8 | 1 | 2.3 | |
| builtin_supported_channelssrc/socket.rs:579 | fn | 10 | 6 | 2 | 0 | 2 | |
| normalize_genericsrc/socket.rs:1498 | fn | 12 | 1 | 6 | 4 | 1.9 | |
| sample_exchange_socketsrc/socket.rs:66 | fn | 27 | 1 | 2 | 6 | 1.7 | |
| streamssrc/socket.rs:1595 | fn | 3 | 1 | 4 | 0 | 1.6 | |
| parse_socket_binarysrc/socket.rs:519 | fn | 3 | 1 | 1 | 0 | 1.4 | |
| websocket_reject_statussrc/socket.rs:328 | fn | 6 | 2 | 1 | 0 | 1.4 | |
| channel_stream_suffixsrc/socket.rs:1820 | fn | 7 | 2 | 3 | 2 | 1.4 | |
| update_statesrc/socket.rs:1641 | fn | 5 | 2 | 5 | 0 | 1.4 | |
| stop_exchange_socketsrc/socket.rs:176 | fn | 32 | 3 | 1 | 4 | 1.3 | |
| state_jsonsrc/socket.rs:1599 | fn | 20 | 1 | 3 | 0 | 1.2 | |
| subscription_messagessrc/socket.rs:450 | fn | 9 | 3 | 2 | 0 | 1.2 | |
| add_socket_headerssrc/socket.rs:428 | fn | 12 | 3 | 1 | 0 | 1.2 | |
| builtin_streamsrc/socket.rs:663 | fn | 13 | 9 | 2 | 8 | 1.2 | |
| normalized_symbolsrc/socket.rs:1747 | fn | 15 | 6 | 2 | 2 | 1.2 | |
| kucoin_endpoint_from_bulletsrc/socket.rs:476 | fn | 18 | 3 | 2 | 1 | 1.1 | |
| start_exchange_socketsrc/socket.rs:123 | fn | 52 | 3 | 2 | 9 | 1.1 | |
| is_websocketsrc/socket.rs:962 | fn | 14 | 3 | 1 | 0 | 1.1 | |
| socket_message_actionsrc/socket.rs:509 | fn | 9 | 5 | 2 | 1 | 1.1 | |
| binance_channel_stream_suffixsrc/socket.rs:1828 | fn | 8 | 4 | 1 | 0 | 1.1 | |
| default_channel_stream_suffixsrc/socket.rs:1837 | fn | 3 | 2 | 1 | 0 | 1.1 | |
| venue_unavailable_messagesrc/socket.rs:313 | fn | 14 | 3 | 3 | 1 | 1 | |
| kucoin_bullet_endpointsrc/socket.rs:466 | fn | 9 | 1 | 1 | 4 | 1 | |
| generic_market_kindsrc/socket.rs:1511 | fn | 13 | 6 | 2 | 0 | 1 | |
| normalize_stream_messagesrc/socket.rs:1007 | fn | 11 | 2 | 4 | 3 | 1 | |
| stream_normalizersrc/socket.rs:1033 | fn | 3 | 1 | 2 | 0 | 1 | |
| default_symbolsrc/socket.rs:1763 | fn | 12 | 8 | 1 | 0 | 1 | |
| bitfinex_symbolsrc/socket.rs:1779 | fn | 13 | 4 | 1 | 0 | 1 | |
| normalized_channelsrc/socket.rs:1793 | fn | 8 | 2 | 2 | 2 | 0.9 | |
| env_credentialsrc/socket.rs:1583 | fn | 7 | 1 | 1 | 2 | 0.9 | |
| normalized_binance_channelsrc/socket.rs:1802 | fn | 8 | 4 | 1 | 0 | 0.9 | |
| normalized_default_channelsrc/socket.rs:1811 | fn | 8 | 3 | 1 | 0 | 0.9 | |
| generic_market_fieldssrc/socket.rs:1525 | fn | 11 | 2 | 1 | 0 | 0.9 | |
| stream_statussrc/socket.rs:209 | fn | 12 | 2 | 1 | 2 | 0.9 | |
| stream_status_summarysrc/socket.rs:222 | fn | 12 | 2 | 1 | 2 | 0.9 | |
| env_slugsrc/socket.rs:1591 | fn | 3 | 2 | 1 | 0 | 0.9 | |
| state_summary_jsonsrc/socket.rs:1620 | fn | 20 | 1 | 1 | 0 | 0.9 | |
| socket_timeoutsrc/socket.rs:1715 | fn | 3 | 1 | 2 | 0 | 0.8 | |
| open_socketsrc/socket.rs:367 | fn | 8 | 1 | 2 | 5 | 0.8 | |
| socket_requestsrc/socket.rs:395 | fn | 5 | 1 | 2 | 1 | 0.8 | |
| accepts_messagesrc/socket.rs:994 | fn | 12 | 2 | 3 | 1 | 0.8 | |
| coinbase_l2_levelssrc/socket.rs:1053 | fn | 25 | 5 | 1 | 0 | 0.8 | |
| coinbase_accept_typessrc/socket.rs:857 | fn | 9 | 3 | 1 | 0 | 0.8 | |
| coinbase_normalizersrc/socket.rs:867 | fn | 9 | 3 | 1 | 0 | 0.8 | |
| read_poll_timeoutsrc/socket.rs:379 | fn | 6 | 3 | 2 | 0 | 0.7 | |
| collect_stream_samplessrc/socket.rs:94 | fn | 24 | 3 | 1 | 6 | 0.7 | |
| unsupported_stream_errorsrc/socket.rs:569 | fn | 9 | 2 | 1 | 1 | 0.7 | |
| select_manifest_streamsrc/socket.rs:590 | fn | 8 | 2 | 1 | 1 | 0.7 | |
| resolved_from_manifestsrc/socket.rs:599 | fn | 35 | 2 | 1 | 7 | 0.7 | |
| synthetic_manifestsrc/socket.rs:952 | fn | 9 | 1 | 1 | 0 | 0.7 | |
| provider_aliassrc/socket.rs:1731 | fn | 11 | 2 | 1 | 0 | 0.7 | |
| normalize_coinbasesrc/socket.rs:1096 | fn | 45 | 4 | 1 | 4 | 0.7 | |
| normalize_binancesrc/socket.rs:1142 | fn | 13 | 1 | 1 | 4 | 0.7 | |
| normalize_krakensrc/socket.rs:1188 | fn | 53 | 4 | 1 | 3 | 0.7 | |
| normalize_bitstampsrc/socket.rs:1259 | fn | 38 | 2 | 1 | 2 | 0.7 | |
| normalize_okxsrc/socket.rs:1298 | fn | 49 | 5 | 1 | 3 | 0.7 | |
| normalize_gateiosrc/socket.rs:1348 | fn | 42 | 4 | 1 | 3 | 0.7 | |
| normalize_bitfinexsrc/socket.rs:1391 | fn | 56 | 8 | 1 | 2 | 0.7 | |
| normalize_kucoinsrc/socket.rs:1448 | fn | 49 | 6 | 1 | 3 | 0.7 | |
| builtin_pingsrc/socket.rs:638 | fn | 6 | 2 | 2 | 0 | 0.7 | |
| apply_socket_message_actionsrc/socket.rs:523 | fn | 10 | 3 | 1 | 0 | 0.7 | |
| socket_read_errorsrc/socket.rs:534 | fn | 8 | 3 | 1 | 0 | 0.7 | |
| KeepAlive::for_streamsrc/socket.rs:408 | method | 7 | 1 | 2 | 0 | 0.7 | |
| KeepAlive::maybe_pingsrc/socket.rs:416 | method | 10 | 2 | 2 | 1 | 0.7 | |
| read_socket_jsonsrc/socket.rs:495 | fn | 6 | 2 | 2 | 3 | 0.7 | |
| binance_accept_typessrc/socket.rs:902 | fn | 14 | 4 | 1 | 0 | 0.7 | |
| binance_normalizersrc/socket.rs:917 | fn | 8 | 5 | 1 | 0 | 0.7 | |
| run_stream_oncesrc/socket.rs:272 | fn | 37 | 3 | 1 | 6 | 0.7 | |
| mark_stream_reconnectingsrc/socket.rs:359 | fn | 7 | 1 | 2 | 2 | 0.7 | |
| normalize_coinbase_snapshotsrc/socket.rs:1037 | fn | 15 | 1 | 1 | 1 | 0.6 | |
| normalize_coinbase_l2_updatesrc/socket.rs:1079 | fn | 16 | 1 | 1 | 2 | 0.6 | |
| binance_market_kindsrc/socket.rs:1156 | fn | 9 | 6 | 1 | 0 | 0.6 | |
| binance_market_fieldssrc/socket.rs:1166 | fn | 21 | 2 | 1 | 0 | 0.6 | |
| resolve_socket_endpointsrc/socket.rs:388 | fn | 6 | 2 | 1 | 1 | 0.6 | |
| send_subscription_messagesrc/socket.rs:441 | fn | 6 | 2 | 1 | 1 | 0.6 | |
| set_read_timeoutsrc/socket.rs:543 | fn | 8 | 3 | 1 | 0 | 0.6 | |
| builtin_kraken_streamsrc/socket.rs:680 | fn | 27 | 6 | 1 | 0 | 0.6 | |
| builtin_bitstamp_streamsrc/socket.rs:711 | fn | 23 | 4 | 1 | 0 | 0.6 | |
| builtin_kucoin_streamsrc/socket.rs:739 | fn | 29 | 4 | 1 | 0 | 0.6 | |
| builtin_gateio_streamsrc/socket.rs:771 | fn | 29 | 4 | 1 | 0 | 0.6 | |
| builtin_bitfinex_streamsrc/socket.rs:805 | fn | 22 | 2 | 1 | 0 | 0.6 | |
| builtin_coinbase_streamsrc/socket.rs:828 | fn | 28 | 3 | 1 | 2 | 0.6 | |
| builtin_binance_streamsrc/socket.rs:880 | fn | 21 | 3 | 1 | 3 | 0.6 | |
| builtin_okx_streamsrc/socket.rs:928 | fn | 23 | 5 | 1 | 0 | 0.6 | |
| stream_loopsrc/socket.rs:241 | fn | 30 | 5 | 1 | 3 | 0.6 | |
| should_collect_more_messagessrc/socket.rs:119 | fn | 3 | 2 | 1 | 0 | 0.6 | |
| pump_socket_messagessrc/socket.rs:335 | fn | 23 | 5 | 1 | 7 | 0.6 | |
| stream_contextsrc/socket.rs:645 | fn | 17 | 3 | 1 | 1 | 0.6 | |
| render_pairssrc/socket.rs:977 | fn | 8 | 1 | 1 | 2 | 0.6 | |
| response_pathsrc/socket.rs:986 | fn | 7 | 1 | 1 | 0 | 0.6 | |
| build_runtime_stream_idsrc/socket.rs:1841 | fn | 12 | 2 | 1 | 0 | 0.6 | |
| publish_stream_eventsrc/socket.rs:1647 | fn | 20 | 5 | 1 | 9 | 0.6 | |
| retained_stream_eventsrc/socket.rs:1668 | fn | 9 | 3 | 1 | 0 | 0.5 | |
| mark_sink_oksrc/socket.rs:1678 | fn | 14 | 1 | 1 | 1 | 0.5 | |
| mark_sink_errorsrc/socket.rs:1693 | fn | 13 | 1 | 1 | 1 | 0.5 | |
| push_limitedsrc/socket.rs:1707 | fn | 7 | 2 | 1 | 0 | 0.5 | |
| kraken_depth_levelssrc/socket.rs:1242 | fn | 16 | 1 | 0 | 0 | 0.5 | |
| depth_sidesrc/socket.rs:1569 | fn | 3 | 1 | 0 | 1 | 0.5 | |
| env_credentialssrc/socket.rs:1573 | fn | 9 | 3 | 0 | 1 | 0.5 | |
| resolves_builtin_coinbase_tickersrc/socket.rs:1877 | fn | 8 | 1 | 0 | 1 | 0.5 | |
| resolves_builtin_binance_depthsrc/socket.rs:1887 | fn | 11 | 1 | 0 | 1 | 0.5 | |
| builds_socket_request_headers_and_subscription_messagessrc/socket.rs:1900 | fn | 25 | 3 | 0 | 3 | 0.5 | |
| classifies_socket_messages_without_a_live_socketsrc/socket.rs:1927 | fn | 19 | 5 | 0 | 1 | 0.5 | |
| channel_aliases_preserve_exchange_depth_routessrc/socket.rs:1948 | fn | 12 | 1 | 0 | 2 | 0.5 | |
| builtin_streams_cover_supported_exchange_providerssrc/socket.rs:1962 | fn | 37 | 3 | 0 | 1 | 0.5 | |
| unsupported_channels_error_with_supported_listsrc/socket.rs:2001 | fn | 9 | 1 | 0 | 1 | 0.5 | |
| resolves_builtin_binance_us_variantsrc/socket.rs:2012 | fn | 9 | 1 | 0 | 2 | 0.5 | |
| venue_unavailable_maps_http_451_to_actionable_messagesrc/socket.rs:2023 | fn | 23 | 1 | 0 | 2 | 0.5 | |
| kucoin_bullet_response_builds_tokenized_endpointsrc/socket.rs:2048 | fn | 18 | 1 | 0 | 1 | 0.5 | |
| kucoin_stream_pings_and_filters_to_data_messagessrc/socket.rs:2068 | fn | 20 | 1 | 0 | 4 | 0.5 | |
| normalizes_kucoin_ticker_and_depth_framessrc/socket.rs:2090 | fn | 51 | 1 | 0 | 2 | 0.5 | |
| normalizes_kraken_ticker_and_book_framessrc/socket.rs:2143 | fn | 49 | 1 | 0 | 2 | 0.5 | |
| normalizes_bitstamp_trade_and_order_book_framessrc/socket.rs:2194 | fn | 36 | 1 | 0 | 2 | 0.5 | |
| normalizes_okx_ticker_and_books_framessrc/socket.rs:2232 | fn | 41 | 1 | 0 | 2 | 0.5 | |
| coinbase_depth_marks_snapshot_and_incremental_updatessrc/socket.rs:2275 | fn | 26 | 1 | 0 | 2 | 0.5 | |
| normalizes_gateio_ticker_and_order_book_framessrc/socket.rs:2303 | fn | 43 | 1 | 0 | 2 | 0.5 | |
| normalizes_bitfinex_array_framessrc/socket.rs:2348 | fn | 27 | 1 | 0 | 2 | 0.5 | |
| per_venue_symbol_dialects_are_coercedsrc/socket.rs:2377 | fn | 21 | 1 | 0 | 1 | 0.5 | |
| normalize_stream_message_dispatches_after_response_pathsrc/socket.rs:2400 | fn | 23 | 1 | 0 | 2 | 0.5 | |
| generic_normalizer_maps_market_kinds_and_depth_fieldssrc/socket.rs:2425 | fn | 22 | 1 | 0 | 3 | 0.5 | |
| normalizes_binance_depth_snapshotsrc/socket.rs:2449 | fn | 16 | 1 | 0 | 2 | 0.5 | |
| samples_coinbase_ticker_socketsrc/socket.rs:2468 | fn | 5 | 1 | 0 | 1 | 0.5 |
Source not readable from this process.