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-network-client/src/traffic.rs

cre8-app-network-client · module traffic · src · 1,380 lines (898 code, 370 comment) · sha 876a53e24163c2b3

Items

const PER_PEER_CAP const WINDOW_SECONDS const PER_CLASS_CAP const PEER_INTERN_CAP const DATA_CREDIT_ENABLED_ENV const DATA_CREDIT_QUANTUM_ENV const DATA_CREDIT_QUANTUM_BYTES const DATA_CREDIT_MIN_QUANTUM_BYTES const DATA_CREDIT_MAX_QUANTA_PER_MINT const DATA_CREDIT_ROW_CAP const DATA_CREDIT_ASSET_PREFIX const DATA_CONSUME_ASSET_PREFIX enum TrafficDirection enum EgressRole struct WindowBucket struct PeerTraffic struct ClassTraffic struct DataCreditRow impl DataCreditRow struct DataCreditQuantum impl DataCreditQuantum struct TrafficLedger impl TrafficLedger static LEDGER static TABLE

Functions

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

functionkindlinescyclomaticcallerscalleesweightcrystal
TrafficLedger::recordsrc/traffic.rs:260method3551644.5
traffic_ledgersrc/traffic.rs:569fn41924.4
TrafficLedger::newsrc/traffic.rs:246method1311404
record_egresssrc/traffic.rs:605fn41533.8
record_response_bytessrc/traffic.rs:707fn82433.2
record_served_egresssrc/traffic.rs:618fn41633.1
data_credit_keysrc/traffic.rs:565fn31302.2
TrafficLedger::evict_oldest_peersrc/traffic.rs:483method102101.9
peer_intern_tablesrc/traffic.rs:716fn41101.8
TrafficLedger::window_totalssrc/traffic.rs:494method123201.8
record_ingress_bytessrc/traffic.rs:589fn73331.7
TrafficLedger::attribute_peersrc/traffic.rs:326method124211.7
DataCreditRow::pending_bytessrc/traffic.rs:193method31101.7
intern_peer_idsrc/traffic.rs:725fn164211.6
TrafficLedger::record_windowsrc/traffic.rs:296method124101.4
TrafficLedger::record_classsrc/traffic.rs:309method134101.4
TrafficLedger::accrue_data_creditsrc/traffic.rs:343method174121.4
TrafficLedger::data_credit_totalssrc/traffic.rs:423method112411.4
current_request_classsrc/traffic.rs:675fn31101.4
current_request_peersrc/traffic.rs:698fn31101.4
TrafficLedger::to_jsonsrc/traffic.rs:507method541511.4
data_credit_quantum_bytessrc/traffic.rs:770fn31911.3
traffic_status_jsonsrc/traffic.rs:753fn41431.3
TrafficLedger::due_data_creditsrc/traffic.rs:376method242701.2
TrafficLedger::mark_data_creditsrc/traffic.rs:411method72611.2
request_class_for_pathsrc/traffic.rs:639fn102301.2
TrafficLedger::evict_oldest_data_credit_rowsrc/traffic.rs:361method102101.1
DataCreditQuantum::through_quantumsrc/traffic.rs:220method31601
pending_data_creditsrc/traffic.rs:786fn82741
set_request_peersrc/traffic.rs:693fn41400.9
set_request_classsrc/traffic.rs:671fn31500.9
data_credit_enabledsrc/traffic.rs:763fn31310.9
attribute_peer_ingresssrc/traffic.rs:628fn82230.9
TrafficLedger::data_credit_jsonsrc/traffic.rs:435method471310.8
mark_data_credit_settledsrc/traffic.rs:800fn41220.7
data_credit_status_jsonsrc/traffic.rs:807fn51230.6
record_ingresssrc/traffic.rs:581fn41230.6
DataCreditQuantum::bytessrc/traffic.rs:225method31000.5
ledger_accumulates_totals_classes_and_peerssrc/traffic.rs:818fn371030.5
window_rolls_off_bytes_older_than_sixty_secondssrc/traffic.rs:857fn161030.5
per_peer_map_evicts_oldest_seen_at_capsrc/traffic.rs:875fn182020.5
class_map_folds_overflow_into_othersrc/traffic.rs:895fn122020.5
status_json_matches_contract_shapesrc/traffic.rs:909fn132020.5
global_record_helpers_feed_the_shared_ledgersrc/traffic.rs:924fn171050.5
data_credit_needs_a_whole_quantum_before_anything_is_duesrc/traffic.rs:945fn451040.5
data_credit_high_water_mark_prevents_recrediting_the_same_bytessrc/traffic.rs:994fn261060.5
data_credit_splits_by_class_and_caps_one_settlesrc/traffic.rs:1024fn301050.5
data_credit_rows_evict_the_least_recently_served_at_capsrc/traffic.rs:1056fn202030.5
data_credit_block_rides_the_status_contractsrc/traffic.rs:1078fn331050.5
resolved_but_unpaid_batches_report_as_skipped_not_creditedsrc/traffic.rs:1117fn231060.5
a_restart_drops_the_accumulator_with_its_high_water_marksrc/traffic.rs:1147fn241060.5
data_credit_kill_switch_and_quantum_override_read_envsrc/traffic.rs:1175fn371080.5
request_class_derives_from_first_path_segmentsrc/traffic.rs:1214fn71010.5
peer_intern_dedupes_and_rejects_emptysrc/traffic.rs:1223fn61010.5
response_bytes_use_thread_local_classsrc/traffic.rs:1231fn111030.5
response_bytes_accrue_data_credit_for_a_stamped_peersrc/traffic.rs:1251fn232060.5
clearing_the_peer_stamp_makes_the_next_response_anonymoussrc/traffic.rs:1278fn161060.5
pushed_egress_is_metered_but_only_served_egress_earnssrc/traffic.rs:1304fn471050.5
the_public_helpers_pick_the_role_their_names_promisesrc/traffic.rs:1356fn241060.5

Source not readable from this process.