Skip to content
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/poller.rs

cre8-app-provider · module poller · src · 604 lines (490 code, 63 comment) · sha 92c261e9e2a84e41

Items

const MIN_POLL_INTERVAL_SECS const DEFAULT_POLL_INTERVAL_SECS struct PollerConfig struct PollerStatus struct PollerHandle static POLLERS

Functions

By call-graph weight (PageRank; 1.0 is the average function). 29 functions in all.

functionkindlinescyclomaticcallerscalleesweightcrystal
normalized_symbol_keysrc/poller.rs:452fn52403.7
poll_json_querysrc/poller.rs:268fn71301.6
pollerssrc/poller.rs:85fn31301.6
symbol_matches_filtersrc/poller.rs:448fn32411.4
make_quote_eventsrc/poller.rs:463fn311511.3
update_statesrc/poller.rs:259fn41311.2
default_poll_interval_secssrc/poller.rs:47fn31311.2
all_poller_statussrc/poller.rs:90fn41121.1
stop_pollersrc/poller.rs:140fn134121.1
symbol_filter_setsrc/poller.rs:444fn31311
start_pollersrc/poller.rs:97fn414250.9
run_one_poll_withsrc/poller.rs:215fn433240.9
panic_payload_messagesrc/poller.rs:191fn93100.8
poll_jsonsrc/poller.rs:264fn31210.8
run_poll_step_recoveringsrc/poller.rs:180fn102220.8
fetch_poller_eventssrc/poller.rs:205fn95140.8
percent_encode_componentsrc/poller.rs:276fn153100.7
run_one_pollsrc/poller.rs:201fn31120.7
fetch_okx_spot_tickerssrc/poller.rs:296fn274140.7
fetch_kraken_tickerssrc/poller.rs:326fn624120.7
fetch_bitstamp_tickerssrc/poller.rs:390fn214140.7
fetch_coinbase_tickerssrc/poller.rs:415fn285130.7
poller_loopsrc/poller.rs:156fn235130.7
test_statesrc/poller.rs:553fn131110.6
default_poll_interval_reads_env_with_minimum_floorsrc/poller.rs:501fn101020.5
symbol_filter_matches_common_exchange_shapessrc/poller.rs:513fn81020.5
empty_symbol_filter_accepts_all_symbolssrc/poller.rs:523fn31010.5
recovering_poll_step_marks_state_error_on_panicsrc/poller.rs:528fn241030.5
run_one_poll_with_updates_success_and_error_statussrc/poller.rs:568fn361050.5

Source not readable from this process.