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-crawler/src/connection.rs
Items
enum CrawlerAction struct CrawlerConnectionInput struct TickTotals const ACTION_ALIASES struct RunnerLoopOptions impl RunnerLoopOptions struct RunnerTotals impl RunnerTotals
Functions
By call-graph weight (PageRank; 1.0 is the average function). 84 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| seed_urlsrc/connection.rs:138 | fn | 8 | 1 | 7 | 0 | 1.8 | |
| parse_actionsrc/connection.rs:109 | fn | 28 | 3 | 3 | 1 | 1.6 | |
| run_runner_status_updatesrc/connection.rs:953 | fn | 12 | 1 | 1 | 2 | 1.2 | |
| json_usizesrc/connection.rs:195 | fn | 10 | 2 | 2 | 0 | 1.2 | |
| search_querysrc/connection.rs:147 | fn | 3 | 1 | 3 | 0 | 1.2 | |
| record_tick_failuresrc/connection.rs:549 | fn | 21 | 2 | 3 | 2 | 1.2 | |
| runner_identifiersrc/connection.rs:155 | fn | 5 | 1 | 2 | 1 | 1.2 | |
| has_policy_inputsrc/connection.rs:161 | fn | 8 | 6 | 5 | 0 | 1.2 | |
| apply_policy_inputsrc/connection.rs:170 | fn | 12 | 1 | 5 | 3 | 1.2 | |
| connectsrc/connection.rs:1091 | fn | 5 | 1 | 2 | 2 | 1.1 | |
| run_ticksrc/connection.rs:296 | fn | 34 | 2 | 3 | 11 | 1.1 | |
| tick_usizesrc/connection.rs:819 | fn | 3 | 1 | 1 | 0 | 1.1 | |
| step_one_runnersrc/connection.rs:966 | fn | 8 | 2 | 2 | 5 | 1 | |
| process_tick_itemsrc/connection.rs:451 | fn | 17 | 1 | 1 | 4 | 1 | |
| string_arraysrc/connection.rs:210 | fn | 11 | 1 | 2 | 0 | 1 | |
| provider_errorsrc/connection.rs:222 | fn | 10 | 2 | 2 | 0 | 1 | |
| run_crawler_actionsrc/connection.rs:1097 | fn | 24 | 4 | 1 | 4 | 1 | |
| run_due_runnerssrc/connection.rs:1039 | fn | 24 | 3 | 2 | 2 | 0.8 | |
| run_crawler_runner_status_control_actionsrc/connection.rs:1217 | fn | 11 | 3 | 1 | 1 | 0.8 | |
| run_crawler_runner_query_control_actionsrc/connection.rs:1229 | fn | 12 | 4 | 1 | 3 | 0.8 | |
| override_string_listsrc/connection.rs:183 | fn | 3 | 2 | 1 | 0 | 0.8 | |
| optional_usize_maxsrc/connection.rs:187 | fn | 3 | 1 | 1 | 0 | 0.8 | |
| optional_i64_clampsrc/connection.rs:191 | fn | 3 | 1 | 1 | 0 | 0.8 | |
| handle_tick_provider_responsesrc/connection.rs:571 | fn | 47 | 2 | 1 | 10 | 0.8 | |
| run_intelsrc/connection.rs:823 | fn | 26 | 1 | 1 | 3 | 0.8 | |
| run_indexsrc/connection.rs:850 | fn | 24 | 2 | 1 | 4 | 0.8 | |
| run_crawler_status_actionsrc/connection.rs:1134 | fn | 7 | 1 | 1 | 0 | 0.8 | |
| run_crawler_seed_actionsrc/connection.rs:1142 | fn | 13 | 1 | 1 | 3 | 0.8 | |
| run_crawler_runner_execution_actionsrc/connection.rs:1188 | fn | 12 | 4 | 1 | 3 | 0.8 | |
| run_crawler_runner_control_actionsrc/connection.rs:1201 | fn | 15 | 3 | 1 | 2 | 0.8 | |
| json_stringsrc/connection.rs:206 | fn | 3 | 1 | 2 | 0 | 0.8 | |
| record_tick_runsrc/connection.rs:392 | fn | 30 | 1 | 1 | 1 | 0.7 | |
| tick_responsesrc/connection.rs:423 | fn | 27 | 1 | 1 | 0 | 0.7 | |
| run_runner_statussrc/connection.rs:939 | fn | 13 | 1 | 1 | 2 | 0.7 | |
| run_runner_duesrc/connection.rs:1064 | fn | 10 | 1 | 1 | 1 | 0.7 | |
| run_runner_stepsrc/connection.rs:1075 | fn | 15 | 2 | 1 | 4 | 0.7 | |
| batch_limitsrc/connection.rs:151 | fn | 3 | 1 | 2 | 0 | 0.7 | |
| run_runnersrc/connection.rs:698 | fn | 9 | 1 | 1 | 6 | 0.7 | |
| run_runner_startsrc/connection.rs:875 | fn | 26 | 1 | 1 | 4 | 0.7 | |
| seed_action_policysrc/connection.rs:1156 | fn | 13 | 2 | 1 | 4 | 0.7 | |
| input_with_actionsrc/connection.rs:1310 | fn | 3 | 1 | 1 | 0 | 0.7 | |
| tick_item_seed_or_failuresrc/connection.rs:469 | fn | 21 | 2 | 1 | 2 | 0.7 | |
| tick_item_policysrc/connection.rs:491 | fn | 8 | 2 | 1 | 3 | 0.7 | |
| handle_tick_fetch_resultsrc/connection.rs:500 | fn | 17 | 2 | 1 | 2 | 0.7 | |
| fetch_frontier_itemsrc/connection.rs:518 | fn | 30 | 2 | 1 | 1 | 0.7 | |
| run_crawler_setup_actionsrc/connection.rs:1122 | fn | 11 | 3 | 1 | 2 | 0.7 | |
| run_crawler_runner_actionsrc/connection.rs:1170 | fn | 17 | 3 | 1 | 2 | 0.7 | |
| run_crawler_listing_actionsrc/connection.rs:1242 | fn | 13 | 4 | 1 | 3 | 0.7 | |
| run_crawler_terminal_actionsrc/connection.rs:1289 | fn | 16 | 4 | 1 | 2 | 0.7 | |
| run_frontier_listingsrc/connection.rs:1256 | fn | 9 | 1 | 1 | 1 | 0.7 | |
| run_runs_listingsrc/connection.rs:1266 | fn | 9 | 1 | 1 | 1 | 0.7 | |
| run_search_listingsrc/connection.rs:1276 | fn | 12 | 1 | 1 | 2 | 0.7 | |
| runner_skip_reasonsrc/connection.rs:975 | fn | 9 | 3 | 1 | 0 | 0.7 | |
| skipped_runner_responsesrc/connection.rs:985 | fn | 8 | 1 | 1 | 0 | 0.7 | |
| runner_step_tick_inputsrc/connection.rs:994 | fn | 17 | 1 | 1 | 0 | 0.7 | |
| handle_runner_tick_resultsrc/connection.rs:1012 | fn | 26 | 2 | 1 | 2 | 0.7 | |
| RunnerLoopOptions::sleep_after_ticksrc/connection.rs:782 | method | 5 | 3 | 1 | 0 | 0.7 | |
| RunnerTotals::observe_ticksrc/connection.rs:809 | method | 8 | 1 | 1 | 1 | 0.7 | |
| runner_start_seedsrc/connection.rs:902 | fn | 14 | 2 | 1 | 4 | 0.6 | |
| runner_start_policysrc/connection.rs:926 | fn | 12 | 2 | 1 | 4 | 0.6 | |
| required_runner_start_seed_idsrc/connection.rs:917 | fn | 8 | 1 | 1 | 0 | 0.6 | |
| seed_runnersrc/connection.rs:685 | fn | 12 | 2 | 1 | 6 | 0.6 | |
| run_runner_loopsrc/connection.rs:708 | fn | 23 | 5 | 1 | 3 | 0.6 | |
| runner_responsesrc/connection.rs:732 | fn | 23 | 1 | 1 | 0 | 0.6 | |
| runner_tick_inputsrc/connection.rs:756 | fn | 13 | 2 | 1 | 0 | 0.6 | |
| runner_loop_optionssrc/connection.rs:789 | fn | 8 | 1 | 1 | 0 | 0.6 | |
| seed_for_ticksrc/connection.rs:233 | fn | 18 | 3 | 1 | 6 | 0.6 | |
| tick_seed_filtersrc/connection.rs:252 | fn | 9 | 1 | 1 | 0 | 0.6 | |
| idle_tick_responsesrc/connection.rs:262 | fn | 33 | 1 | 1 | 1 | 0.6 | |
| record_tick_and_responsesrc/connection.rs:331 | fn | 28 | 1 | 1 | 2 | 0.6 | |
| process_tick_itemssrc/connection.rs:360 | fn | 14 | 2 | 1 | 1 | 0.6 | |
| tick_statussrc/connection.rs:375 | fn | 9 | 4 | 1 | 0 | 0.6 | |
| tick_messagesrc/connection.rs:385 | fn | 6 | 1 | 1 | 0 | 0.6 | |
| accumulate_tick_importssrc/connection.rs:619 | fn | 7 | 1 | 1 | 1 | 0.6 | |
| extract_tick_intelsrc/connection.rs:627 | fn | 39 | 5 | 1 | 1 | 0.6 | |
| index_tick_pagesrc/connection.rs:667 | fn | 17 | 3 | 1 | 1 | 0.6 | |
| RunnerLoopOptions::should_stopsrc/connection.rs:778 | method | 3 | 2 | 0 | 1 | 0.5 | |
| parse_action_recognises_canonical_and_alias_verbssrc/connection.rs:1315 | fn | 21 | 1 | 0 | 2 | 0.5 | |
| parse_action_infers_seed_when_url_is_present_without_actionsrc/connection.rs:1338 | fn | 13 | 1 | 0 | 1 | 0.5 | |
| seed_url_trims_and_drops_empty_stringssrc/connection.rs:1353 | fn | 17 | 1 | 0 | 1 | 0.5 | |
| string_array_filters_empty_and_non_stringssrc/connection.rs:1372 | fn | 11 | 1 | 0 | 1 | 0.5 | |
| json_helpers_handle_nested_paths_and_missing_keyssrc/connection.rs:1385 | fn | 16 | 1 | 0 | 2 | 0.5 | |
| provider_error_extracts_message_when_ok_is_falsesrc/connection.rs:1403 | fn | 12 | 1 | 0 | 1 | 0.5 | |
| extras_and_specs_register_expected_connection_kindssrc/connection.rs:1417 | fn | 25 | 3 | 0 | 0 | 0.5 |
Source not readable from this process.