Skip to content
1 viewer

rust 1,859,968 · typescript 235,218 · javascript 132,952 · python 20,426 · 6,406 files · digest c536f05fc420 · built in 1.4 s · crystals off

crates/cre8-app-voice/src/federation_gossip.rs

cre8-app-voice · module federation_gossip · src · 521 lines (347 code, 106 comment) · sha 1d655549c0582abc

Items

const ENV_PEERS const ENV_INTERVAL const ENV_LIMIT const DEFAULT_INTERVAL_SECS const DEFAULT_LIMIT const MAX_PULL_RESPONSE_BYTES static LAST_SEEN_NS static SPAWNED static PULLS_TOTAL static IMPORTS_TOTAL static SKIPPED_TOTAL struct GossipStats static TICKS_TOTAL

Functions

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

functionkindlinescyclomaticcallerscalleesweightcrystal
parse_peerssrc/federation_gossip.rs:100fn114402.3
last_seen_mapsrc/federation_gossip.rs:60fn31201.9
take_values_from_responsesrc/federation_gossip.rs:306fn101301.7
jitter_from_nanossrc/federation_gossip.rs:133fn92301.6
takesrc/federation_gossip.rs:367fn121201.4
peers_from_envsrc/federation_gossip.rs:93fn31321.3
pull_from_peersrc/federation_gossip.rs:236fn212181.2
ensure_spawnedsrc/federation_gossip.rs:169fn353261.2
decode_voice_take_envelopessrc/federation_gossip.rs:317fn31201.1
should_pull_sincesrc/federation_gossip.rs:148fn32201
peer_pull_urlsrc/federation_gossip.rs:258fn31201
interval_secssrc/federation_gossip.rs:112fn31211
run_gossip_passsrc/federation_gossip.rs:221fn141141
envelope_is_newer_than_watermarksrc/federation_gossip.rs:159fn31301
max_envelope_timestampsrc/federation_gossip.rs:321fn31301
decode_peer_takes_bodysrc/federation_gossip.rs:294fn112221
statssrc/federation_gossip.rs:82fn101220.9
limit_per_pullsrc/federation_gossip.rs:116fn31210.9
gossip_ticksrc/federation_gossip.rs:208fn62210.9
envelopesrc/federation_gossip.rs:518fn31210.8
last_seen_forsrc/federation_gossip.rs:349fn31210.8
record_last_seensrc/federation_gossip.rs:353fn83210.8
fetch_peer_response_bodysrc/federation_gossip.rs:267fn263120.8
tick_jittersrc/federation_gossip.rs:127fn31120.7
fetch_peer_envelopessrc/federation_gossip.rs:262fn41120.6
import_peer_envelopessrc/federation_gossip.rs:325fn233110.6
peer_pull_url_uses_since_and_limit_query_paramssrc/federation_gossip.rs:381fn31010.5
take_values_prefers_wrapped_connection_takessrc/federation_gossip.rs:386fn111010.5
take_values_falls_back_to_top_level_takessrc/federation_gossip.rs:399fn81010.5
decode_voice_takes_skips_invalid_envelopessrc/federation_gossip.rs:409fn91020.5
decode_peer_takes_body_handles_wrapped_json_and_bad_jsonsrc/federation_gossip.rs:420fn101020.5
record_last_seen_only_moves_forwardsrc/federation_gossip.rs:432fn81020.5
parse_peers_trims_strips_slash_and_drops_emptiessrc/federation_gossip.rs:444fn41010.5
parse_peers_dedups_preserving_first_seen_ordersrc/federation_gossip.rs:450fn61010.5
parse_peers_empty_input_is_empty_listsrc/federation_gossip.rs:458fn41010.5
should_pull_since_is_none_on_first_pull_then_watermarksrc/federation_gossip.rs:466fn61010.5
envelope_is_newer_than_watermark_keeps_equal_and_greatersrc/federation_gossip.rs:474fn101020.5
watermark_filter_dedups_already_pulled_takessrc/federation_gossip.rs:486fn131030.5
jitter_from_nanos_stays_within_ten_percent_boundsrc/federation_gossip.rs:503fn82010.5
jitter_from_nanos_is_zero_for_tiny_intervalssrc/federation_gossip.rs:513fn41010.5

Source not readable from this process.