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/connection_execute.rs
Items
const PLANNER_HISTORY_WINDOW struct PlannerHistoricalSignals struct PlannerLatencyHistory struct ExecuteTarget struct ExecutePlanning struct ExecuteRunResult struct ExecutePostExecution enum ProtocolRouteHandler impl ProtocolRouteHandler struct ProtocolRoute const PROTOCOL_ROUTES
Functions
By call-graph weight (PageRank; 1.0 is the average function). 98 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| with_protocol_storesrc/connection_execute.rs:281 | fn | 6 | 1 | 10 | 1 | 3.5 | |
| protocol_catalogsrc/connection_execute.rs:50 | fn | 3 | 1 | 6 | 1 | 2.5 | |
| delegate_or_localsrc/connection_execute.rs:966 | fn | 3 | 1 | 3 | 0 | 1.7 | |
| short_label_idsrc/connection_execute.rs:445 | fn | 7 | 2 | 2 | 0 | 1.5 | |
| replan_dispatch_strategysrc/connection_execute.rs:1012 | fn | 21 | 4 | 3 | 0 | 1.5 | |
| create_conflict_responsesrc/connection_execute.rs:111 | fn | 55 | 5 | 5 | 0 | 1.4 | |
| descriptor_fixturesrc/connection_execute.rs:2564 | fn | 17 | 1 | 4 | 0 | 1.3 | |
| read_public_input_limbssrc/connection_execute.rs:2378 | fn | 15 | 2 | 1 | 0 | 1.1 | |
| protocol_status_responsesrc/connection_execute.rs:81 | fn | 29 | 3 | 1 | 4 | 1.1 | |
| ProtocolRouteHandler::dispatchsrc/connection_execute.rs:2445 | method | 13 | 4 | 1 | 1 | 1.1 | |
| parse_distributed_result_valuesrc/connection_execute.rs:1034 | fn | 9 | 3 | 1 | 0 | 1 | |
| percentile_sortedsrc/connection_execute.rs:436 | fn | 8 | 2 | 1 | 0 | 1 | |
| node_function_symbolssrc/connection_execute.rs:594 | fn | 17 | 5 | 1 | 0 | 1 | |
| protocol_get_responsesrc/connection_execute.rs:61 | fn | 9 | 1 | 1 | 1 | 0.9 | |
| latest_resolvable_ir_hashsrc/connection_execute.rs:288 | fn | 19 | 5 | 1 | 3 | 0.8 | |
| protocol_id_as_ir_hashsrc/connection_execute.rs:313 | fn | 4 | 1 | 1 | 1 | 0.8 | |
| dispatch_strategy_labelsrc/connection_execute.rs:991 | fn | 9 | 5 | 2 | 0 | 0.8 | |
| planner_mode_labelsrc/connection_execute.rs:404 | fn | 10 | 6 | 3 | 0 | 0.8 | |
| resolve_ir_hash_for_protocolsrc/connection_execute.rs:318 | fn | 7 | 2 | 1 | 2 | 0.7 | |
| execute_cache_aliasessrc/connection_execute.rs:1881 | fn | 20 | 2 | 1 | 0 | 0.7 | |
| is_empty_truth_fallbacksrc/connection_execute.rs:308 | fn | 4 | 2 | 1 | 0 | 0.7 | |
| decode_proof_hexsrc/connection_execute.rs:2369 | fn | 6 | 1 | 1 | 0 | 0.7 | |
| protocol_verify_public_inputssrc/connection_execute.rs:2396 | fn | 21 | 1 | 1 | 1 | 0.7 | |
| should_attempt_midflight_replansrc/connection_execute.rs:1001 | fn | 10 | 7 | 1 | 0 | 0.7 | |
| preferred_dispatch_peersrc/connection_execute.rs:962 | fn | 3 | 1 | 1 | 0 | 0.6 | |
| plan_shard_chain_strategysrc/connection_execute.rs:970 | fn | 13 | 3 | 1 | 1 | 0.6 | |
| plan_gpu_strategysrc/connection_execute.rs:984 | fn | 6 | 2 | 1 | 1 | 0.6 | |
| handle_distributed_successsrc/connection_execute.rs:1631 | fn | 38 | 3 | 1 | 1 | 0.6 | |
| maybe_replan_distributedsrc/connection_execute.rs:1670 | fn | 27 | 3 | 1 | 3 | 0.6 | |
| planner_latency_historysrc/connection_execute.rs:696 | fn | 33 | 7 | 1 | 1 | 0.6 | |
| apply_planner_latency_historysrc/connection_execute.rs:730 | fn | 19 | 5 | 1 | 1 | 0.6 | |
| apply_planner_replan_historysrc/connection_execute.rs:750 | fn | 22 | 5 | 1 | 1 | 0.6 | |
| apply_planner_runtime_historysrc/connection_execute.rs:773 | fn | 25 | 5 | 1 | 1 | 0.6 | |
| ranked_region_contributorssrc/connection_execute.rs:453 | fn | 37 | 2 | 1 | 1 | 0.6 | |
| ranked_function_contributorssrc/connection_execute.rs:491 | fn | 37 | 2 | 1 | 0 | 0.6 | |
| measured_region_contributorssrc/connection_execute.rs:529 | fn | 64 | 8 | 1 | 1 | 0.6 | |
| measured_function_contributorssrc/connection_execute.rs:612 | fn | 57 | 6 | 1 | 1 | 0.6 | |
| plan_mode_to_dispatch_strategysrc/connection_execute.rs:947 | fn | 14 | 4 | 1 | 4 | 0.6 | |
| run_distributed_dispatch_loopsrc/connection_execute.rs:1595 | fn | 35 | 6 | 1 | 4 | 0.6 | |
| seed_execute_memorysrc/connection_execute.rs:1512 | fn | 9 | 2 | 1 | 3 | 0.6 | |
| try_execute_distributedsrc/connection_execute.rs:1522 | fn | 72 | 5 | 1 | 5 | 0.6 | |
| run_local_executesrc/connection_execute.rs:1698 | fn | 44 | 1 | 1 | 2 | 0.6 | |
| open_storesrc/connection_execute.rs:276 | fn | 4 | 1 | 1 | 2 | 0.6 | |
| planner_historical_signals_for_ir_hashsrc/connection_execute.rs:670 | fn | 16 | 1 | 1 | 4 | 0.6 | |
| resolve_ir_hash_or_fetchsrc/connection_execute.rs:1286 | fn | 30 | 4 | 1 | 2 | 0.6 | |
| apply_planning_success_ratesrc/connection_execute.rs:1390 | fn | 5 | 3 | 1 | 0 | 0.6 | |
| apply_planning_replan_ratesrc/connection_execute.rs:1396 | fn | 7 | 2 | 1 | 0 | 0.6 | |
| apply_planning_io_waitsrc/connection_execute.rs:1404 | fn | 8 | 2 | 1 | 0 | 0.6 | |
| apply_planning_hotspot_ratesrc/connection_execute.rs:1413 | fn | 7 | 2 | 1 | 0 | 0.6 | |
| apply_planning_tail_ratiosrc/connection_execute.rs:1421 | fn | 9 | 2 | 1 | 0 | 0.6 | |
| apply_planning_error_ratesrc/connection_execute.rs:1431 | fn | 8 | 2 | 1 | 0 | 0.6 | |
| apply_planning_cache_ratesrc/connection_execute.rs:1440 | fn | 6 | 2 | 1 | 0 | 0.6 | |
| broadcast_attestationsrc/connection_execute.rs:335 | fn | 68 | 7 | 1 | 5 | 0.5 | |
| cache_execute_resultsrc/connection_execute.rs:1829 | fn | 51 | 4 | 1 | 1 | 0.5 | |
| record_execute_observationsrc/connection_execute.rs:1902 | fn | 35 | 1 | 1 | 2 | 0.5 | |
| execute_local_quorum_statussrc/connection_execute.rs:1938 | fn | 11 | 1 | 1 | 1 | 0.5 | |
| record_execute_runtime_metricssrc/connection_execute.rs:1950 | fn | 51 | 1 | 1 | 12 | 0.5 | |
| has_existing_bindingsrc/connection_execute.rs:54 | fn | 6 | 1 | 1 | 0 | 0.5 | |
| upsert_create_app_manifestsrc/connection_execute.rs:167 | fn | 24 | 2 | 1 | 2 | 0.5 | |
| existing_protocol_for_createsrc/connection_execute.rs:192 | fn | 6 | 1 | 1 | 1 | 0.5 | |
| create_catalog_countssrc/connection_execute.rs:199 | fn | 4 | 1 | 1 | 1 | 0.5 | |
| protocol_create_success_responsesrc/connection_execute.rs:204 | fn | 20 | 1 | 1 | 0 | 0.5 | |
| load_planner_feedback_for_protocolsrc/connection_execute.rs:415 | fn | 4 | 1 | 1 | 2 | 0.5 | |
| hypergraph_planning_snapshot_for_executesrc/connection_execute.rs:799 | fn | 67 | 11 | 1 | 6 | 0.5 | |
| peer_estimates_for_ir_hashsrc/connection_execute.rs:867 | fn | 79 | 11 | 1 | 2 | 0.5 | |
| execute_min_peers_requiredsrc/connection_execute.rs:1354 | fn | 11 | 1 | 1 | 0 | 0.5 | |
| apply_execute_planning_snapshotsrc/connection_execute.rs:1366 | fn | 23 | 3 | 1 | 7 | 0.5 | |
| append_execute_planner_outcomesrc/connection_execute.rs:2002 | fn | 64 | 3 | 1 | 5 | 0.5 | |
| update_execute_runtime_contributorssrc/connection_execute.rs:2067 | fn | 49 | 5 | 1 | 4 | 0.5 | |
| execute_runtime_metricssrc/connection_execute.rs:2117 | fn | 25 | 3 | 1 | 0 | 0.5 | |
| invocation_id_for_tracesrc/connection_execute.rs:1192 | fn | 3 | 1 | 1 | 0 | 0.5 | |
| prepare_execute_targetsrc/connection_execute.rs:1240 | fn | 45 | 4 | 1 | 6 | 0.5 | |
| plan_protocol_executionsrc/connection_execute.rs:1317 | fn | 36 | 2 | 1 | 11 | 0.5 | |
| record_initial_execute_plansrc/connection_execute.rs:1447 | fn | 28 | 1 | 1 | 5 | 0.5 | |
| execute_protocol_plansrc/connection_execute.rs:1476 | fn | 35 | 2 | 1 | 5 | 0.5 | |
| register_execute_receipt_aliasessrc/connection_execute.rs:1743 | fn | 8 | 5 | 1 | 1 | 0.5 | |
| checkpoint_execute_memorysrc/connection_execute.rs:1752 | fn | 16 | 2 | 1 | 2 | 0.5 | |
| finish_protocol_executionsrc/connection_execute.rs:1769 | fn | 59 | 3 | 1 | 9 | 0.5 | |
| append_execute_summary_diagnosticssrc/connection_execute.rs:2143 | fn | 31 | 4 | 1 | 0 | 0.5 | |
| build_protocol_execute_responsesrc/connection_execute.rs:2175 | fn | 24 | 1 | 1 | 0 | 0.5 | |
| protocol_list_responsesrc/connection_execute.rs:71 | fn | 9 | 1 | 0 | 1 | 0.5 | |
| protocol_create_responsesrc/connection_execute.rs:225 | fn | 46 | 4 | 0 | 9 | 0.5 | |
| protocol_detail_responsesrc/connection_execute.rs:1044 | fn | 64 | 1 | 0 | 4 | 0.5 | |
| protocol_similar_responsesrc/connection_execute.rs:1109 | fn | 22 | 1 | 0 | 1 | 0.5 | |
| protocol_execute_responsesrc/connection_execute.rs:1132 | fn | 57 | 3 | 0 | 11 | 0.5 | |
| execute_planner_payloadsrc/connection_execute.rs:2200 | fn | 31 | 1 | 0 | 0 | 0.5 | |
| execute_planner_hypergraph_payloadsrc/connection_execute.rs:2232 | fn | 20 | 1 | 0 | 0 | 0.5 | |
| execute_receipt_payloadsrc/connection_execute.rs:2253 | fn | 19 | 1 | 0 | 0 | 0.5 | |
| execute_consensus_payloadsrc/connection_execute.rs:2273 | fn | 9 | 1 | 0 | 0 | 0.5 | |
| protocol_symbol_using_responsesrc/connection_execute.rs:2283 | fn | 15 | 1 | 0 | 1 | 0.5 | |
| protocol_prove_responsesrc/connection_execute.rs:2301 | fn | 65 | 3 | 0 | 5 | 0.5 | |
| protocol_verify_responsesrc/connection_execute.rs:2420 | fn | 15 | 2 | 0 | 2 | 0.5 | |
| protocol_get_action_responsesrc/connection_execute.rs:2466 | fn | 7 | 1 | 0 | 1 | 0.5 | |
| protocol_graph_patch_responsesrc/connection_execute.rs:2552 | fn | 6 | 1 | 0 | 1 | 0.5 | |
| create_conflict_response_rejects_existing_protocol_without_overwritesrc/connection_execute.rs:2583 | fn | 11 | 1 | 0 | 2 | 0.5 | |
| create_conflict_response_requires_explicit_version_changesrc/connection_execute.rs:2596 | fn | 15 | 1 | 0 | 2 | 0.5 | |
| create_conflict_response_requires_owner_revision_for_version_changesrc/connection_execute.rs:2613 | fn | 15 | 1 | 0 | 2 | 0.5 | |
| create_conflict_response_allows_same_version_or_authorized_version_changesrc/connection_execute.rs:2630 | fn | 11 | 1 | 0 | 2 | 0.5 |
Source not readable from this process.