Skip to content
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-compute-core/src/discovery.rs

cre8-app-compute-core · module discovery · src · 1,046 lines (809 code, 92 comment) · sha 2a8d7d73e7cceeaf

Items

struct PeerInfo struct DiscoveryStats struct PeerDiscovery impl PeerDiscovery static DISC

Functions

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

functionkindlinescyclomaticcallerscalleesweightcrystal
now_unixsrc/discovery.rs:513fn311117.1
PeerDiscovery::newsrc/discovery.rs:98method311505.4
global_discoverysrc/discovery.rs:227fn2811613.8
make_peersrc/discovery.rs:523fn2211713.6
make_localsrc/discovery.rs:546fn312112.2
PeerDiscovery::registersrc/discovery.rs:109method621702.1
handle_discoversrc/discovery.rs:270fn564431.5
init_global_discoverysrc/discovery.rs:259fn621021.3
PeerDiscovery::merge_gossipsrc/discovery.rs:158method155501.2
PeerDiscovery::gossip_payloadsrc/discovery.rs:139method153411.2
handle_gossip_exchangesrc/discovery.rs:374fn141231.1
PeerDiscovery::sync_to_contextsrc/discovery.rs:181method74201
sync_discovery_to_peer_endpointssrc/discovery.rs:505fn52221
PeerDiscovery::peer_mutsrc/discovery.rs:212method31300.9
PeerDiscovery::evict_stalesrc/discovery.rs:117method41310.9
PeerDiscovery::peer_idssrc/discovery.rs:217method31200.9
PeerDiscovery::healthy_peerssrc/discovery.rs:123method31200.9
PeerDiscovery::statssrc/discovery.rs:190method101210.8
PeerDiscovery::endpoint_forsrc/discovery.rs:175method31500.8
healthy_gossip_targetssrc/discovery.rs:435fn153220.8
post_gossipsrc/discovery.rs:478fn132270.7
bootstrap_discoverysrc/discovery.rs:394fn263360.7
evict_stale_peerssrc/discovery.rs:429fn52220.7
gossip_payload_and_targetssrc/discovery.rs:451fn41230.7
PeerDiscovery::with_ttlsrc/discovery.rs:103method41300.7
gossip_ticksrc/discovery.rs:492fn102330.6
mark_peer_unhealthysrc/discovery.rs:456fn62220.6
merge_gossip_responsesrc/discovery.rs:463fn142240.6
spawn_json_serversrc/discovery.rs:550fn242210.6
handle_peers_listsrc/discovery.rs:328fn421120.6
PeerDiscovery::peers_for_languagesrc/discovery.rs:133method32100.6
PeerDiscovery::peers_with_gpusrc/discovery.rs:128method32100.5
PeerDiscovery::seedssrc/discovery.rs:202method31100.5
PeerDiscovery::local_infosrc/discovery.rs:207method31100.5
test_register_and_lookupsrc/discovery.rs:576fn81050.5
test_register_skips_selfsrc/discovery.rs:586fn61030.5
test_evict_stalesrc/discovery.rs:594fn101070.5
test_evict_keeps_freshsrc/discovery.rs:606fn61060.5
test_healthy_peers_filtersrc/discovery.rs:614fn121050.5
test_peers_for_languagesrc/discovery.rs:628fn161050.5
test_gpu_peer_filter_and_accessorssrc/discovery.rs:646fn341090.5
test_gossip_payload_excludes_stalesrc/discovery.rs:682fn151070.5
test_merge_gossip_dedupsrc/discovery.rs:699fn211060.5
test_healthy_gossip_targets_choose_three_and_skip_bad_peerssrc/discovery.rs:722fn203050.5
test_merge_gossip_skips_selfsrc/discovery.rs:744fn61030.5
test_sync_to_contextsrc/discovery.rs:752fn171050.5
test_global_wrappers_sync_evict_targets_and_merge_responsesrc/discovery.rs:771fn5830120.5
test_gossip_tick_without_targets_only_evictssrc/discovery.rs:831fn211070.5
test_post_gossip_marks_peer_unhealthy_for_invalid_endpointsrc/discovery.rs:854fn111060.5
test_gossip_tick_merges_successful_local_responsesrc/discovery.rs:867fn221080.5
test_bootstrap_with_unreachable_seedsrc/discovery.rs:891fn101030.5
test_bootstrap_discovery_merges_successful_seed_responsesrc/discovery.rs:903fn141060.5
test_statssrc/discovery.rs:919fn121050.5
test_handle_discover_routesrc/discovery.rs:933fn111010.5
test_handle_discover_records_gpu_fields_and_peers_listsrc/discovery.rs:946fn491040.5
test_handle_discover_explicit_gpu_capable_overrides_native_gpu_tagsrc/discovery.rs:997fn131040.5
test_handle_discover_missing_peer_idsrc/discovery.rs:1012fn41010.5
test_handle_gossip_exchange_routesrc/discovery.rs:1018fn181010.5
test_handle_gossip_exchange_tolerates_invalid_peer_payloadsrc/discovery.rs:1038fn81030.5

Source not readable from this process.