1 viewer
rust 1,847,276 · typescript 232,434 · javascript 131,064 · python 19,227 · 6,362 files · digest fa0546eddd29 · built in 1.5 s · crystals off
crates/cre8-app-conduit/src/peer_relay.rs
Items
const BATCH_INTERVAL const MAX_BATCH_BYTES const BACKLOG_DROP_BYTES const TAP_CAPACITY const RECV_POLL const BACKOFF_START const BACKOFF_MAX const MAX_ERROR_CHARS const MAX_RELAYS struct RelayAuth impl Debug for RelayAuth impl RelayAuth struct RelayStats impl RelayStats struct RelayEntry impl RelayEntry type RelayKey static RELAYS const INTERNAL_HOSTNAMES const INTERNAL_PEER_REFUSAL static LOCK struct SeenRequest struct FakePeer impl FakePeer impl Drop for FakePeer
Functions
By call-graph weight (PageRank; 1.0 is the average function). 68 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| RelayAuth::headerssrc/peer_relay.rs:131 | method | 10 | 3 | 6 | 0 | 3 | |
| address_is_internalsrc/peer_relay.rs:497 | fn | 19 | 13 | 2 | 0 | 2.3 | |
| guard_peer_destinationsrc/peer_relay.rs:532 | fn | 27 | 9 | 3 | 1 | 1.8 | |
| RelayAuth::is_emptysrc/peer_relay.rs:126 | method | 3 | 2 | 1 | 0 | 1.3 | |
| slugifysrc/peer_relay.rs:603 | fn | 3 | 1 | 2 | 1 | 1.3 | |
| sample_avccsrc/peer_relay.rs:1093 | fn | 11 | 1 | 2 | 0 | 1.2 | |
| FakePeer::start_failingsrc/peer_relay.rs:956 | method | 26 | 5 | 3 | 2 | 1.2 | |
| validate_peer_urlsrc/peer_relay.rs:447 | fn | 22 | 8 | 4 | 2 | 1.2 | |
| with_relayssrc/peer_relay.rs:237 | fn | 4 | 1 | 5 | 1 | 1.1 | |
| post_jsonsrc/peer_relay.rs:771 | fn | 12 | 2 | 2 | 5 | 1.1 | |
| FakePeer::requestssrc/peer_relay.rs:983 | method | 3 | 1 | 3 | 1 | 1.1 | |
| ingest_stream_idsrc/peer_relay.rs:617 | fn | 3 | 1 | 6 | 0 | 1.1 | |
| serve_onesrc/peer_relay.rs:1023 | fn | 54 | 11 | 1 | 3 | 1 | |
| guard_credential_transportsrc/peer_relay.rs:576 | fn | 16 | 5 | 2 | 1 | 0.9 | |
| annexb_has_parameter_setssrc/peer_relay.rs:624 | fn | 18 | 5 | 2 | 0 | 0.9 | |
| RelayAuth::describesrc/peer_relay.rs:143 | method | 3 | 2 | 1 | 1 | 0.9 | |
| handle_requestsrc/peer_relay.rs:253 | fn | 24 | 5 | 3 | 5 | 0.9 | |
| RelayEntry::visible_tosrc/peer_relay.rs:200 | method | 6 | 2 | 2 | 0 | 0.9 | |
| refusal_reasonsrc/peer_relay.rs:757 | fn | 10 | 5 | 3 | 0 | 0.9 | |
| derive_target_channelsrc/peer_relay.rs:610 | fn | 3 | 1 | 3 | 1 | 0.9 | |
| avcc_parameter_setssrc/peer_relay.rs:650 | fn | 28 | 5 | 1 | 0 | 0.8 | |
| RelayStats::startingsrc/peer_relay.rs:164 | method | 3 | 1 | 3 | 0 | 0.8 | |
| header_valuesrc/peer_relay.rs:1013 | fn | 9 | 1 | 1 | 0 | 0.8 | |
| egresssrc/peer_relay.rs:746 | fn | 3 | 1 | 2 | 1 | 0.8 | |
| string_fieldsrc/peer_relay.rs:440 | fn | 3 | 1 | 3 | 0 | 0.7 | |
| guard_peer_url_destinationsrc/peer_relay.rs:594 | fn | 6 | 2 | 2 | 2 | 0.7 | |
| add_responsesrc/peer_relay.rs:282 | fn | 79 | 11 | 2 | 19 | 0.7 | |
| video_payloadsrc/peer_relay.rs:682 | fn | 12 | 3 | 2 | 2 | 0.7 | |
| video_unitsrc/peer_relay.rs:1078 | fn | 13 | 1 | 4 | 1 | 0.7 | |
| test_entrysrc/peer_relay.rs:1116 | fn | 15 | 1 | 3 | 3 | 0.7 | |
| RelayStats::note_errorsrc/peer_relay.rs:168 | method | 6 | 1 | 2 | 0 | 0.7 | |
| relay_registry_locksrc/peer_relay.rs:922 | fn | 4 | 1 | 2 | 1 | 0.7 | |
| frame_for_unitsrc/peer_relay.rs:700 | fn | 24 | 2 | 3 | 7 | 0.7 | |
| audio_unitsrc/peer_relay.rs:1105 | fn | 10 | 1 | 3 | 0 | 0.7 | |
| post_batchsrc/peer_relay.rs:785 | fn | 13 | 2 | 2 | 6 | 0.7 | |
| remove_responsesrc/peer_relay.rs:362 | fn | 28 | 4 | 1 | 7 | 0.7 | |
| list_responsesrc/peer_relay.rs:391 | fn | 6 | 1 | 1 | 2 | 0.7 | |
| status_responsesrc/peer_relay.rs:398 | fn | 23 | 3 | 1 | 4 | 0.7 | |
| FakePeer::startsrc/peer_relay.rs:950 | method | 3 | 1 | 2 | 1 | 0.6 | |
| collapse_to_last_keyframesrc/peer_relay.rs:728 | fn | 11 | 3 | 2 | 0 | 0.6 | |
| unit_is_protectedsrc/peer_relay.rs:908 | fn | 3 | 2 | 2 | 1 | 0.6 | |
| stop_relaysrc/peer_relay.rs:425 | fn | 12 | 2 | 2 | 4 | 0.6 | |
| drive_relaysrc/peer_relay.rs:824 | fn | 82 | 13 | 3 | 10 | 0.6 | |
| failuresrc/peer_relay.rs:278 | fn | 3 | 1 | 2 | 0 | 0.6 | |
| FakePeer::wait_forsrc/peer_relay.rs:992 | method | 13 | 3 | 2 | 1 | 0.6 | |
| batch_bytessrc/peer_relay.rs:740 | fn | 3 | 1 | 1 | 0 | 0.5 | |
| start_peer_channelsrc/peer_relay.rs:805 | fn | 14 | 2 | 1 | 1 | 0.5 | |
| FakePeer::ingest_failures_leftsrc/peer_relay.rs:987 | method | 3 | 1 | 1 | 1 | 0.5 | |
| peer_relay_enabledsrc/peer_relay.rs:94 | fn | 3 | 1 | 1 | 0 | 0.5 | |
| RelayAuth::from_inputsrc/peer_relay.rs:116 | method | 9 | 1 | 1 | 0 | 0.5 | |
| private_peers_allowedsrc/peer_relay.rs:476 | fn | 6 | 1 | 1 | 1 | 0.5 | |
| RelayAuth::fmtsrc/peer_relay.rs:110 | trait impl | 3 | 1 | 0 | 1 | 0.5 | |
| RelayEntry::telemetrysrc/peer_relay.rs:207 | method | 24 | 1 | 0 | 1 | 0.5 | |
| FakePeer::dropsrc/peer_relay.rs:1008 | trait impl | 3 | 1 | 0 | 0 | 0.5 | |
| wire_batch_round_trips_into_the_ingest_contractsrc/peer_relay.rs:1137 | fn | 26 | 1 | 0 | 8 | 0.5 | |
| keyframes_carry_parameter_setssrc/peer_relay.rs:1168 | fn | 12 | 1 | 0 | 3 | 0.5 | |
| relay_registers_pushes_and_stops_on_the_peersrc/peer_relay.rs:1185 | fn | 57 | 2 | 0 | 11 | 0.5 | |
| failed_batches_are_retried_from_the_last_keyframesrc/peer_relay.rs:1247 | fn | 23 | 2 | 0 | 10 | 0.5 | |
| collapse_keeps_the_last_keyframe_and_counts_the_restsrc/peer_relay.rs:1273 | fn | 24 | 1 | 0 | 6 | 0.5 | |
| peer_url_validation_refuses_credentials_and_foreign_schemessrc/peer_relay.rs:1302 | fn | 10 | 1 | 0 | 1 | 0.5 | |
| internal_destinations_are_refused_unless_the_operator_opts_insrc/peer_relay.rs:1318 | fn | 36 | 2 | 0 | 2 | 0.5 | |
| a_peers_response_body_never_reaches_telemetrysrc/peer_relay.rs:1360 | fn | 14 | 1 | 0 | 4 | 0.5 | |
| relay_auth_debug_prints_the_shape_not_the_secretsrc/peer_relay.rs:1378 | fn | 9 | 1 | 0 | 0 | 0.5 | |
| target_channel_defaults_to_the_source_handlesrc/peer_relay.rs:1391 | fn | 9 | 1 | 0 | 3 | 0.5 | |
| add_and_remove_are_a_lifecyclesrc/peer_relay.rs:1404 | fn | 51 | 2 | 0 | 4 | 0.5 | |
| the_relay_registry_refuses_past_its_capsrc/peer_relay.rs:1461 | fn | 42 | 3 | 0 | 6 | 0.5 | |
| a_credential_never_rides_plaintext_to_a_remote_peersrc/peer_relay.rs:1508 | fn | 15 | 2 | 0 | 1 | 0.5 | |
| unsupported_operations_are_reportedsrc/peer_relay.rs:1526 | fn | 7 | 1 | 0 | 2 | 0.5 |
Source not readable from this process.