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-virtual_compute/src/logic.rs
Items
const VIRTUAL_REPLAY_ARTIFACT_MAX_BYTES struct ComputeSetup struct PreparedComputeDispatch struct ComputeOutbox struct ComputeExecution struct ComputeExplorerSnapshot struct TraceIds struct TraceRecords struct TraceArtifacts struct TraceContextData const TRACE_KIND_PREFIXES struct ReplaySourcePlan impl ReplaySourcePlan struct ReplayTracePlan impl ReplayTracePlan struct ReplayDigestPlan impl ReplayDigestPlan struct ReplayComparisonPlan impl ReplayComparisonPlan struct ReplayCheckPlan impl ReplayCheckPlan struct ReplayVerdictPlan impl ReplayVerdictPlan
Functions
By call-graph weight (PageRank; 1.0 is the average function). 166 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| push_trace_story_stagesrc/logic.rs:2244 | fn | 20 | 1 | 10 | 0 | 4.7 | |
| trace_getsrc/logic.rs:2031 | fn | 3 | 1 | 7 | 2 | 1.8 | |
| trace_kind_for_idsrc/logic.rs:2027 | fn | 3 | 1 | 2 | 0 | 1.6 | |
| virtual_dispatch_payloadsrc/logic.rs:1419 | fn | 31 | 2 | 5 | 11 | 1.6 | |
| merge_object_fieldsrc/logic.rs:1807 | fn | 9 | 2 | 2 | 0 | 1.6 | |
| target_kind_from_idsrc/logic.rs:2035 | fn | 11 | 4 | 3 | 0 | 1.5 | |
| computesrc/logic.rs:94 | fn | 8 | 1 | 5 | 5 | 1.4 | |
| value_dispatch_modesrc/logic.rs:1825 | fn | 20 | 1 | 1 | 2 | 1.4 | |
| replay_artifact_pathsrc/logic.rs:2667 | fn | 14 | 6 | 2 | 0 | 1.3 | |
| launch_session_outbox_pathsrc/logic.rs:298 | fn | 9 | 2 | 2 | 1 | 1.3 | |
| trace_item_matches_result_or_receiptsrc/logic.rs:723 | fn | 4 | 2 | 2 | 1 | 1.3 | |
| push_trace_idsrc/logic.rs:2133 | fn | 8 | 2 | 2 | 0 | 1.2 | |
| plan_for_tasksrc/logic.rs:1395 | fn | 23 | 1 | 1 | 3 | 1.1 | |
| ensure_dispatch_policy_defaultssrc/logic.rs:1740 | fn | 36 | 10 | 2 | 2 | 1 | |
| merge_work_contract_into_argssrc/logic.rs:1635 | fn | 36 | 8 | 2 | 0 | 1 | |
| dispatch_mode_from_sourcessrc/logic.rs:1821 | fn | 3 | 1 | 2 | 1 | 1 | |
| replay_required_value_matchsrc/logic.rs:2568 | fn | 3 | 1 | 2 | 0 | 1 | |
| replay_compared_values_matchsrc/logic.rs:2576 | fn | 7 | 3 | 2 | 0 | 1 | |
| replay_source_from_tracesrc/logic.rs:2265 | fn | 10 | 1 | 2 | 0 | 1 | |
| task_statussrc/logic.rs:1381 | fn | 3 | 1 | 1 | 1 | 1 | |
| replay_payload_from_artifact_pathsrc/logic.rs:2683 | fn | 8 | 1 | 2 | 2 | 0.9 | |
| live_compute_statussrc/logic.rs:9 | fn | 14 | 1 | 2 | 1 | 0.9 | |
| trace_status_ranksrc/logic.rs:2142 | fn | 9 | 5 | 2 | 1 | 0.9 | |
| lifecycle_event_for_statussrc/logic.rs:2238 | fn | 5 | 1 | 2 | 0 | 0.9 | |
| tracesrc/logic.rs:468 | fn | 13 | 1 | 2 | 7 | 0.9 | |
| compute_launch_idsrc/logic.rs:285 | fn | 3 | 1 | 2 | 0 | 0.9 | |
| compute_outbox_pathsrc/logic.rs:289 | fn | 8 | 1 | 2 | 1 | 0.9 | |
| resolve_dispatch_kernel_source_refsrc/logic.rs:1900 | fn | 72 | 7 | 3 | 3 | 0.9 | |
| compute_task_id_for_inputsrc/logic.rs:262 | fn | 11 | 1 | 2 | 1 | 0.9 | |
| temp_pathsrc/logic.rs:2701 | fn | 3 | 1 | 2 | 1 | 0.8 | |
| task_targets_chunksrc/logic.rs:1376 | fn | 4 | 2 | 2 | 2 | 0.8 | |
| proof_metadata_from_sourcessrc/logic.rs:2584 | fn | 60 | 11 | 1 | 7 | 0.8 | |
| planned_delegation_plansrc/logic.rs:1499 | fn | 26 | 1 | 1 | 1 | 0.8 | |
| descriptor_source_refsrc/logic.rs:1979 | fn | 7 | 1 | 1 | 1 | 0.8 | |
| kernel_for_source_refsrc/logic.rs:2000 | fn | 6 | 1 | 1 | 2 | 0.8 | |
| ReplayCheckPlan::replayablesrc/logic.rs:2498 | method | 3 | 3 | 1 | 0 | 0.8 | |
| replay_proof_shape_matchsrc/logic.rs:2572 | fn | 3 | 3 | 1 | 0 | 0.8 | |
| select_trace_task_for_targetsrc/logic.rs:2047 | fn | 6 | 1 | 1 | 3 | 0.8 | |
| select_trace_receipt_for_resultsrc/logic.rs:2062 | fn | 13 | 1 | 1 | 2 | 0.8 | |
| select_trace_snapshotsrc/logic.rs:2076 | fn | 18 | 2 | 1 | 5 | 0.8 | |
| queue_for_contextsrc/logic.rs:24 | fn | 42 | 3 | 1 | 6 | 0.8 | |
| strategy_uses_gpusrc/logic.rs:1672 | fn | 6 | 1 | 2 | 0 | 0.8 | |
| target_compute_declarationsrc/logic.rs:242 | fn | 19 | 1 | 3 | 2 | 0.8 | |
| trace_target_recordssrc/logic.rs:2095 | fn | 37 | 9 | 2 | 2 | 0.8 | |
| descriptor_task_id_for_inputsrc/logic.rs:1178 | fn | 14 | 1 | 2 | 1 | 0.8 | |
| ReplayDigestPlan::from_sourcesrc/logic.rs:2376 | method | 48 | 2 | 2 | 2 | 0.8 | |
| trace_requested_target_kindsrc/logic.rs:550 | fn | 6 | 2 | 1 | 0 | 0.8 | |
| dispatch_kernel_source_ref_hintsrc/logic.rs:1973 | fn | 5 | 1 | 1 | 2 | 0.7 | |
| resolve_dispatch_kernelsrc/logic.rs:1987 | fn | 12 | 2 | 1 | 2 | 0.7 | |
| ReplayComparisonPlan::betweensrc/logic.rs:2452 | method | 18 | 1 | 3 | 2 | 0.7 | |
| ReplayCheckPlan::from_digestsrc/logic.rs:2487 | method | 10 | 2 | 3 | 0 | 0.7 | |
| ReplayVerdictPlan::from_checkssrc/logic.rs:2542 | method | 17 | 9 | 3 | 2 | 0.7 | |
| trace_task_frame_idsrc/logic.rs:810 | fn | 7 | 1 | 1 | 1 | 0.7 | |
| compute_setupsrc/logic.rs:131 | fn | 7 | 1 | 1 | 4 | 0.7 | |
| prepare_compute_dispatchsrc/logic.rs:139 | fn | 23 | 1 | 1 | 7 | 0.7 | |
| compute_outboxsrc/logic.rs:163 | fn | 5 | 1 | 1 | 2 | 0.7 | |
| execute_prepared_computesrc/logic.rs:169 | fn | 24 | 1 | 1 | 9 | 0.7 | |
| compute_result_jsonsrc/logic.rs:194 | fn | 34 | 1 | 1 | 0 | 0.7 | |
| trace_snapshot_target_idsrc/logic.rs:585 | fn | 6 | 1 | 1 | 1 | 0.7 | |
| trace_select_task_for_targetsrc/logic.rs:611 | fn | 10 | 1 | 1 | 2 | 0.7 | |
| trace_select_receipt_for_resultsrc/logic.rs:664 | fn | 10 | 1 | 1 | 2 | 0.7 | |
| trace_select_snapshotsrc/logic.rs:686 | fn | 5 | 1 | 1 | 2 | 0.7 | |
| requested_replay_artifact_sourcesrc/logic.rs:2645 | fn | 10 | 1 | 1 | 2 | 0.7 | |
| replay_trace_id_from_sourcesrc/logic.rs:2656 | fn | 10 | 1 | 1 | 2 | 0.7 | |
| plansrc/logic.rs:67 | fn | 9 | 1 | 1 | 1 | 0.7 | |
| queuesrc/logic.rs:77 | fn | 16 | 3 | 1 | 2 | 0.7 | |
| actsrc/logic.rs:426 | fn | 41 | 2 | 1 | 4 | 0.7 | |
| enqueue_target_compute_tasksrc/logic.rs:274 | fn | 10 | 2 | 2 | 1 | 0.7 | |
| append_outbox_eventsrc/logic.rs:365 | fn | 34 | 3 | 2 | 3 | 0.7 | |
| complete_replay_digestsrc/logic.rs:2705 | fn | 11 | 1 | 2 | 0 | 0.7 | |
| compute_started_eventsrc/logic.rs:308 | fn | 11 | 1 | 2 | 0 | 0.7 | |
| compute_finished_eventsrc/logic.rs:320 | fn | 18 | 1 | 2 | 0 | 0.7 | |
| compute_response_oksrc/logic.rs:352 | fn | 3 | 1 | 2 | 0 | 0.7 | |
| compute_receiptsrc/logic.rs:356 | fn | 7 | 1 | 2 | 0 | 0.7 | |
| ids_with_prefixsrc/logic.rs:1817 | fn | 3 | 1 | 1 | 0 | 0.7 | |
| trace_push_snapshot_target_idssrc/logic.rs:772 | fn | 11 | 2 | 1 | 1 | 0.7 | |
| apply_dispatch_overridessrc/logic.rs:1861 | fn | 29 | 5 | 2 | 0 | 0.7 | |
| dispatch_overrides_for_inputsrc/logic.rs:1891 | fn | 8 | 1 | 2 | 0 | 0.7 | |
| trace_task_last_dispatch_idsrc/logic.rs:635 | fn | 3 | 1 | 1 | 0 | 0.7 | |
| trace_story_compute_dispatchsrc/logic.rs:898 | fn | 19 | 1 | 1 | 1 | 0.7 | |
| trace_story_lifecycle_dispatchsrc/logic.rs:918 | fn | 11 | 1 | 1 | 1 | 0.7 | |
| select_trace_result_for_tasksrc/logic.rs:2054 | fn | 7 | 1 | 1 | 3 | 0.7 | |
| compute_bridge_statussrc/logic.rs:238 | fn | 3 | 1 | 1 | 1 | 0.7 | |
| descriptorsrc/logic.rs:1113 | fn | 64 | 2 | 1 | 8 | 0.7 | |
| replaysrc/logic.rs:1193 | fn | 40 | 1 | 1 | 10 | 0.7 | |
| receiptssrc/logic.rs:1234 | fn | 53 | 3 | 1 | 5 | 0.7 | |
| proofssrc/logic.rs:1288 | fn | 41 | 2 | 1 | 4 | 0.7 | |
| artifactssrc/logic.rs:1330 | fn | 43 | 2 | 1 | 3 | 0.7 | |
| merge_dispatch_hint_fieldssrc/logic.rs:1697 | fn | 23 | 2 | 1 | 1 | 0.6 | |
| merge_proof_policy_fieldssrc/logic.rs:1721 | fn | 10 | 3 | 1 | 1 | 0.6 | |
| merge_task_policysrc/logic.rs:1732 | fn | 7 | 3 | 1 | 0 | 0.6 | |
| trace_clean_idsrc/logic.rs:536 | fn | 3 | 1 | 1 | 0 | 0.6 | |
| trace_request_id_with_prefixsrc/logic.rs:540 | fn | 3 | 1 | 1 | 0 | 0.6 | |
| trace_target_request_idsrc/logic.rs:544 | fn | 5 | 1 | 1 | 2 | 0.6 | |
| trace_shard_receiptssrc/logic.rs:706 | fn | 12 | 3 | 1 | 2 | 0.6 | |
| trace_first_matching_list_itemsrc/logic.rs:719 | fn | 3 | 1 | 1 | 1 | 0.6 | |
| load_virtual_dispatch_tasksrc/logic.rs:1451 | fn | 8 | 2 | 1 | 2 | 0.6 | |
| load_virtual_dispatch_kernelsrc/logic.rs:1460 | fn | 10 | 2 | 1 | 2 | 0.6 | |
| normalized_task_inputsrc/logic.rs:1471 | fn | 4 | 2 | 1 | 0 | 0.6 | |
| apply_kernel_dispatch_defaultssrc/logic.rs:1476 | fn | 22 | 2 | 1 | 2 | 0.6 | |
| work_contract_for_tasksrc/logic.rs:1582 | fn | 30 | 1 | 1 | 3 | 0.6 | |
| ensure_capabilitiessrc/logic.rs:1613 | fn | 21 | 5 | 1 | 2 | 0.6 | |
| task_dispatch_policysrc/logic.rs:1686 | fn | 10 | 1 | 1 | 4 | 0.6 | |
| apply_dispatch_policysrc/logic.rs:1777 | fn | 29 | 4 | 1 | 0 | 0.6 | |
| task_status_matchessrc/logic.rs:1385 | fn | 9 | 3 | 1 | 1 | 0.6 | |
| trace_request_idssrc/logic.rs:519 | fn | 16 | 1 | 1 | 4 | 0.6 | |
| trace_resolve_recordssrc/logic.rs:557 | fn | 15 | 1 | 1 | 9 | 0.6 | |
| trace_artifactssrc/logic.rs:692 | fn | 13 | 1 | 1 | 4 | 0.6 | |
| trace_context_datasrc/logic.rs:728 | fn | 35 | 1 | 1 | 7 | 0.6 | |
| trace_storysrc/logic.rs:818 | fn | 18 | 1 | 1 | 9 | 0.6 | |
| trace_responsesrc/logic.rs:1070 | fn | 42 | 4 | 1 | 0 | 0.6 | |
| compute_request_contextsrc/logic.rs:1846 | fn | 3 | 1 | 1 | 0 | 0.6 | |
| attach_dispatch_request_contextsrc/logic.rs:1850 | fn | 10 | 3 | 1 | 0 | 0.6 | |
| ReplayCheckPlan::summary_jsonsrc/logic.rs:2516 | method | 17 | 1 | 1 | 0 | 0.6 | |
| trace_target_node_idssrc/logic.rs:764 | fn | 7 | 1 | 1 | 3 | 0.6 | |
| trace_dispatch_payloadsrc/logic.rs:784 | fn | 12 | 1 | 1 | 1 | 0.6 | |
| trace_work_contractsrc/logic.rs:797 | fn | 8 | 1 | 1 | 0 | 0.6 | |
| trace_frame_idsrc/logic.rs:806 | fn | 3 | 1 | 1 | 2 | 0.6 | |
| trace_compute_summarysrc/logic.rs:2152 | fn | 85 | 1 | 1 | 2 | 0.6 | |
| compute_explorer_snapshotsrc/logic.rs:339 | fn | 12 | 1 | 1 | 5 | 0.6 | |
| execute_dispatch_payloadsrc/logic.rs:411 | fn | 14 | 2 | 1 | 2 | 0.6 | |
| compute_delegation_plansrc/logic.rs:1526 | fn | 55 | 2 | 1 | 4 | 0.6 | |
| trace_hydrate_from_snapshotsrc/logic.rs:573 | fn | 11 | 2 | 1 | 2 | 0.6 | |
| trace_hydrate_from_receiptsrc/logic.rs:592 | fn | 5 | 2 | 1 | 1 | 0.6 | |
| trace_hydrate_from_resultsrc/logic.rs:598 | fn | 5 | 2 | 1 | 1 | 0.6 | |
| trace_resolve_tasksrc/logic.rs:604 | fn | 6 | 1 | 1 | 2 | 0.6 | |
| trace_hydrate_from_tasksrc/logic.rs:622 | fn | 12 | 2 | 1 | 3 | 0.6 | |
| trace_resolve_resultsrc/logic.rs:639 | fn | 13 | 1 | 1 | 3 | 0.6 | |
| trace_resolve_receiptsrc/logic.rs:653 | fn | 10 | 1 | 1 | 2 | 0.6 | |
| trace_resolve_snapshotsrc/logic.rs:675 | fn | 10 | 1 | 1 | 2 | 0.6 | |
| trace_story_targetsrc/logic.rs:837 | fn | 16 | 2 | 1 | 1 | 0.6 | |
| trace_story_tasksrc/logic.rs:854 | fn | 21 | 2 | 1 | 2 | 0.6 | |
| trace_story_queuedsrc/logic.rs:876 | fn | 13 | 2 | 1 | 2 | 0.6 | |
| trace_story_dispatchedsrc/logic.rs:890 | fn | 7 | 3 | 1 | 3 | 0.6 | |
| trace_story_resultsrc/logic.rs:930 | fn | 35 | 2 | 1 | 2 | 0.6 | |
| trace_story_receiptsrc/logic.rs:966 | fn | 36 | 3 | 1 | 1 | 0.6 | |
| trace_story_shard_receiptssrc/logic.rs:1003 | fn | 18 | 2 | 1 | 1 | 0.6 | |
| trace_story_snapshotsrc/logic.rs:1022 | fn | 23 | 2 | 1 | 1 | 0.6 | |
| trace_story_artifact_manifestsrc/logic.rs:1046 | fn | 19 | 2 | 1 | 1 | 0.6 | |
| ReplaySourcePlan::loadsrc/logic.rs:2285 | method | 11 | 2 | 1 | 2 | 0.6 | |
| ReplaySourcePlan::source_candidatesrc/logic.rs:2297 | method | 3 | 1 | 1 | 0 | 0.6 | |
| ReplaySourcePlan::path_loadedsrc/logic.rs:2313 | method | 3 | 1 | 1 | 0 | 0.6 | |
| ReplayTracePlan::loadsrc/logic.rs:2325 | method | 32 | 4 | 1 | 2 | 0.6 | |
| replay_source_valuesrc/logic.rs:2561 | fn | 6 | 1 | 1 | 1 | 0.6 | |
| append_outbox_eventsrc/logic.rs:401 | fn | 9 | 1 | 0 | 0 | 0.5 | |
| trace_summary_valuesrc/logic.rs:1066 | fn | 3 | 1 | 0 | 0 | 0.5 | |
| work_kindsrc/logic.rs:1679 | fn | 6 | 1 | 0 | 0 | 0.5 | |
| ReplaySourcePlan::kindsrc/logic.rs:2301 | method | 11 | 4 | 0 | 0 | 0.5 | |
| ReplayDigestPlan::to_jsonsrc/logic.rs:2425 | method | 16 | 1 | 0 | 0 | 0.5 | |
| ReplayComparisonPlan::valuessrc/logic.rs:2471 | method | 3 | 1 | 0 | 0 | 0.5 | |
| ReplayCheckPlan::to_jsonsrc/logic.rs:2502 | method | 13 | 1 | 0 | 0 | 0.5 | |
| replay_payload_from_artifact_pathsrc/logic.rs:2693 | fn | 3 | 1 | 0 | 0 | 0.5 | |
| compute_task_id_helpers_prefer_explicit_target_then_bootstrapsrc/logic.rs:2718 | fn | 21 | 1 | 0 | 2 | 0.5 | |
| compute_target_and_outbox_helpers_cover_noop_pathssrc/logic.rs:2741 | fn | 13 | 1 | 0 | 6 | 0.5 | |
| compute_event_and_receipt_helpers_preserve_response_shapesrc/logic.rs:2756 | fn | 21 | 1 | 0 | 4 | 0.5 | |
| append_outbox_event_writes_jsonl_and_records_offsets_best_effortsrc/logic.rs:2779 | fn | 17 | 1 | 0 | 3 | 0.5 | |
| work_contract_merge_preserves_args_and_derives_gpu_defaultssrc/logic.rs:2798 | fn | 27 | 1 | 0 | 1 | 0.5 | |
| dispatch_policy_defaults_fill_gpu_capabilities_and_booleanssrc/logic.rs:2827 | fn | 21 | 1 | 0 | 1 | 0.5 | |
| resolve_dispatch_kernel_source_ref_handles_noop_and_missing_registry_casessrc/logic.rs:2850 | fn | 15 | 1 | 0 | 2 | 0.5 | |
| replay_verdict_covers_replayable_without_trace_and_incompletesrc/logic.rs:2867 | fn | 14 | 1 | 0 | 4 | 0.5 | |
| replay_artifact_path_trims_explicit_source_and_uses_latest_when_presentsrc/logic.rs:2883 | fn | 13 | 2 | 0 | 1 | 0.5 | |
| trace_target_records_skips_missing_targets_into_empty_bucketssrc/logic.rs:2898 | fn | 16 | 2 | 0 | 2 | 0.5 | |
| replay_digest_extracts_source_contract_artifact_and_proof_shapesrc/logic.rs:2916 | fn | 43 | 1 | 0 | 2 | 0.5 | |
| replay_comparison_and_verdict_helpers_preserve_trace_match_semanticssrc/logic.rs:2961 | fn | 25 | 1 | 0 | 5 | 0.5 | |
| replay_pure_match_helpers_require_a_present_source_valuesrc/logic.rs:2988 | fn | 7 | 1 | 0 | 2 | 0.5 | |
| replay_payload_rejects_oversized_artifactsrc/logic.rs:2997 | fn | 11 | 1 | 0 | 2 | 0.5 |
Source not readable from this process.