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/connection.rs
Items
const SPECS enum ProviderAction const PROVIDER_ACTION_ALIASES enum SyncSourceMode impl SyncSourceMode const SYNC_SOURCE_MODE_ALIASES struct ProviderConnectionInput type DataActionHandler type StreamActionHandler const DATA_ACTION_HANDLERS const STREAM_ACTION_HANDLERS struct SyncSourceResolution const IMPORT_BATCH_RECORDS struct FakeProvider impl ExternalDataProvider for FakeProvider struct EnvRestore impl EnvRestore impl Drop for EnvRestore
Functions
By call-graph weight (PageRank; 1.0 is the average function). 66 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| connectsrc/connection.rs:495 | fn | 59 | 15 | 8 | 17 | 3.7 | |
| recordsrc/connection.rs:1412 | fn | 3 | 1 | 3 | 0 | 1.8 | |
| lookup_provider_actionsrc/connection.rs:403 | fn | 5 | 1 | 2 | 0 | 1.3 | |
| requiresrc/connection.rs:409 | fn | 9 | 2 | 3 | 0 | 1.2 | |
| sync_fetch_requestsrc/connection.rs:984 | fn | 9 | 1 | 2 | 0 | 1 | |
| resolve_sync_sourcesrc/connection.rs:994 | fn | 13 | 3 | 2 | 3 | 1 | |
| handle_catalogsrc/connection.rs:699 | fn | 28 | 2 | 1 | 2 | 0.9 | |
| handle_statussrc/connection.rs:728 | fn | 17 | 2 | 1 | 3 | 0.9 | |
| handle_runssrc/connection.rs:746 | fn | 9 | 1 | 1 | 1 | 0.9 | |
| handle_socket_samplesrc/connection.rs:756 | fn | 27 | 1 | 1 | 1 | 0.9 | |
| handle_stream_startsrc/connection.rs:784 | fn | 28 | 1 | 1 | 2 | 0.9 | |
| handle_stream_stopsrc/connection.rs:813 | fn | 20 | 1 | 1 | 1 | 0.9 | |
| handle_stream_statussrc/connection.rs:834 | fn | 24 | 2 | 1 | 2 | 0.9 | |
| handle_stream_sinkssrc/connection.rs:859 | fn | 9 | 1 | 1 | 0 | 0.9 | |
| handle_syncsrc/connection.rs:1059 | fn | 6 | 1 | 1 | 3 | 0.9 | |
| handle_resultsrc/connection.rs:1387 | fn | 9 | 1 | 1 | 0 | 0.9 | |
| stream_sink_idssrc/connection.rs:442 | fn | 10 | 3 | 1 | 0 | 0.9 | |
| explicit_source_modesrc/connection.rs:431 | fn | 5 | 1 | 2 | 0 | 0.9 | |
| handle_sync_with_providersrc/connection.rs:1066 | fn | 107 | 9 | 2 | 11 | 0.9 | |
| parse_actionsrc/connection.rs:392 | fn | 10 | 2 | 2 | 1 | 0.8 | |
| handle_data_actionsrc/connection.rs:555 | fn | 11 | 1 | 2 | 1 | 0.8 | |
| handle_stream_actionsrc/connection.rs:567 | fn | 6 | 1 | 2 | 1 | 0.8 | |
| has_inline_provider_payloadsrc/connection.rs:437 | fn | 3 | 2 | 1 | 0 | 0.8 | |
| resolve_payload_sync_sourcesrc/connection.rs:1008 | fn | 17 | 2 | 1 | 0 | 0.8 | |
| resolve_live_sync_sourcesrc/connection.rs:1026 | fn | 19 | 1 | 1 | 0 | 0.8 | |
| resolve_seed_sync_sourcesrc/connection.rs:1046 | fn | 12 | 1 | 1 | 0 | 0.8 | |
| normalize_recordsrc/connection.rs:453 | fn | 24 | 1 | 3 | 0 | 0.7 | |
| handle_poll_startsrc/connection.rs:869 | fn | 50 | 4 | 1 | 3 | 0.7 | |
| handle_poll_stopsrc/connection.rs:920 | fn | 20 | 1 | 1 | 1 | 0.7 | |
| handle_poll_statussrc/connection.rs:941 | fn | 35 | 1 | 1 | 1 | 0.7 | |
| parse_connection_inputsrc/connection.rs:488 | fn | 6 | 2 | 1 | 0 | 0.7 | |
| handle_poll_actionsrc/connection.rs:690 | fn | 8 | 4 | 1 | 3 | 0.7 | |
| parse_source_modesrc/connection.rs:419 | fn | 11 | 4 | 2 | 2 | 0.7 | |
| sync_payloadsrc/connection.rs:1341 | fn | 3 | 2 | 2 | 0 | 0.6 | |
| import_records_batchedsrc/connection.rs:1307 | fn | 33 | 4 | 2 | 1 | 0.6 | |
| handle_source_mission_syncsrc/connection.rs:1175 | fn | 113 | 4 | 1 | 7 | 0.6 | |
| sync_datasetsrc/connection.rs:1345 | fn | 9 | 1 | 1 | 0 | 0.6 | |
| sync_dry_run_responsesrc/connection.rs:1355 | fn | 31 | 2 | 1 | 0 | 0.6 | |
| EnvRestore::setsrc/connection.rs:1593 | method | 7 | 1 | 1 | 0 | 0.5 | |
| external_history_contextsrc/connection.rs:1616 | fn | 19 | 1 | 1 | 4 | 0.5 | |
| register_wikipedia_source_policysrc/connection.rs:1636 | fn | 41 | 1 | 1 | 0 | 0.5 | |
| authorize_wikipedia_source_missionsrc/connection.rs:1678 | fn | 37 | 1 | 1 | 0 | 0.5 | |
| submit_wikipedia_source_missionsrc/connection.rs:1716 | fn | 17 | 1 | 1 | 0 | 0.5 | |
| SyncSourceMode::as_strsrc/connection.rs:309 | method | 7 | 3 | 0 | 0 | 0.5 | |
| catalog_data_actionsrc/connection.rs:595 | fn | 3 | 1 | 0 | 1 | 0.5 | |
| status_data_actionsrc/connection.rs:599 | fn | 3 | 1 | 0 | 1 | 0.5 | |
| runs_data_actionsrc/connection.rs:603 | fn | 3 | 1 | 0 | 1 | 0.5 | |
| sync_data_actionsrc/connection.rs:607 | fn | 3 | 1 | 0 | 1 | 0.5 | |
| result_data_actionsrc/connection.rs:611 | fn | 3 | 1 | 0 | 1 | 0.5 | |
| backfill_bars_data_actionsrc/connection.rs:615 | fn | 17 | 1 | 0 | 1 | 0.5 | |
| bars_data_actionsrc/connection.rs:635 | fn | 34 | 4 | 0 | 2 | 0.5 | |
| socket_sample_stream_actionsrc/connection.rs:670 | fn | 3 | 1 | 0 | 1 | 0.5 | |
| stream_start_actionsrc/connection.rs:674 | fn | 3 | 1 | 0 | 1 | 0.5 | |
| stream_stop_actionsrc/connection.rs:678 | fn | 3 | 1 | 0 | 1 | 0.5 | |
| stream_status_actionsrc/connection.rs:682 | fn | 3 | 1 | 0 | 1 | 0.5 | |
| stream_sinks_actionsrc/connection.rs:686 | fn | 3 | 1 | 0 | 1 | 0.5 | |
| FakeProvider::descriptorsrc/connection.rs:1417 | trait impl | 10 | 1 | 0 | 0 | 0.5 | |
| FakeProvider::seed_recordssrc/connection.rs:1428 | trait impl | 3 | 1 | 0 | 1 | 0.5 | |
| FakeProvider::normalize_payloadsrc/connection.rs:1432 | trait impl | 3 | 1 | 0 | 1 | 0.5 | |
| FakeProvider::fetch_livesrc/connection.rs:1436 | trait impl | 11 | 1 | 0 | 1 | 0.5 | |
| action_and_source_mode_helpers_cover_aliases_and_defaultssrc/connection.rs:1450 | fn | 37 | 1 | 0 | 4 | 0.5 | |
| sync_fetch_request_trims_cursor_query_and_clamps_pagessrc/connection.rs:1489 | fn | 31 | 1 | 0 | 1 | 0.5 | |
| resolve_sync_source_handles_payload_seed_live_and_empty_payload_errorsrc/connection.rs:1522 | fn | 29 | 1 | 0 | 1 | 0.5 | |
| dispatchers_cover_result_stream_sinks_and_sync_dry_runsrc/connection.rs:1553 | fn | 33 | 1 | 0 | 4 | 0.5 | |
| EnvRestore::dropsrc/connection.rs:1603 | trait impl | 11 | 2 | 0 | 0 | 0.5 | |
| wikipedia_history_admission_is_verified_idempotent_and_restart_safesrc/connection.rs:1735 | fn | 160 | 2 | 0 | 8 | 0.5 |
Source not readable from this process.