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-conduit/src/connection/live_restore_runner.rs
Items
const MAX_LIVE_RESTORE_JSON_BYTES const MAX_LIVE_RESTORE_JSONL_BYTES const MAX_LIVE_RESTORE_JSONL_LINE_BYTES struct LiveRestoreRunnerBridge impl LiveRestoreRunnerBridge enum JsonlRead struct LiveRestoreRunnerLaunch
Functions
By call-graph weight (PageRank; 1.0 is the average function). 66 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| live_restore_runner_pathsrc/connection/live_restore_runner.rs:182 | fn | 3 | 1 | 11 | 2 | 4.9 | |
| live_restore_runner_specsrc/connection/live_restore_runner.rs:83 | fn | 5 | 1 | 5 | 0 | 3.6 | |
| live_restore_path_from_rawsrc/connection/live_restore_runner.rs:161 | fn | 16 | 5 | 3 | 1 | 3.4 | |
| live_restore_runner_stringsrc/connection/live_restore_runner.rs:89 | fn | 3 | 1 | 2 | 2 | 2.8 | |
| live_stream_tokensrc/connection/live_restore_runner.rs:934 | fn | 9 | 5 | 3 | 0 | 2.5 | |
| live_restore_runner_responsesrc/connection/live_restore_runner.rs:279 | fn | 23 | 1 | 5 | 0 | 1.8 | |
| live_restore_value_boolsrc/connection/live_restore_runner.rs:93 | fn | 14 | 3 | 2 | 0 | 1.8 | |
| live_restore_value_f64src/connection/live_restore_runner.rs:132 | fn | 8 | 1 | 3 | 2 | 1.8 | |
| live_restore_value_u64src/connection/live_restore_runner.rs:118 | fn | 3 | 1 | 2 | 1 | 1.5 | |
| LiveRestoreRunnerBridge::unusedsrc/connection/live_restore_runner.rs:53 | method | 24 | 1 | 6 | 0 | 1.5 | |
| validate_live_restore_jsonl_limitssrc/connection/live_restore_runner.rs:251 | fn | 23 | 3 | 1 | 0 | 1.4 | |
| default_live_restore_runner_output_root_fromsrc/connection/live_restore_runner.rs:619 | fn | 3 | 1 | 2 | 1 | 1.4 | |
| live_restore_runner_u64src/connection/live_restore_runner.rs:122 | fn | 9 | 3 | 3 | 2 | 1.3 | |
| live_restore_probe_audio_chunk_atsrc/connection/live_restore_runner.rs:1055 | fn | 31 | 3 | 2 | 1 | 1.2 | |
| read_live_restore_jsonl_valuesrc/connection/live_restore_runner.rs:226 | fn | 24 | 3 | 1 | 1 | 1.1 | |
| resolve_live_restore_runner_input_pathsrc/connection/live_restore_runner.rs:567 | fn | 5 | 1 | 2 | 1 | 1.1 | |
| live_restore_runner_boolsrc/connection/live_restore_runner.rs:108 | fn | 9 | 3 | 2 | 2 | 1 | |
| resolve_live_stream_idssrc/connection/live_restore_runner.rs:944 | fn | 31 | 1 | 2 | 2 | 0.9 | |
| resolve_live_corpus_sourcessrc/connection/live_restore_runner.rs:976 | fn | 71 | 13 | 2 | 4 | 0.9 | |
| live_restore_runner_f64src/connection/live_restore_runner.rs:141 | fn | 9 | 3 | 2 | 2 | 0.9 | |
| read_live_restore_jsonsrc/connection/live_restore_runner.rs:186 | fn | 5 | 1 | 3 | 1 | 0.8 | |
| live_restore_path_in_valuesrc/connection/live_restore_runner.rs:178 | fn | 3 | 1 | 2 | 1 | 0.7 | |
| live_restore_runner_command_summarysrc/connection/live_restore_runner.rs:595 | fn | 23 | 1 | 2 | 0 | 0.7 | |
| prepare_live_restore_runner_launchsrc/connection/live_restore_runner.rs:630 | fn | 78 | 2 | 2 | 6 | 0.7 | |
| read_live_restore_jsonlsrc/connection/live_restore_runner.rs:192 | fn | 27 | 5 | 3 | 1 | 0.7 | |
| live_restore_runner_valuesrc/connection/live_restore_runner.rs:151 | fn | 9 | 3 | 1 | 1 | 0.7 | |
| find_default_cre8conduit_rootsrc/connection/live_restore_runner.rs:540 | fn | 17 | 5 | 1 | 1 | 0.7 | |
| LiveRestoreRunnerBridge::failedsrc/connection/live_restore_runner.rs:78 | method | 3 | 1 | 3 | 1 | 0.7 | |
| live_restore_runner_hyperdb_configsrc/connection/live_restore_runner.rs:740 | fn | 17 | 5 | 1 | 3 | 0.7 | |
| preview_paths_from_manifestsrc/connection/live_restore_runner.rs:399 | fn | 14 | 1 | 3 | 3 | 0.7 | |
| load_live_restore_runner_reportsrc/connection/live_restore_runner.rs:414 | fn | 78 | 1 | 3 | 9 | 0.6 | |
| resolve_cre8conduit_rootsrc/connection/live_restore_runner.rs:558 | fn | 8 | 1 | 2 | 3 | 0.6 | |
| unique_temp_filesrc/connection/live_restore_runner.rs:1396 | fn | 12 | 1 | 1 | 0 | 0.6 | |
| live_restore_runner_commandsrc/connection/live_restore_runner.rs:758 | fn | 11 | 2 | 2 | 0 | 0.6 | |
| resolve_live_restore_runnersrc/connection/live_restore_runner.rs:906 | fn | 27 | 5 | 2 | 8 | 0.6 | |
| live_restore_preview_manifest_path_from_specsrc/connection/live_restore_runner.rs:345 | fn | 13 | 1 | 2 | 1 | 0.6 | |
| live_restore_preview_mjpeg_path_from_specsrc/connection/live_restore_runner.rs:359 | fn | 13 | 1 | 2 | 1 | 0.6 | |
| live_restore_preview_audio_dir_from_specsrc/connection/live_restore_runner.rs:373 | fn | 13 | 1 | 2 | 1 | 0.6 | |
| default_live_restore_runner_output_rootsrc/connection/live_restore_runner.rs:623 | fn | 6 | 1 | 1 | 1 | 0.6 | |
| live_restore_runner_corpus_inputssrc/connection/live_restore_runner.rs:709 | fn | 11 | 2 | 1 | 1 | 0.6 | |
| apply_live_restore_runner_job_optionssrc/connection/live_restore_runner.rs:721 | fn | 18 | 6 | 1 | 3 | 0.6 | |
| live_restore_tail_stream_path_from_specsrc/connection/live_restore_runner.rs:832 | fn | 13 | 1 | 1 | 1 | 0.6 | |
| load_live_restore_runner_pathssrc/connection/live_restore_runner.rs:493 | fn | 46 | 3 | 1 | 13 | 0.6 | |
| invoke_live_restore_runnersrc/connection/live_restore_runner.rs:770 | fn | 56 | 5 | 1 | 6 | 0.6 | |
| live_restore_runner_async_enabledsrc/connection/live_restore_runner.rs:827 | fn | 4 | 1 | 1 | 1 | 0.6 | |
| pending_live_restore_runner_commandsrc/connection/live_restore_runner.rs:846 | fn | 26 | 1 | 1 | 3 | 0.6 | |
| pending_live_restore_tail_bridgesrc/connection/live_restore_runner.rs:873 | fn | 32 | 1 | 1 | 7 | 0.6 | |
| live_restore_probe_audio_chunksrc/connection/live_restore_runner.rs:1048 | fn | 6 | 1 | 1 | 1 | 0.6 | |
| start_live_restore_runner_asyncsrc/connection/live_restore_runner.rs:1211 | fn | 180 | 6 | 1 | 9 | 0.6 | |
| default_preview_manifest_pathsrc/connection/live_restore_runner.rs:387 | fn | 3 | 1 | 1 | 0 | 0.6 | |
| default_preview_mjpeg_pathsrc/connection/live_restore_runner.rs:391 | fn | 3 | 1 | 1 | 0 | 0.6 | |
| default_preview_audio_dirsrc/connection/live_restore_runner.rs:395 | fn | 3 | 1 | 1 | 0 | 0.6 | |
| finalize_live_restore_runner_asyncsrc/connection/live_restore_runner.rs:1087 | fn | 123 | 9 | 1 | 12 | 0.5 | |
| live_restore_report_path_from_specsrc/connection/live_restore_runner.rs:303 | fn | 13 | 1 | 1 | 1 | 0.5 | |
| live_restore_script_path_from_specsrc/connection/live_restore_runner.rs:317 | fn | 13 | 1 | 1 | 1 | 0.5 | |
| live_restore_restore_stream_path_from_specsrc/connection/live_restore_runner.rs:331 | fn | 6 | 1 | 1 | 1 | 0.5 | |
| live_restore_restore_report_path_from_specsrc/connection/live_restore_runner.rs:338 | fn | 6 | 1 | 1 | 1 | 0.5 | |
| path_to_jsonsrc/connection/live_restore_runner.rs:275 | fn | 3 | 1 | 0 | 0 | 0.5 | |
| truncate_runner_outputsrc/connection/live_restore_runner.rs:573 | fn | 7 | 2 | 0 | 0 | 0.5 | |
| live_restore_value_f64_rejects_non_finite_valuessrc/connection/live_restore_runner.rs:1410 | fn | 11 | 1 | 0 | 1 | 0.5 | |
| default_runner_output_root_lives_under_data_output_conduitsrc/connection/live_restore_runner.rs:1423 | fn | 8 | 1 | 0 | 1 | 0.5 | |
| runner_output_root_accepts_top_level_and_nested_aliasessrc/connection/live_restore_runner.rs:1433 | fn | 22 | 1 | 0 | 1 | 0.5 | |
| live_stream_token_filters_normalizes_and_falls_backsrc/connection/live_restore_runner.rs:1457 | fn | 9 | 1 | 0 | 1 | 0.5 | |
| resolve_live_stream_ids_prefers_input_aliases_then_spec_then_defaultssrc/connection/live_restore_runner.rs:1468 | fn | 31 | 1 | 0 | 1 | 0.5 | |
| resolve_live_corpus_sources_collects_aliases_and_dedupes_targetsrc/connection/live_restore_runner.rs:1501 | fn | 45 | 1 | 0 | 1 | 0.5 | |
| read_live_restore_jsonl_enforces_limits_and_reports_parse_errorssrc/connection/live_restore_runner.rs:1548 | fn | 24 | 1 | 0 | 3 | 0.5 |
Source not readable from this process.