Skip to content
1 viewer

rust 1,859,989 · typescript 235,537 · javascript 132,952 · python 20,426 · 6,407 files · digest 4f42637fac12 · built in 1.2 s · crystals off

crates/cre8-app-protocol/src/graph_store.rs

cre8-app-protocol · module graph_store · src · 5,945 lines (4,788 code, 648 comment) · sha 8fa6cecf858741dc

Items

type DurableHypergraph type DurableHypergraph const PROTOCOL_GRAPH_CONCURRENT_MUTATION_MAX_ATTEMPTS struct ProtocolGraphSalvageOutcome struct ProtocolGraphStorageStatus struct ProtocolGraphOpenCheck struct ProtocolGraphRepairStatus impl CurrentStoreGuard type SharedProtocolGraphStore struct HoldingProtocolStore impl HoldingProtocolStore impl Drop for HoldingProtocolStore type LiveProtocolStores static LIVE static WARNED struct EvidenceRefVertexShape const EVIDENCE_REF_VERTEX_SHAPES struct EvidenceNeighborhoodPayloads struct ConsensusStamp const IR_OP_KIND_LABELS const PLANNER_FEEDBACK_KEY const PLANNER_DECISIONS_KEY const PLANNER_RUNTIME_METRICS_KEY const PLANNER_OUTCOMES_KEY const PLANNER_REGION_SUMMARY_PREFIX const PLANNER_SCHEMA_ID const PLANNER_SCHEMA_VERSION const PLANNER_KIND_FEEDBACK const PLANNER_KIND_REGION_SUMMARIES const PLANNER_KIND_DECISIONS const PLANNER_KIND_RUNTIME_METRICS const PLANNER_KIND_OUTCOME_RECORDS struct PlannerSchemaEnvelope struct PlannerPriorSummary struct PlannerDecisionRecord struct PlannerRuntimeMetricsRecord struct PlannerOutcomeRecord static SEQ static SEQ

Functions

By call-graph weight (PageRank; 1.0 is the average function). 229 functions in all.

functionkindlinescyclomaticcallerscalleesweightcrystal
with_graphsrc/graph_store.rs:734fn29610766198
with_graph_mutsrc/graph_store.rs:768fn4998616106
HoldingProtocolStore::entersrc/graph_store.rs:933method4113063.6
open_protocol_graphsrc/graph_store.rs:478fn4144251.2
live_protocol_store_for_fallbacksrc/graph_store.rs:951fn623345.5
open_protocol_graph_from_truthsrc/graph_store.rs:490fn47671223.8
HoldingProtocolStore::activesrc/graph_store.rs:938method318015.8
live_protocol_storesrc/graph_store.rs:980fn314213.8
with_storesrc/graph_store.rs:875fn22418511.5
protocol_graph_paths_from_truthsrc/graph_store.rs:328fn91849
is_concurrent_mutation_open_errorsrc/graph_store.rs:120fn31507
live_protocol_store_atsrc/graph_store.rs:974fn31226.4
collect_expr_symbolssrc/graph_store.rs:1143fn164726.1
live_protocol_storessrc/graph_store.rs:963fn41405.1
live_store_keysrc/graph_store.rs:969fn31405.1
open_with_concurrent_mutation_retrysrc/graph_store.rs:135fn194615.1
visit_expr_childrensrc/graph_store.rs:1109fn217224
with_ambient_storesrc/graph_store.rs:724fn91323.9
read_memory_slotsrc/graph_store.rs:3924fn1011033.9
protocol_vidsrc/graph_store.rs:1091fn311103.7
ensure_vertexsrc/graph_store.rs:1445fn2161513.6
should_recover_protocol_graph_open_errorsrc/graph_store.rs:77fn118603.5
decode_planner_payloadsrc/graph_store.rs:4002fn94503.1
push_unique_symbolsrc/graph_store.rs:1103fn52103.1
ensure_edgesrc/graph_store.rs:1467fn3991013
op_uses_symbolssrc/graph_store.rs:1295fn95552.7
evidence_ref_matchessrc/graph_store.rs:3147fn32302.7
protocols_defining_symbolsrc/graph_store.rs:3798fn3710722.7
write_memory_slotsrc/graph_store.rs:3899fn232922.6
store_peersrc/graph_store.rs:1675fn2822212.5
recover_protocol_graph_storage_with_salvagesrc/graph_store.rs:212fn816422.4
claims_for_refsrc/graph_store.rs:3162fn335572.4
attestations_for_protocolsrc/graph_store.rs:3441fn141622.3
evidence_ref_fingerprintsrc/graph_store.rs:2864fn31212.3
log_protocol_graph_salvage_outcomesrc/graph_store.rs:297fn301202.3
open_protocol_graph_beside_live_writersrc/graph_store.rs:1059fn232212.2
store_protocolsrc/graph_store.rs:1551fn105414112.2
symbol_vidsrc/graph_store.rs:1095fn31212.2
cleanupsrc/graph_store.rs:4345fn412512.2
visit_expr_listsrc/graph_store.rs:1131fn52102.2
visit_object_valuessrc/graph_store.rs:1137fn52102.2
CurrentStoreGuard::for_contextsrc/graph_store.rs:712method31912.1
ensure_protocol_decomposition_edgesrc/graph_store.rs:1510fn183512.1
get_protocolsrc/graph_store.rs:1665fn61732.1
open_temp_graphsrc/graph_store.rs:4333fn1112312
load_planner_feedbacksrc/graph_store.rs:4052fn51822
write_evidence_claimsrc/graph_store.rs:3073fn4231021.9
list_consensus_stampssrc/graph_store.rs:3572fn151231.8
recover_protocol_graph_storagesrc/graph_store.rs:104fn71221.8
seed_protocol_graph_storage_from_salvagesrc/graph_store.rs:187fn143201.7
outputs_for_transform_plansrc/graph_store.rs:3392fn215421.7
push_unique_refsrc/graph_store.rs:3196fn52311.6
execution_evidence_promotions_from_graphsrc/graph_store.rs:2431fn11418851.6
store_gpu_capability_vertexsrc/graph_store.rs:1723fn344121.6
planner_envelopesrc/graph_store.rs:3992fn91501.5
protocols_using_symbolsrc/graph_store.rs:3760fn318321.4
resolve_symbolsrc/graph_store.rs:3844fn41421.4
ir_op_vertex_idsrc/graph_store.rs:72fn41321.3
append_planner_outcome_with_regionssrc/graph_store.rs:4087fn224241.3
upsert_evidence_claim_vertexsrc/graph_store.rs:3038fn142111.3
write_claim_ref_edgesrc/graph_store.rs:3053fn181131.3
load_planner_outcome_recordssrc/graph_store.rs:4220fn51421.3
op_symbolssrc/graph_store.rs:1179fn61321.3
load_planner_decisionssrc/graph_store.rs:4178fn51421.3
store_peer_capability_gpusrc/graph_store.rs:1713fn92511.3
quarantine_graph_filesrc/graph_store.rs:90fn122101.2
receipt_vertex_id_if_presentsrc/graph_store.rs:2872fn51321.2
evidence_ref_vertexsrc/graph_store.rs:3014fn41331.2
generic_evidence_ref_vertex_idsrc/graph_store.rs:2868fn31111.2
with_shared_graph_mutsrc/graph_store.rs:1036fn173361.2
refs_claimed_equivalentsrc/graph_store.rs:3206fn228351.2
write_execution_observationsrc/graph_store.rs:2100fn211681.2
transform_reuse_output_hashessrc/graph_store.rs:3414fn202241.2
load_planner_runtime_metricssrc/graph_store.rs:4198fn71321.2
unique_temp_pathssrc/graph_store.rs:5651fn101411.2
install_runtime_graph_writersrc/graph_store.rs:829fn151441.2
store_full_receiptsrc/graph_store.rs:1956fn433541.1
with_shared_graphsrc/graph_store.rs:1019fn143171.1
write_vm_trace_stepsrc/graph_store.rs:2075fn221121.1
collect_expr_literalssrc/graph_store.rs:1160fn103111
collect_op_binding_symbolssrc/graph_store.rs:1186fn53131
collect_op_value_symbolssrc/graph_store.rs:1265fn154111
sweep_excess_cache_entriessrc/graph_store.rs:3730fn255341
link_execution_observation_cachesrc/graph_store.rs:2794fn213131
evidence_neighborhood_for_refsrc/graph_store.rs:3343fn472161
shared_protocol_storesrc/graph_store.rs:998fn132651
is_consensus_reachedsrc/graph_store.rs:3537fn121211
make_ir_graphsrc/graph_store.rs:4350fn151801
store_attestationsrc/graph_store.rs:1894fn563241
collect_basic_use_symbolssrc/graph_store.rs:1305fn32121
collect_memory_use_symbolssrc/graph_store.rs:1340fn228111
collect_call_use_symbolssrc/graph_store.rs:1363fn216111
collect_probabilistic_use_symbolssrc/graph_store.rs:1385fn113111
collect_quantum_use_symbolssrc/graph_store.rs:1397fn228111
write_execution_occurrencesrc/graph_store.rs:2129fn15310451
planner_region_summary_keysrc/graph_store.rs:4154fn31400.9
bounded_appendsrc/graph_store.rs:4146fn72300.9
push_unique_stringsrc/graph_store.rs:3277fn52200.9
collect_basic_expr_use_symbolssrc/graph_store.rs:1309fn182110.9
collect_delete_use_symbolsrc/graph_store.rs:1328fn113100.9
ir_hash_for_protocol_idsrc/graph_store.rs:1874fn62530.9
sweep_stale_cachesrc/graph_store.rs:3708fn204250.9
execution_evidence_promotion_vertex_idsrc/graph_store.rs:2546fn31200.9
require_request_atom_unclaimedsrc/graph_store.rs:2550fn467200.9
require_monotonic_evidencesrc/graph_store.rs:2628fn164200.9
ensure_evidence_ref_vertexsrc/graph_store.rs:3019fn103130.9
evidence_ref_edge_idsrc/graph_store.rs:3030fn71110.9
append_planner_outcomesrc/graph_store.rs:4077fn81410.9
tombstone_cache_vertexsrc/graph_store.rs:3687fn112200.9
cache_payload_is_livesrc/graph_store.rs:3699fn31200.9
write_vm_trace_contractsrc/graph_store.rs:2004fn121240.8
evidence_ref_vertex_shapesrc/graph_store.rs:2986fn61100.8
shaped_evidence_ref_vertex_idsrc/graph_store.rs:2993fn72110.8
shaped_evidence_ref_propssrc/graph_store.rs:3001fn123100.8
collect_function_binding_symbolssrc/graph_store.rs:1200fn123100.8
collect_simple_binding_symbolssrc/graph_store.rs:1213fn208100.8
write_execution_evidence_promotionsrc/graph_store.rs:2295fn13514270.8
make_gpu_capabilitysrc/graph_store.rs:5479fn131600.8
append_planner_outcome_recordsrc/graph_store.rs:4227fn111440.8
collect_named_binding_symbolssrc/graph_store.rs:1192fn73120.8
collect_control_binding_symbolssrc/graph_store.rs:1234fn83110.8
collect_type_import_binding_symbolssrc/graph_store.rs:1243fn216100.8
evidence_claim_from_vertexsrc/graph_store.rs:3116fn72110.8
evidence_ref_vertex_ids_for_querysrc/graph_store.rs:3124fn164120.8
push_unique_claimsrc/graph_store.rs:3141fn52100.8
claim_mentions_refsrc/graph_store.rs:3151fn53110.8
attestation_peer_viewssrc/graph_store.rs:3460fn233320.8
store_planner_feedbacksrc/graph_store.rs:4059fn141120.8
require_exact_promotion_edgesrc/graph_store.rs:2597fn307100.8
collect_claim_refssrc/graph_store.rs:3229fn93110.8
plan_immutable_execution_vertexsrc/graph_store.rs:2645fn183210.8
plan_execution_occurrence_edgesrc/graph_store.rs:2664fn266210.8
all_peerssrc/graph_store.rs:1866fn31130.8
add_transform_outputssrc/graph_store.rs:3307fn52220.7
reopen_protocol_graph_after_recoverysrc/graph_store.rs:451fn62100.7
protocol_graph_wal_doctor_from_truthsrc/graph_store.rs:339fn424270.7
apply_runtime_graph_mutationsrc/graph_store.rs:845fn243100.7
open_protocol_graph_deferred_writersrc/graph_store.rs:562fn345290.7
write_memory_namespacesrc/graph_store.rs:3959fn112110.7
stamp_attestation_tiersrc/graph_store.rs:3631fn484140.7
mark_consensus_reachedsrc/graph_store.rs:3590fn224220.7
append_planner_decisionsrc/graph_store.rs:4185fn111340.7
quarantine_files_forsrc/graph_store.rs:5664fn152320.7
live_writer_truthsrc/graph_store.rs:5843fn61420.7
put_peersrc/graph_store.rs:5850fn31410.7
load_memory_namespacesrc/graph_store.rs:3937fn192230.7
planner_prior_for_ir_hashsrc/graph_store.rs:4114fn318210.7
ensure_vm_trace_vertexsrc/graph_store.rs:2017fn101110.7
link_vm_trace_programsrc/graph_store.rs:2028fn172130.7
link_vm_trace_receiptsrc/graph_store.rs:2046fn172130.7
write_vm_trace_stepssrc/graph_store.rs:2064fn102110.7
store_protocol_node_symbolssrc/graph_store.rs:597fn192140.7
store_protocol_node_literalssrc/graph_store.rs:617fn162140.7
store_protocol_control_flow_edgessrc/graph_store.rs:634fn244110.7
store_protocol_data_flow_edgessrc/graph_store.rs:659fn244110.7
op_kind_labelsrc/graph_store.rs:3884fn31100.7
store_peer_protocolsrc/graph_store.rs:1803fn374240.7
store_region_summariessrc/graph_store.rs:4159fn101330.7
with_graph_mut_deferred_flushsrc/graph_store.rs:822fn61210.7
neighborhood_refssrc/graph_store.rs:3283fn153120.6
collect_evidence_neighborhood_payloadssrc/graph_store.rs:3313fn288150.6
op_literalssrc/graph_store.rs:1421fn192110.6
store_peer_capability_gpussrc/graph_store.rs:1768fn307310.6
actualizations_for_protocolsrc/graph_store.rs:4289fn191220.6
link_execution_observation_programsrc/graph_store.rs:2691fn251120.6
link_execution_observation_nucleussrc/graph_store.rs:2717fn442120.6
link_execution_observation_receiptsrc/graph_store.rs:2762fn202130.6
link_execution_observation_cachessrc/graph_store.rs:2783fn102110.6
link_execution_observation_parentsrc/graph_store.rs:2816fn212120.6
upsert_execution_observation_vertexsrc/graph_store.rs:2838fn142100.6
merge_execution_observation_call_countsrc/graph_store.rs:2853fn102100.6
observation_props_for_refsrc/graph_store.rs:3239fn133110.6
receipt_props_for_refsrc/graph_store.rs:3253fn164130.6
push_unique_json_by_keysrc/graph_store.rs:3270fn63100.6
get_consensus_stampsrc/graph_store.rs:3552fn71120.6
providers_for_ir_hashsrc/graph_store.rs:1844fn201220.6
load_region_summariessrc/graph_store.rs:4171fn51230.6
protocol_graph_storage_statussrc/graph_store.rs:405fn101110.6
protocol_graph_open_checksrc/graph_store.rs:417fn142110.6
apply_protocol_graph_wal_doctor_modesrc/graph_store.rs:433fn165120.6
attestation_tier_profilesrc/graph_store.rs:3496fn398140.6
append_planner_runtime_metricssrc/graph_store.rs:4207fn111240.6
shape_countssrc/graph_store.rs:4546nested fn251120.6
write_actualizationsrc/graph_store.rs:4250fn363140.6
protocol_graph_wal_doctorsrc/graph_store.rs:459fn41020.5
open_protocol_graph_deferredsrc/graph_store.rs:546fn112070.5
HoldingProtocolStore::dropsrc/graph_store.rs:944trait impl31000.5
live_protocol_storesrc/graph_store.rs:987fn31000.5
shared_protocol_storesrc/graph_store.rs:1013fn41020.5
has_transform_reuse_claimsrc/graph_store.rs:3435fn31010.5
op_uses_symbols_excludes_def_fn_name_and_paramssrc/graph_store.rs:4371fn82020.5
op_uses_symbols_emits_callee_from_return_callsrc/graph_store.rs:4381fn71010.5
op_uses_symbols_assign_skips_target_keeps_value_identssrc/graph_store.rs:4390fn161010.5
op_uses_symbols_for_in_skips_varsrc/graph_store.rs:4408fn71010.5
wal_format_open_errors_are_recoverablesrc/graph_store.rs:4417fn61010.5
ir_graph_round_tripsrc/graph_store.rs:4425fn171050.5
ir_graph_round_trip_ir_hash_stablesrc/graph_store.rs:4444fn131050.5
ensure_edge_same_id_replay_is_immutablesrc/graph_store.rs:4459fn663050.5
repeated_protocol_decomposition_shapes_deduplicatesrc/graph_store.rs:4527fn561060.5
receipt_full_field_round_tripsrc/graph_store.rs:4585fn411080.5
attestation_edge_links_protocol_receipt_peersrc/graph_store.rs:4628fn241080.5
evidence_ref_queries_follow_materialized_edgessrc/graph_store.rs:4654fn421090.5
execution_observation_links_receipt_cache_and_nucleussrc/graph_store.rs:4698fn14920110.5
execution_occurrence_is_immutable_atomic_and_wal_durablesrc/graph_store.rs:4849fn23220130.5
vm_trace_contract_materializes_trace_and_stepssrc/graph_store.rs:5083fn531040.5
consensus_counts_unique_peerssrc/graph_store.rs:5138fn212060.5
list_consensus_stamps_returns_only_stamped_protocols_sortedsrc/graph_store.rs:5161fn261060.5
get_protocol_returns_none_for_unknown_hashsrc/graph_store.rs:5189fn51030.5
planner_feedback_round_tripsrc/graph_store.rs:5196fn271050.5
planner_prior_summary_for_ir_hashsrc/graph_store.rs:5225fn341040.5
planner_runtime_records_round_tripsrc/graph_store.rs:5261fn13210120.5
planner_legacy_payloads_still_decodesrc/graph_store.rs:5395fn801070.5
store_peer_capability_gpu_persists_typed_vertex_with_propssrc/graph_store.rs:5494fn301060.5
store_peer_capability_gpu_links_to_peer_via_edgesrc/graph_store.rs:5526fn181090.5
store_peer_capability_gpu_is_idempotentsrc/graph_store.rs:5546fn251080.5
store_peer_capability_gpu_skips_edge_when_peer_vertex_missingsrc/graph_store.rs:5573fn131070.5
store_peer_capability_gpus_single_is_aggregate_onlysrc/graph_store.rs:5588fn191090.5
store_peer_capability_gpus_multi_aggregates_primary_and_per_device_restsrc/graph_store.rs:5609fn301090.5
is_concurrent_mutation_open_error_matches_hyperdb_display_text_and_is_disjoint_from_corruptionsrc/graph_store.rs:5681fn101020.5
concurrent_mutation_retry_succeeds_once_the_race_clearssrc/graph_store.rs:5693fn142010.5
concurrent_mutation_retry_gives_up_after_max_attempts_without_quarantiningsrc/graph_store.rs:5709fn161030.5
non_concurrent_mutation_error_is_not_retriedsrc/graph_store.rs:5727fn101010.5
mid_file_corruption_salvages_undamaged_prefix_and_keeps_quarantine_filessrc/graph_store.rs:5739fn554050.5
unreadable_wal_falls_back_to_empty_store_with_quarantine_keptsrc/graph_store.rs:5796fn262050.5
salvage_seed_failure_reports_error_and_does_not_panicsrc/graph_store.rs:5824fn181020.5
shared_protocol_store_is_one_handle_per_store_until_releasedsrc/graph_store.rs:5855fn141060.5
a_plain_open_beside_the_live_writer_cannot_truncate_write_or_quarantinesrc/graph_store.rs:5871fn3410110.5
graph_fallbacks_write_through_the_live_writersrc/graph_store.rs:5907fn141090.5
a_nested_fallback_reads_the_view_instead_of_relocking_the_writersrc/graph_store.rs:5923fn2210100.5

Source not readable from this process.