1 viewer
rust 1,961,941 · typescript 233,850 · javascript 141,145 · python 22,871 · 6,801 files · digest 6d882eacc8db · built in 12.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 const GATED_BATCH_PASS_TTL_MS const GATED_RELAY_SUBJECT 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). 75 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| RelayAuth::headerssrc/peer_relay.rs:154 | method | 10 | 3 | 6 | 0 | 3 | |
| address_is_internalsrc/peer_relay.rs:542 | fn | 19 | 13 | 2 | 0 | 2.3 | |
| secure_or_loopbacksrc/peer_relay.rs:634 | fn | 13 | 4 | 2 | 1 | 1.9 | |
| guard_peer_destinationsrc/peer_relay.rs:577 | fn | 27 | 9 | 3 | 1 | 1.8 | |
| slugifysrc/peer_relay.rs:658 | fn | 3 | 1 | 3 | 1 | 1.5 | |
| RelayAuth::is_emptysrc/peer_relay.rs:149 | method | 3 | 2 | 1 | 0 | 1.3 | |
| sample_avccsrc/peer_relay.rs:1192 | fn | 11 | 1 | 2 | 0 | 1.2 | |
| FakePeer::start_failingsrc/peer_relay.rs:1054 | method | 26 | 5 | 3 | 2 | 1.2 | |
| validate_peer_urlsrc/peer_relay.rs:492 | fn | 22 | 8 | 4 | 2 | 1.2 | |
| ingest_stream_idsrc/peer_relay.rs:672 | fn | 3 | 1 | 6 | 0 | 1.1 | |
| FakePeer::requestssrc/peer_relay.rs:1081 | method | 3 | 1 | 4 | 1 | 1.1 | |
| with_relayssrc/peer_relay.rs:266 | fn | 4 | 1 | 5 | 1 | 1.1 | |
| post_jsonsrc/peer_relay.rs:861 | fn | 12 | 2 | 2 | 5 | 1.1 | |
| serve_onesrc/peer_relay.rs:1121 | fn | 55 | 11 | 1 | 3 | 1 | |
| derive_target_channelsrc/peer_relay.rs:665 | fn | 3 | 1 | 3 | 1 | 1 | |
| guard_credential_transportsrc/peer_relay.rs:621 | fn | 6 | 2 | 2 | 1 | 0.9 | |
| annexb_has_parameter_setssrc/peer_relay.rs:714 | fn | 18 | 5 | 2 | 0 | 0.9 | |
| RelayAuth::describesrc/peer_relay.rs:166 | method | 3 | 2 | 1 | 1 | 0.9 | |
| handle_requestsrc/peer_relay.rs:282 | fn | 24 | 5 | 3 | 5 | 0.9 | |
| RelayEntry::visible_tosrc/peer_relay.rs:228 | method | 6 | 2 | 2 | 0 | 0.9 | |
| RelayEntry::gatedsrc/peer_relay.rs:220 | method | 3 | 1 | 3 | 1 | 0.9 | |
| refusal_reasonsrc/peer_relay.rs:847 | fn | 10 | 5 | 3 | 0 | 0.9 | |
| RelayStats::startingsrc/peer_relay.rs:187 | method | 3 | 1 | 4 | 0 | 0.8 | |
| avcc_parameter_setssrc/peer_relay.rs:740 | fn | 28 | 5 | 1 | 0 | 0.8 | |
| header_valuesrc/peer_relay.rs:1111 | fn | 9 | 1 | 1 | 0 | 0.8 | |
| egresssrc/peer_relay.rs:836 | fn | 3 | 1 | 2 | 1 | 0.8 | |
| string_fieldsrc/peer_relay.rs:485 | fn | 3 | 1 | 3 | 0 | 0.7 | |
| guard_pass_transportsrc/peer_relay.rs:630 | fn | 3 | 1 | 2 | 1 | 0.7 | |
| guard_peer_url_destinationsrc/peer_relay.rs:649 | fn | 6 | 2 | 2 | 2 | 0.7 | |
| relay_targetsrc/peer_relay.rs:682 | fn | 17 | 5 | 2 | 5 | 0.7 | |
| video_unitsrc/peer_relay.rs:1177 | fn | 13 | 1 | 5 | 1 | 0.7 | |
| add_responsesrc/peer_relay.rs:311 | fn | 90 | 14 | 2 | 23 | 0.7 | |
| video_payloadsrc/peer_relay.rs:772 | fn | 12 | 3 | 2 | 2 | 0.7 | |
| test_entrysrc/peer_relay.rs:1215 | fn | 15 | 1 | 4 | 3 | 0.7 | |
| relay_registry_locksrc/peer_relay.rs:1019 | fn | 4 | 1 | 2 | 1 | 0.7 | |
| FakePeer::startsrc/peer_relay.rs:1048 | method | 3 | 1 | 3 | 1 | 0.7 | |
| frame_for_unitsrc/peer_relay.rs:790 | fn | 24 | 2 | 3 | 7 | 0.7 | |
| audio_unitsrc/peer_relay.rs:1204 | fn | 10 | 1 | 3 | 0 | 0.7 | |
| RelayStats::note_errorsrc/peer_relay.rs:191 | method | 6 | 1 | 2 | 0 | 0.6 | |
| remove_responsesrc/peer_relay.rs:402 | fn | 28 | 4 | 1 | 7 | 0.6 | |
| list_responsesrc/peer_relay.rs:431 | fn | 6 | 1 | 1 | 2 | 0.6 | |
| status_responsesrc/peer_relay.rs:438 | fn | 23 | 3 | 1 | 4 | 0.6 | |
| post_batchsrc/peer_relay.rs:875 | fn | 16 | 3 | 2 | 7 | 0.6 | |
| stop_relaysrc/peer_relay.rs:465 | fn | 17 | 3 | 3 | 5 | 0.6 | |
| drive_relaysrc/peer_relay.rs:917 | fn | 86 | 15 | 4 | 11 | 0.6 | |
| collapse_to_last_keyframesrc/peer_relay.rs:818 | fn | 11 | 3 | 2 | 0 | 0.6 | |
| unit_is_protectedsrc/peer_relay.rs:1005 | fn | 3 | 2 | 2 | 1 | 0.6 | |
| FakePeer::wait_forsrc/peer_relay.rs:1090 | method | 13 | 3 | 3 | 1 | 0.6 | |
| batch_passsrc/peer_relay.rs:702 | fn | 8 | 2 | 2 | 2 | 0.6 | |
| failuresrc/peer_relay.rs:307 | fn | 3 | 1 | 2 | 0 | 0.6 | |
| batch_bytessrc/peer_relay.rs:830 | fn | 3 | 1 | 1 | 0 | 0.5 | |
| start_peer_channelsrc/peer_relay.rs:898 | fn | 14 | 2 | 1 | 1 | 0.5 | |
| FakePeer::ingest_failures_leftsrc/peer_relay.rs:1085 | method | 3 | 1 | 1 | 1 | 0.5 | |
| peer_relay_enabledsrc/peer_relay.rs:117 | fn | 3 | 1 | 1 | 0 | 0.5 | |
| RelayAuth::from_inputsrc/peer_relay.rs:139 | method | 9 | 1 | 1 | 0 | 0.5 | |
| private_peers_allowedsrc/peer_relay.rs:521 | fn | 6 | 1 | 1 | 1 | 0.5 | |
| RelayAuth::fmtsrc/peer_relay.rs:133 | trait impl | 3 | 1 | 0 | 1 | 0.5 | |
| RelayEntry::telemetrysrc/peer_relay.rs:235 | method | 25 | 1 | 0 | 1 | 0.5 | |
| FakePeer::dropsrc/peer_relay.rs:1106 | trait impl | 3 | 1 | 0 | 0 | 0.5 | |
| wire_batch_round_trips_into_the_ingest_contractsrc/peer_relay.rs:1236 | fn | 26 | 1 | 0 | 8 | 0.5 | |
| keyframes_carry_parameter_setssrc/peer_relay.rs:1267 | fn | 12 | 1 | 0 | 3 | 0.5 | |
| relay_registers_pushes_and_stops_on_the_peersrc/peer_relay.rs:1284 | fn | 57 | 2 | 0 | 11 | 0.5 | |
| failed_batches_are_retried_from_the_last_keyframesrc/peer_relay.rs:1346 | fn | 23 | 2 | 0 | 10 | 0.5 | |
| collapse_keeps_the_last_keyframe_and_counts_the_restsrc/peer_relay.rs:1372 | fn | 24 | 1 | 0 | 6 | 0.5 | |
| peer_url_validation_refuses_credentials_and_foreign_schemessrc/peer_relay.rs:1401 | fn | 10 | 1 | 0 | 1 | 0.5 | |
| internal_destinations_are_refused_unless_the_operator_opts_insrc/peer_relay.rs:1417 | fn | 36 | 2 | 0 | 2 | 0.5 | |
| a_peers_response_body_never_reaches_telemetrysrc/peer_relay.rs:1459 | fn | 14 | 1 | 0 | 4 | 0.5 | |
| relay_auth_debug_prints_the_shape_not_the_secretsrc/peer_relay.rs:1477 | fn | 9 | 1 | 0 | 0 | 0.5 | |
| target_channel_defaults_to_the_source_handlesrc/peer_relay.rs:1490 | fn | 9 | 1 | 0 | 3 | 0.5 | |
| a_private_channel_relays_under_its_own_namesrc/peer_relay.rs:1502 | fn | 12 | 1 | 0 | 2 | 0.5 | |
| a_private_relay_is_unlisted_and_carries_a_pass_on_every_batchsrc/peer_relay.rs:1519 | fn | 44 | 3 | 0 | 14 | 0.5 | |
| add_and_remove_are_a_lifecyclesrc/peer_relay.rs:1567 | fn | 51 | 2 | 0 | 4 | 0.5 | |
| the_relay_registry_refuses_past_its_capsrc/peer_relay.rs:1624 | fn | 42 | 3 | 0 | 6 | 0.5 | |
| a_credential_never_rides_plaintext_to_a_remote_peersrc/peer_relay.rs:1671 | fn | 15 | 2 | 0 | 1 | 0.5 | |
| unsupported_operations_are_reportedsrc/peer_relay.rs:1689 | fn | 7 | 1 | 0 | 2 | 0.5 |
Source not readable from this process.