1 viewer
rust 1,859,748 · typescript 235,215 · javascript 132,932 · python 20,426 · 6,405 files · digest 3ddca2872e6e · built in 1.4 s · crystals off
crates/cre8-app-compute/src/coordinator/dispatch_strategy.rs
Items
Functions
By call-graph weight (PageRank; 1.0 is the average function). 35 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| missing_executor_capabilitiessrc/coordinator/dispatch_strategy.rs:46 | fn | 3 | 1 | 4 | 0 | 3.1 | |
| select_strategysrc/coordinator/dispatch_strategy.rs:251 | fn | 29 | 6 | 16 | 9 | 2.4 | |
| peersrc/coordinator/dispatch_strategy.rs:307 | fn | 14 | 1 | 10 | 0 | 2.1 | |
| requestsrc/coordinator/dispatch_strategy.rs:286 | fn | 20 | 1 | 9 | 0 | 2 | |
| peer_carries_executor_capabilitiessrc/coordinator/dispatch_strategy.rs:50 | fn | 3 | 1 | 2 | 1 | 1.8 | |
| shard_from_peerssrc/coordinator/dispatch_strategy.rs:188 | fn | 4 | 1 | 2 | 0 | 1.4 | |
| strategy_from_decisionsrc/coordinator/dispatch_strategy.rs:203 | fn | 27 | 13 | 5 | 4 | 1.1 | |
| peer_quality_scoresrc/coordinator/dispatch_strategy.rs:21 | fn | 6 | 1 | 1 | 0 | 1.1 | |
| cached_strategysrc/coordinator/dispatch_strategy.rs:28 | fn | 3 | 1 | 2 | 0 | 1 | |
| decisionsrc/coordinator/dispatch_strategy.rs:409 | fn | 14 | 1 | 4 | 0 | 0.9 | |
| peer_withsrc/coordinator/dispatch_strategy.rs:332 | fn | 3 | 1 | 4 | 1 | 0.8 | |
| constrainedsrc/coordinator/dispatch_strategy.rs:336 | fn | 5 | 1 | 4 | 1 | 0.8 | |
| peer_estimatesrc/coordinator/dispatch_strategy.rs:149 | fn | 14 | 1 | 1 | 3 | 0.8 | |
| eligible_peerssrc/coordinator/dispatch_strategy.rs:86 | fn | 11 | 4 | 2 | 1 | 0.8 | |
| selected_shard_peerssrc/coordinator/dispatch_strategy.rs:193 | fn | 9 | 2 | 1 | 0 | 0.7 | |
| fallback_strategysrc/coordinator/dispatch_strategy.rs:231 | fn | 12 | 4 | 1 | 1 | 0.7 | |
| preferred_peer_ranksrc/coordinator/dispatch_strategy.rs:32 | fn | 11 | 1 | 1 | 0 | 0.7 | |
| requester_carries_executor_capabilitiessrc/coordinator/dispatch_strategy.rs:57 | fn | 7 | 2 | 1 | 1 | 0.7 | |
| apply_preferred_peer_filtersrc/coordinator/dispatch_strategy.rs:98 | fn | 11 | 3 | 1 | 0 | 0.7 | |
| sort_capable_peerssrc/coordinator/dispatch_strategy.rs:110 | fn | 16 | 5 | 1 | 1 | 0.7 | |
| build_adaptive_requestsrc/coordinator/dispatch_strategy.rs:164 | fn | 19 | 1 | 1 | 2 | 0.7 | |
| ir_prefers_shardingsrc/coordinator/dispatch_strategy.rs:184 | fn | 3 | 1 | 1 | 0 | 0.7 | |
| peer_network_mssrc/coordinator/dispatch_strategy.rs:127 | fn | 5 | 2 | 1 | 0 | 0.7 | |
| peer_queue_mssrc/coordinator/dispatch_strategy.rs:133 | fn | 7 | 2 | 1 | 0 | 0.7 | |
| peer_reliabilitysrc/coordinator/dispatch_strategy.rs:141 | fn | 7 | 2 | 1 | 0 | 0.7 | |
| local_placement_refusalsrc/coordinator/dispatch_strategy.rs:70 | fn | 13 | 3 | 2 | 1 | 0.6 | |
| required_distribution_does_not_take_small_job_local_shortcutsrc/coordinator/dispatch_strategy.rs:323 | fn | 6 | 1 | 0 | 3 | 0.5 | |
| eligible_peers_exclude_a_peer_missing_any_required_tagsrc/coordinator/dispatch_strategy.rs:343 | fn | 13 | 1 | 0 | 7 | 0.5 | |
| a_constrained_request_is_placed_only_on_a_peer_that_carries_its_tagssrc/coordinator/dispatch_strategy.rs:358 | fn | 11 | 3 | 0 | 4 | 0.5 | |
| the_local_shortcut_needs_the_requester_to_carry_the_tagssrc/coordinator/dispatch_strategy.rs:371 | fn | 17 | 2 | 0 | 5 | 0.5 | |
| with_no_capable_candidate_the_local_fallback_must_be_refusedsrc/coordinator/dispatch_strategy.rs:390 | fn | 18 | 1 | 0 | 6 | 0.5 | |
| strategy_from_decision_maps_cached_delegate_and_gpu_modessrc/coordinator/dispatch_strategy.rs:425 | fn | 23 | 4 | 0 | 4 | 0.5 | |
| strategy_from_decision_uses_selected_shard_peers_when_allowedsrc/coordinator/dispatch_strategy.rs:450 | fn | 19 | 2 | 0 | 4 | 0.5 | |
| strategy_from_decision_falls_back_to_capable_peers_when_targets_are_not_shardablesrc/coordinator/dispatch_strategy.rs:471 | fn | 13 | 2 | 0 | 4 | 0.5 | |
| strategy_from_decision_handles_continuation_and_default_fallbackssrc/coordinator/dispatch_strategy.rs:486 | fn | 27 | 4 | 0 | 4 | 0.5 |
Source not readable from this process.