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-truth/src/native_impl/storage_lattice_conduit.rs
Items
macro ingest_row_value struct ConduitJobCore struct ConduitJobState
Functions
By call-graph weight (PageRank; 1.0 is the average function). 56 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| ensure_conduit_tablessrc/native_impl/storage_lattice_conduit.rs:674 | fn | 42 | 1 | 10 | 0 | 3.3 | |
| row_storage_provider_sqlsrc/native_impl/storage_lattice_conduit.rs:85 | fn | 8 | 1 | 1 | 0 | 1 | |
| ensure_lattice_matching_tablessrc/native_impl/storage_lattice_conduit.rs:487 | fn | 12 | 1 | 2 | 0 | 1 | |
| ensure_knowledge_tablessrc/native_impl/storage_lattice_conduit.rs:546 | fn | 19 | 1 | 2 | 0 | 1 | |
| knowledge_ingest_from_sql_rowsrc/native_impl/storage_lattice_conduit.rs:660 | fn | 13 | 1 | 1 | 0 | 1 | |
| row_conduit_event_sqlsrc/native_impl/storage_lattice_conduit.rs:1007 | fn | 3 | 1 | 1 | 0 | 1 | |
| row_domain_metric_snapshot_sqlsrc/native_impl/storage_lattice_conduit.rs:1099 | fn | 9 | 1 | 1 | 0 | 1 | |
| conduit_job_rowsrc/native_impl/storage_lattice_conduit.rs:912 | fn | 15 | 1 | 2 | 0 | 0.8 | |
| conduit_job_core_from_truth_rowsrc/native_impl/storage_lattice_conduit.rs:891 | fn | 10 | 1 | 1 | 1 | 0.7 | |
| conduit_job_state_from_truth_rowsrc/native_impl/storage_lattice_conduit.rs:902 | fn | 9 | 1 | 1 | 3 | 0.7 | |
| row_conduit_jobsrc/native_impl/storage_lattice_conduit.rs:847 | fn | 5 | 1 | 2 | 3 | 0.7 | |
| conduit_job_core_from_sql_rowsrc/native_impl/storage_lattice_conduit.rs:870 | fn | 10 | 1 | 1 | 0 | 0.7 | |
| conduit_job_state_from_sql_rowsrc/native_impl/storage_lattice_conduit.rs:881 | fn | 9 | 1 | 1 | 0 | 0.7 | |
| row_storage_providersrc/native_impl/storage_lattice_conduit.rs:76 | fn | 8 | 1 | 1 | 2 | 0.6 | |
| query_storage_providers_sqlsrc/native_impl/storage_lattice_conduit.rs:94 | fn | 15 | 2 | 1 | 1 | 0.6 | |
| collect_replica_candidates_from_rowssrc/native_impl/storage_lattice_conduit.rs:124 | fn | 18 | 4 | 1 | 1 | 0.6 | |
| query_replica_candidates_sqlsrc/native_impl/storage_lattice_conduit.rs:143 | fn | 24 | 4 | 1 | 0 | 0.6 | |
| conduit_get_job_querysrc/native_impl/storage_lattice_conduit.rs:797 | fn | 16 | 1 | 1 | 2 | 0.6 | |
| row_conduit_job_sqlsrc/native_impl/storage_lattice_conduit.rs:814 | fn | 5 | 1 | 1 | 3 | 0.6 | |
| conduit_jobs_querysrc/native_impl/storage_lattice_conduit.rs:829 | fn | 17 | 1 | 1 | 2 | 0.6 | |
| query_conduit_jobs_sqlsrc/native_impl/storage_lattice_conduit.rs:928 | fn | 29 | 2 | 1 | 0 | 0.6 | |
| lattice_load_latest_result_payload_sqlsrc/native_impl/storage_lattice_conduit.rs:531 | fn | 14 | 2 | 1 | 0 | 0.6 | |
| knowledge_ingests_from_truth_rowssrc/native_impl/storage_lattice_conduit.rs:630 | fn | 7 | 2 | 1 | 0 | 0.6 | |
| knowledge_recent_ingests_sqlsrc/native_impl/storage_lattice_conduit.rs:638 | fn | 15 | 2 | 1 | 1 | 0.6 | |
| row_conduit_eventsrc/native_impl/storage_lattice_conduit.rs:999 | fn | 7 | 1 | 1 | 2 | 0.6 | |
| query_conduit_events_sqlsrc/native_impl/storage_lattice_conduit.rs:1011 | fn | 16 | 2 | 1 | 1 | 0.6 | |
| row_domain_metric_snapshotsrc/native_impl/storage_lattice_conduit.rs:1089 | fn | 9 | 1 | 1 | 2 | 0.6 | |
| query_domain_metric_snapshots_sqlsrc/native_impl/storage_lattice_conduit.rs:1109 | fn | 22 | 2 | 1 | 1 | 0.6 | |
| storage_announce_providersrc/native_impl/storage_lattice_conduit.rs:8 | fn | 19 | 1 | 0 | 0 | 0.5 | |
| storage_upsert_replica_claimsrc/native_impl/storage_lattice_conduit.rs:28 | fn | 21 | 1 | 0 | 0 | 0.5 | |
| storage_provider_countsrc/native_impl/storage_lattice_conduit.rs:50 | fn | 9 | 1 | 0 | 0 | 0.5 | |
| storage_list_providerssrc/native_impl/storage_lattice_conduit.rs:60 | fn | 15 | 2 | 0 | 4 | 0.5 | |
| storage_select_replica_candidatessrc/native_impl/storage_lattice_conduit.rs:110 | fn | 13 | 2 | 0 | 4 | 0.5 | |
| storage_upsert_compute_resultsrc/native_impl/storage_lattice_conduit.rs:168 | fn | 25 | 1 | 0 | 0 | 0.5 | |
| storage_get_compute_result_by_keysrc/native_impl/storage_lattice_conduit.rs:194 | fn | 46 | 4 | 0 | 3 | 0.5 | |
| storage_get_compute_result_by_tuplesrc/native_impl/storage_lattice_conduit.rs:241 | fn | 58 | 4 | 0 | 3 | 0.5 | |
| storage_get_compute_result_by_content_idsrc/native_impl/storage_lattice_conduit.rs:300 | fn | 48 | 4 | 0 | 3 | 0.5 | |
| storage_upsert_manifest_with_chunkssrc/native_impl/storage_lattice_conduit.rs:349 | fn | 49 | 3 | 0 | 0 | 0.5 | |
| storage_get_manifestsrc/native_impl/storage_lattice_conduit.rs:399 | fn | 36 | 4 | 0 | 3 | 0.5 | |
| storage_list_manifest_chunkssrc/native_impl/storage_lattice_conduit.rs:436 | fn | 27 | 2 | 0 | 0 | 0.5 | |
| storage_status_countssrc/native_impl/storage_lattice_conduit.rs:464 | fn | 11 | 1 | 0 | 0 | 0.5 | |
| storage_truth_countssrc/native_impl/storage_lattice_conduit.rs:476 | fn | 10 | 1 | 0 | 0 | 0.5 | |
| lattice_upsert_resultsrc/native_impl/storage_lattice_conduit.rs:500 | fn | 15 | 1 | 0 | 1 | 0.5 | |
| lattice_load_latest_result_payloadsrc/native_impl/storage_lattice_conduit.rs:516 | fn | 14 | 2 | 0 | 6 | 0.5 | |
| knowledge_record_ingestsrc/native_impl/storage_lattice_conduit.rs:566 | fn | 41 | 1 | 0 | 1 | 0.5 | |
| knowledge_recent_ingestssrc/native_impl/storage_lattice_conduit.rs:608 | fn | 21 | 2 | 0 | 6 | 0.5 | |
| conduit_upsert_jobsrc/native_impl/storage_lattice_conduit.rs:717 | fn | 33 | 1 | 0 | 1 | 0.5 | |
| conduit_update_job_statesrc/native_impl/storage_lattice_conduit.rs:751 | fn | 23 | 1 | 0 | 1 | 0.5 | |
| conduit_get_jobsrc/native_impl/storage_lattice_conduit.rs:775 | fn | 21 | 4 | 0 | 5 | 0.5 | |
| conduit_list_jobssrc/native_impl/storage_lattice_conduit.rs:820 | fn | 8 | 2 | 0 | 5 | 0.5 | |
| conduit_count_jobssrc/native_impl/storage_lattice_conduit.rs:958 | fn | 6 | 1 | 0 | 1 | 0.5 | |
| conduit_append_eventsrc/native_impl/storage_lattice_conduit.rs:965 | fn | 16 | 1 | 0 | 1 | 0.5 | |
| conduit_list_eventssrc/native_impl/storage_lattice_conduit.rs:982 | fn | 16 | 2 | 0 | 6 | 0.5 | |
| conduit_status_countssrc/native_impl/storage_lattice_conduit.rs:1028 | fn | 14 | 1 | 0 | 1 | 0.5 | |
| conduit_upsert_domain_metric_snapshotsrc/native_impl/storage_lattice_conduit.rs:1043 | fn | 17 | 1 | 0 | 1 | 0.5 | |
| conduit_list_domain_metric_snapshotssrc/native_impl/storage_lattice_conduit.rs:1061 | fn | 27 | 2 | 0 | 6 | 0.5 |
Source not readable from this process.