1 viewer
rust 1,860,881 · typescript 235,770 · javascript 132,961 · python 20,426 · 6,411 files · digest 3bf1ccedeeb3 · built in 2 s · crystals off
crates/cre8-app-truth/src/native_impl/matching_model_protocol.rs
Items
const PATH_CACHE_SUMMARY_TABLE static ENSURED const PATH_CACHE_SUMMARY_BACKFILL_ROWS const MATCHING_ROUND_RETENTION_ENV const MATCHING_ROUND_RETENTION_DEFAULT const MATCHING_ROUND_RETENTION_FLOOR const MATCHING_ROUND_PRUNE_BATCH const PATH_CACHE_RECENT_ORDER struct ProjectedRound const PATH_CACHE_PROJECTION_COLUMNS macro cert_row_value struct CertificateSqlRow impl CertificateSqlRow
Functions
By call-graph weight (PageRank; 1.0 is the average function). 97 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| ensure_matching_tablessrc/native_impl/matching_model_protocol.rs:24 | fn | 81 | 2 | 22 | 4 | 4.7 | |
| roundsrc/native_impl/matching_model_protocol.rs:2195 | fn | 13 | 1 | 14 | 0 | 3.4 | |
| projected_round_from_rowsrc/native_impl/matching_model_protocol.rs:1031 | fn | 28 | 3 | 2 | 0 | 1.8 | |
| certificate_from_jsonsrc/native_impl/matching_model_protocol.rs:1879 | fn | 3 | 1 | 2 | 0 | 1.8 | |
| backfill_path_cache_summariessrc/native_impl/matching_model_protocol.rs:266 | fn | 21 | 3 | 1 | 0 | 1.5 | |
| backfill_legacy_position_intent_epochssrc/native_impl/matching_model_protocol.rs:414 | fn | 34 | 4 | 1 | 3 | 1.5 | |
| epoch_state_labelsrc/native_impl/matching_model_protocol.rs:361 | fn | 6 | 2 | 1 | 0 | 1.4 | |
| matching_upsert_path_cachesrc/native_impl/matching_model_protocol.rs:634 | fn | 30 | 1 | 6 | 3 | 1.3 | |
| bridge_first_or_durablesrc/native_impl/matching_model_protocol.rs:320 | fn | 12 | 3 | 7 | 0 | 1.1 | |
| collect_certificate_rowssrc/native_impl/matching_model_protocol.rs:1813 | fn | 9 | 2 | 2 | 0 | 1.1 | |
| certificate_from_sql_rowsrc/native_impl/matching_model_protocol.rs:1860 | fn | 3 | 1 | 2 | 2 | 1.1 | |
| matching_load_recent_round_summariessrc/native_impl/matching_model_protocol.rs:871 | fn | 34 | 5 | 6 | 8 | 1.1 | |
| insert_position_intent_epochsrc/native_impl/matching_model_protocol.rs:368 | fn | 23 | 2 | 3 | 1 | 1.1 | |
| payload_records_from_truth_rowssrc/native_impl/matching_model_protocol.rs:333 | fn | 13 | 3 | 6 | 1 | 1.1 | |
| persist_projected_windowsrc/native_impl/matching_model_protocol.rs:1083 | fn | 17 | 2 | 2 | 0 | 1 | |
| certificate_from_truth_rowsrc/native_impl/matching_model_protocol.rs:1770 | fn | 16 | 1 | 1 | 2 | 1 | |
| prune_round_payloadssrc/native_impl/matching_model_protocol.rs:174 | fn | 9 | 1 | 2 | 3 | 1 | |
| CertificateSqlRow::into_jsonsrc/native_impl/matching_model_protocol.rs:1843 | method | 15 | 1 | 1 | 1 | 1 | |
| certificate_sql_rowsrc/native_impl/matching_model_protocol.rs:1864 | fn | 14 | 1 | 1 | 0 | 1 | |
| positionsrc/native_impl/matching_model_protocol.rs:2072 | fn | 8 | 1 | 5 | 0 | 1 | |
| matching_load_recent_expr_selectionssrc/native_impl/matching_model_protocol.rs:1108 | fn | 31 | 5 | 4 | 8 | 0.9 | |
| matching_upsert_position_intentsrc/native_impl/matching_model_protocol.rs:477 | fn | 36 | 5 | 2 | 6 | 0.9 | |
| read_path_cache_windowsrc/native_impl/matching_model_protocol.rs:1060 | fn | 13 | 1 | 1 | 1 | 0.8 | |
| matching_round_retentionsrc/native_impl/matching_model_protocol.rs:155 | fn | 7 | 1 | 1 | 1 | 0.8 | |
| prune_path_cache_bodiessrc/native_impl/matching_model_protocol.rs:197 | fn | 11 | 3 | 1 | 3 | 0.8 | |
| prune_payload_tablesrc/native_impl/matching_model_protocol.rs:235 | fn | 17 | 2 | 1 | 0 | 0.8 | |
| certificates_from_sql_for_hashsrc/native_impl/matching_model_protocol.rs:1795 | fn | 8 | 1 | 1 | 2 | 0.8 | |
| certificates_from_sql_allsrc/native_impl/matching_model_protocol.rs:1804 | fn | 8 | 1 | 1 | 2 | 0.8 | |
| surplus_path_cache_keyssrc/native_impl/matching_model_protocol.rs:217 | fn | 14 | 2 | 1 | 0 | 0.7 | |
| read_path_cache_roundsrc/native_impl/matching_model_protocol.rs:1076 | fn | 6 | 1 | 1 | 1 | 0.7 | |
| path_cache_window_lensrc/native_impl/matching_model_protocol.rs:952 | fn | 5 | 1 | 2 | 0 | 0.7 | |
| project_path_cache_windowsrc/native_impl/matching_model_protocol.rs:1002 | fn | 8 | 2 | 2 | 2 | 0.7 | |
| matching_upsert_positionsrc/native_impl/matching_model_protocol.rs:514 | fn | 12 | 1 | 2 | 2 | 0.7 | |
| latest_position_intent_epochsrc/native_impl/matching_model_protocol.rs:392 | fn | 21 | 2 | 2 | 1 | 0.7 | |
| temp_truthsrc/native_impl/matching_model_protocol.rs:1993 | fn | 5 | 1 | 2 | 2 | 0.7 | |
| epoch_countsrc/native_impl/matching_model_protocol.rs:1999 | fn | 11 | 1 | 2 | 0 | 0.7 | |
| matching_positions_from_sqlsrc/native_impl/matching_model_protocol.rs:347 | fn | 13 | 3 | 2 | 0 | 0.7 | |
| matching_load_position_intent_epochssrc/native_impl/matching_model_protocol.rs:449 | fn | 27 | 4 | 2 | 2 | 0.6 | |
| matching_load_positionssrc/native_impl/matching_model_protocol.rs:288 | fn | 14 | 1 | 1 | 6 | 0.6 | |
| matching_load_path_cache_for_revisionsrc/native_impl/matching_model_protocol.rs:823 | fn | 19 | 1 | 1 | 7 | 0.6 | |
| matching_recent_round_summaries_from_sidecar_tablesrc/native_impl/matching_model_protocol.rs:913 | fn | 33 | 4 | 1 | 0 | 0.6 | |
| round_summaries_from_sidecar_rowssrc/native_impl/matching_model_protocol.rs:961 | fn | 14 | 3 | 1 | 0 | 0.6 | |
| matching_persist_resultsrc/native_impl/matching_model_protocol.rs:617 | fn | 16 | 1 | 1 | 1 | 0.6 | |
| certificate_querysrc/native_impl/matching_model_protocol.rs:1743 | fn | 18 | 2 | 1 | 1 | 0.6 | |
| certificates_from_truth_rowssrc/native_impl/matching_model_protocol.rs:1762 | fn | 7 | 2 | 1 | 1 | 0.6 | |
| certificates_from_sqlsrc/native_impl/matching_model_protocol.rs:1787 | fn | 7 | 2 | 1 | 2 | 0.6 | |
| matching_recent_expr_selections_from_sidecar_tablesrc/native_impl/matching_model_protocol.rs:1142 | fn | 30 | 3 | 1 | 0 | 0.6 | |
| round_selections_from_sidecar_rowssrc/native_impl/matching_model_protocol.rs:1174 | fn | 12 | 2 | 1 | 0 | 0.6 | |
| matching_path_cache_for_revision_from_sqlsrc/native_impl/matching_model_protocol.rs:843 | fn | 18 | 3 | 1 | 0 | 0.6 | |
| matching_apply_settlement_plansrc/native_impl/matching_model_protocol.rs:527 | fn | 89 | 10 | 1 | 6 | 0.6 | |
| matching_expired_position_ids_from_sqlsrc/native_impl/matching_model_protocol.rs:1211 | fn | 15 | 2 | 1 | 0 | 0.6 | |
| matching_recent_transactions_from_sqlsrc/native_impl/matching_model_protocol.rs:745 | fn | 18 | 3 | 1 | 0 | 0.6 | |
| matching_recent_path_cache_from_sqlsrc/native_impl/matching_model_protocol.rs:795 | fn | 17 | 3 | 1 | 0 | 0.6 | |
| matching_persist_transactionssrc/native_impl/matching_model_protocol.rs:665 | fn | 24 | 2 | 0 | 1 | 0.5 | |
| matching_load_recent_transactionssrc/native_impl/matching_model_protocol.rs:690 | fn | 22 | 1 | 0 | 7 | 0.5 | |
| matching_load_transactions_stampedsrc/native_impl/matching_model_protocol.rs:719 | fn | 25 | 3 | 0 | 1 | 0.5 | |
| matching_load_recent_path_cachesrc/native_impl/matching_model_protocol.rs:764 | fn | 18 | 1 | 0 | 7 | 0.5 | |
| matching_load_expired_position_idssrc/native_impl/matching_model_protocol.rs:1187 | fn | 23 | 2 | 0 | 6 | 0.5 | |
| matching_mark_positions_consumedsrc/native_impl/matching_model_protocol.rs:1227 | fn | 11 | 3 | 0 | 1 | 0.5 | |
| matching_latest_position_revisionsrc/native_impl/matching_model_protocol.rs:1239 | fn | 9 | 1 | 0 | 1 | 0.5 | |
| model_upsert_adaptersrc/native_impl/matching_model_protocol.rs:1249 | fn | 32 | 1 | 0 | 0 | 0.5 | |
| model_get_adaptersrc/native_impl/matching_model_protocol.rs:1282 | fn | 36 | 3 | 0 | 0 | 0.5 | |
| model_list_adapterssrc/native_impl/matching_model_protocol.rs:1319 | fn | 35 | 2 | 0 | 0 | 0.5 | |
| model_upsert_modelsrc/native_impl/matching_model_protocol.rs:1355 | fn | 47 | 1 | 0 | 0 | 0.5 | |
| model_get_modelsrc/native_impl/matching_model_protocol.rs:1403 | fn | 42 | 3 | 0 | 0 | 0.5 | |
| model_list_modelssrc/native_impl/matching_model_protocol.rs:1446 | fn | 45 | 2 | 0 | 0 | 0.5 | |
| model_append_ingestsrc/native_impl/matching_model_protocol.rs:1492 | fn | 30 | 1 | 0 | 0 | 0.5 | |
| model_list_ingests_for_modelsrc/native_impl/matching_model_protocol.rs:1523 | fn | 38 | 2 | 0 | 0 | 0.5 | |
| model_count_adapterssrc/native_impl/matching_model_protocol.rs:1562 | fn | 5 | 1 | 0 | 0 | 0.5 | |
| model_count_modelssrc/native_impl/matching_model_protocol.rs:1568 | fn | 5 | 1 | 0 | 0 | 0.5 | |
| model_count_ingestssrc/native_impl/matching_model_protocol.rs:1574 | fn | 5 | 1 | 0 | 0 | 0.5 | |
| protocol_upsert_protocolsrc/native_impl/matching_model_protocol.rs:1580 | fn | 24 | 1 | 0 | 0 | 0.5 | |
| protocol_upsert_app_manifestsrc/native_impl/matching_model_protocol.rs:1605 | fn | 21 | 1 | 0 | 0 | 0.5 | |
| protocol_upsert_connectionsrc/native_impl/matching_model_protocol.rs:1627 | fn | 20 | 1 | 0 | 0 | 0.5 | |
| protocol_list_descriptor_jsonssrc/native_impl/matching_model_protocol.rs:1648 | fn | 20 | 4 | 0 | 3 | 0.5 | |
| protocol_list_app_manifest_jsonssrc/native_impl/matching_model_protocol.rs:1669 | fn | 23 | 4 | 0 | 3 | 0.5 | |
| protocol_store_certificatesrc/native_impl/matching_model_protocol.rs:1693 | fn | 40 | 1 | 0 | 0 | 0.5 | |
| protocol_load_certificatessrc/native_impl/matching_model_protocol.rs:1734 | fn | 8 | 2 | 0 | 4 | 0.5 | |
| protocol_store_sourcesrc/native_impl/matching_model_protocol.rs:1883 | fn | 22 | 1 | 0 | 0 | 0.5 | |
| protocol_load_sourcesrc/native_impl/matching_model_protocol.rs:1906 | fn | 44 | 4 | 0 | 3 | 0.5 | |
| protocol_latest_ir_hash_for_protocolsrc/native_impl/matching_model_protocol.rs:1951 | fn | 27 | 4 | 0 | 4 | 0.5 | |
| protocol_catalog_countssrc/native_impl/matching_model_protocol.rs:1979 | fn | 7 | 1 | 0 | 0 | 0.5 | |
| second_matching_ensure_on_one_database_runs_no_backfill_scansrc/native_impl/matching_model_protocol.rs:2017 | fn | 17 | 1 | 0 | 4 | 0.5 | |
| fresh_matching_database_still_backfills_a_raw_legacy_position_rowsrc/native_impl/matching_model_protocol.rs:2039 | fn | 27 | 1 | 0 | 5 | 0.5 | |
| bridge_first_or_durable_prefers_nonempty_bridge_rowssrc/native_impl/matching_model_protocol.rs:2084 | fn | 13 | 1 | 0 | 2 | 0.5 | |
| empty_bridge_falls_through_to_durable_position_runtimesrc/native_impl/matching_model_protocol.rs:2105 | fn | 23 | 1 | 0 | 6 | 0.5 | |
| matching_load_positions_returns_seeded_rowssrc/native_impl/matching_model_protocol.rs:2132 | fn | 10 | 1 | 0 | 3 | 0.5 | |
| intent_epoch_projection_is_residual_aware_cas_guarded_and_replayablesrc/native_impl/matching_model_protocol.rs:2144 | fn | 50 | 1 | 0 | 6 | 0.5 | |
| round_sidecars_serve_summaries_and_selections_without_the_payloadsrc/native_impl/matching_model_protocol.rs:2213 | fn | 20 | 1 | 0 | 4 | 0.5 | |
| pre_migration_rounds_fall_back_to_payload_extractionsrc/native_impl/matching_model_protocol.rs:2238 | fn | 24 | 1 | 0 | 4 | 0.5 | |
| upsert_projects_the_round_into_the_summary_tablesrc/native_impl/matching_model_protocol.rs:2268 | fn | 26 | 1 | 0 | 2 | 0.5 | |
| legacy_rows_backfill_into_the_summary_tablesrc/native_impl/matching_model_protocol.rs:2299 | fn | 27 | 1 | 0 | 4 | 0.5 | |
| partly_projected_window_falls_back_instead_of_truncatingsrc/native_impl/matching_model_protocol.rs:2331 | fn | 27 | 1 | 0 | 4 | 0.5 | |
| a_window_wider_than_the_backfill_projects_itself_on_first_readsrc/native_impl/matching_model_protocol.rs:2363 | fn | 38 | 2 | 0 | 4 | 0.5 | |
| retention_prunes_round_bodies_and_keeps_their_projectionssrc/native_impl/matching_model_protocol.rs:2406 | fn | 29 | 2 | 0 | 4 | 0.5 | |
| retention_projects_a_round_before_it_frees_itsrc/native_impl/matching_model_protocol.rs:2441 | fn | 43 | 3 | 0 | 3 | 0.5 | |
| path_cache_for_revision_returns_only_that_revisions_roundssrc/native_impl/matching_model_protocol.rs:2488 | fn | 13 | 2 | 0 | 3 | 0.5 |
Source not readable from this process.