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/tree_transfer.rs
Items
const TRANSFER_CONTENT_TYPE const TRANSFER_HELLO_JSON_SCHEMA const TRANSFER_TREE_PATH const TRANSFER_PULL_PATH const TRANSFER_RECEIPTS_PATH const ENV_TRANSFER_FAULTS const ENV_TRANSFER_CHUNK_BYTES const ENV_TRANSFER_MAX_RESPONSE_BYTES const ENV_TRANSFER_WIRE const DEFAULT_CHUNK_LEN const DEFAULT_MAX_RESPONSE_BYTES const DEFAULT_MAX_ATTEMPTS const MAX_ATTEMPTS_CAP const RECEIPT_REGISTRY_CAP const PEER_ID_HEADER trait PartBytes struct AtomStoreBytes impl PartBytes for AtomStoreBytes struct TreePart struct TreeParts impl TreeParts struct ReaderPartSource impl ReaderPartSource impl PartSource for ReaderPartSource enum TransferFault impl TransferFault struct CorruptingSource impl PartSource for CorruptingSource struct HelloDecoded struct HelloJson struct ServeOutcome static RECEIPTS trait PartSink struct AtomPartSink impl PartSink for AtomPartSink struct PullWire struct PullOptions impl Default for PullOptions struct PullOutcome struct SinkHeld impl HeldParts for SinkHeld struct SinkPartBytes impl PartBytes for SinkPartBytes struct KindHints impl KindHints struct HttpPullTransport struct PullCallerAuth impl HttpPullTransport struct PullTreeRequest const SERVE_LOCAL_PEER const SERVE_NETWORK const SERVE_CALLER const SERVE_CALLER_SEED struct MemoryTree impl PartBytes for MemoryTree struct MemorySink impl PartSink for MemorySink const TEST_CHUNK_LEN static STORE_LOCK
Functions
By call-graph weight (PageRank; 1.0 is the average function). 93 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| digestsrc/tree_transfer.rs:1583 | fn | 3 | 1 | 6 | 1 | 2.5 | |
| manifest_root_hashsrc/tree_transfer.rs:243 | fn | 13 | 2 | 5 | 3 | 1.7 | |
| pushsrc/tree_transfer.rs:165 | nested fn | 5 | 2 | 7 | 0 | 1.7 | |
| part_id_of_hexsrc/tree_transfer.rs:124 | fn | 3 | 1 | 4 | 0 | 1.5 | |
| frame_namesrc/tree_transfer.rs:403 | fn | 3 | 1 | 2 | 0 | 1.5 | |
| pull_tree_framed_with_sinksrc/tree_transfer.rs:1234 | fn | 80 | 4 | 2 | 9 | 1.5 | |
| build_tree_nsrc/tree_transfer.rs:1775 | fn | 53 | 2 | 2 | 1 | 1.5 | |
| serve_tree_frames_with_basessrc/tree_transfer.rs:492 | fn | 60 | 11 | 3 | 3 | 1.4 | |
| root_hash_of_pairssrc/tree_transfer.rs:230 | fn | 10 | 2 | 2 | 0 | 1.4 | |
| serve_contextsrc/tree_transfer.rs:1602 | fn | 24 | 1 | 8 | 2 | 1.4 | |
| enumerate_tree_partssrc/tree_transfer.rs:155 | fn | 70 | 9 | 12 | 8 | 1.3 | |
| manifest_entriessrc/tree_transfer.rs:128 | fn | 6 | 2 | 3 | 0 | 1.3 | |
| normalize_rel_pathsrc/tree_transfer.rs:226 | fn | 3 | 1 | 2 | 0 | 1.2 | |
| pull_tree_withsrc/tree_transfer.rs:815 | fn | 242 | 43 | 9 | 10 | 1.1 | |
| ReaderPartSource::newsrc/tree_transfer.rs:290 | method | 3 | 1 | 6 | 0 | 1.1 | |
| handle_transfer_treesrc/tree_transfer.rs:1352 | fn | 129 | 17 | 7 | 18 | 1.1 | |
| build_treesrc/tree_transfer.rs:1769 | fn | 3 | 1 | 8 | 1 | 1.1 | |
| decode_hellosrc/tree_transfer.rs:382 | fn | 20 | 5 | 3 | 1 | 1.1 | |
| serve_requestsrc/tree_transfer.rs:1627 | fn | 10 | 1 | 6 | 0 | 1.1 | |
| default_wire_versionsrc/tree_transfer.rs:411 | fn | 7 | 3 | 1 | 1 | 1 | |
| enforcing_envsrc/tree_transfer.rs:1639 | fn | 6 | 1 | 5 | 1 | 1 | |
| PullOptions::defaultsrc/tree_transfer.rs:664 | trait impl | 8 | 1 | 8 | 0 | 1 | |
| receipts_forsrc/tree_transfer.rs:569 | fn | 10 | 1 | 5 | 0 | 1 | |
| directory_root_hashsrc/tree_transfer.rs:259 | fn | 20 | 1 | 3 | 2 | 1 | |
| serve_tree_framessrc/tree_transfer.rs:476 | fn | 11 | 1 | 3 | 1 | 1 | |
| TreeParts::logical_bytessrc/tree_transfer.rs:115 | method | 3 | 1 | 6 | 0 | 0.9 | |
| error_jsonsrc/tree_transfer.rs:1317 | fn | 3 | 1 | 4 | 2 | 0.9 | |
| walksrc/tree_transfer.rs:260 | nested fn | 15 | 4 | 1 | 3 | 0.9 | |
| TreeParts::len_ofsrc/tree_transfer.rs:119 | method | 3 | 1 | 1 | 0 | 0.9 | |
| transfer_pull_responsesrc/tree_transfer.rs:1507 | fn | 13 | 4 | 3 | 4 | 0.9 | |
| serve_withsrc/tree_transfer.rs:1860 | fn | 14 | 3 | 6 | 2 | 0.8 | |
| execute_transfer_pullsrc/tree_transfer.rs:1521 | fn | 33 | 4 | 2 | 4 | 0.8 | |
| recipe_chunk_idssrc/tree_transfer.rs:135 | fn | 17 | 2 | 2 | 0 | 0.8 | |
| assert_sink_holds_every_partsrc/tree_transfer.rs:1875 | fn | 6 | 2 | 5 | 0 | 0.8 | |
| hello_json_bodysrc/tree_transfer.rs:449 | fn | 6 | 1 | 2 | 0 | 0.8 | |
| persist_receiptsrc/tree_transfer.rs:581 | fn | 6 | 1 | 3 | 2 | 0.8 | |
| TransferFault::specsrc/tree_transfer.rs:325 | method | 6 | 2 | 2 | 0 | 0.8 | |
| parse_faultsrc/tree_transfer.rs:333 | fn | 10 | 3 | 2 | 1 | 0.8 | |
| record_receiptsrc/tree_transfer.rs:559 | fn | 9 | 3 | 3 | 0 | 0.7 | |
| hello_from_request_bodysrc/tree_transfer.rs:438 | fn | 10 | 2 | 2 | 0 | 0.7 | |
| pull_tree_framedsrc/tree_transfer.rs:1224 | fn | 6 | 1 | 1 | 1 | 0.7 | |
| max_response_bytessrc/tree_transfer.rs:1060 | fn | 7 | 1 | 1 | 1 | 0.6 | |
| parse_wire_versionsrc/tree_transfer.rs:419 | fn | 9 | 5 | 1 | 1 | 0.6 | |
| HttpPullTransport::newsrc/tree_transfer.rs:1106 | method | 9 | 1 | 1 | 0 | 0.6 | |
| HttpPullTransport::with_caller_authsrc/tree_transfer.rs:1119 | method | 10 | 3 | 1 | 0 | 0.6 | |
| HttpPullTransport::remote_peer_idsrc/tree_transfer.rs:1130 | method | 3 | 1 | 1 | 0 | 0.6 | |
| query_paramsrc/tree_transfer.rs:1321 | fn | 14 | 4 | 2 | 0 | 0.6 | |
| devnet_envsrc/tree_transfer.rs:1646 | fn | 7 | 1 | 1 | 1 | 0.6 | |
| serve_chunk_lensrc/tree_transfer.rs:1068 | fn | 6 | 1 | 2 | 2 | 0.6 | |
| verified_bytes_forsrc/tree_transfer.rs:732 | fn | 7 | 2 | 1 | 1 | 0.6 | |
| KindHints::newsrc/tree_transfer.rs:748 | method | 5 | 1 | 1 | 0 | 0.6 | |
| KindHints::kind_forsrc/tree_transfer.rs:789 | method | 3 | 1 | 1 | 1 | 0.6 | |
| KindHints::known_idssrc/tree_transfer.rs:795 | method | 3 | 1 | 1 | 0 | 0.6 | |
| have_listsrc/tree_transfer.rs:800 | fn | 10 | 2 | 1 | 0 | 0.6 | |
| faults_enabledsrc/tree_transfer.rs:1075 | fn | 4 | 2 | 1 | 1 | 0.5 | |
| is_truthysrc/tree_transfer.rs:1336 | fn | 3 | 2 | 1 | 0 | 0.5 | |
| handle_transfer_pullsrc/tree_transfer.rs:1485 | fn | 19 | 4 | 1 | 4 | 0.5 | |
| handle_transfer_receiptssrc/tree_transfer.rs:1561 | fn | 17 | 2 | 1 | 5 | 0.5 | |
| AtomStoreBytes::part_bytessrc/tree_transfer.rs:89 | trait impl | 3 | 1 | 0 | 1 | 0.5 | |
| TreeParts::descriptorssrc/tree_transfer.rs:111 | method | 3 | 1 | 0 | 0 | 0.5 | |
| ReaderPartSource::read_partsrc/tree_transfer.rs:296 | trait impl | 17 | 2 | 0 | 0 | 0.5 | |
| CorruptingSource::read_partsrc/tree_transfer.rs:351 | trait impl | 10 | 4 | 0 | 0 | 0.5 | |
| AtomPartSink::part_bytessrc/tree_transfer.rs:603 | trait impl | 3 | 1 | 0 | 1 | 0.5 | |
| AtomPartSink::store_partsrc/tree_transfer.rs:607 | trait impl | 8 | 2 | 0 | 1 | 0.5 | |
| AtomPartSink::finishsrc/tree_transfer.rs:616 | trait impl | 21 | 2 | 0 | 2 | 0.5 | |
| SinkHeld::held_bytessrc/tree_transfer.rs:716 | trait impl | 3 | 1 | 0 | 0 | 0.5 | |
| SinkPartBytes::part_bytessrc/tree_transfer.rs:726 | trait impl | 4 | 1 | 0 | 0 | 0.5 | |
| KindHints::learnsrc/tree_transfer.rs:754 | method | 34 | 11 | 0 | 3 | 0.5 | |
| HttpPullTransport::postsrc/tree_transfer.rs:1134 | method | 60 | 10 | 0 | 3 | 0.5 | |
| transfer_connection_requires_authenticated_origin_before_parsingsrc/tree_transfer.rs:1655 | fn | 10 | 1 | 0 | 3 | 0.5 | |
| transfer_connection_preserves_ingest_gatesrc/tree_transfer.rs:1667 | fn | 10 | 1 | 0 | 3 | 0.5 | |
| an_unsigned_caller_is_refused_before_the_body_is_readsrc/tree_transfer.rs:1679 | fn | 9 | 1 | 0 | 4 | 0.5 | |
| a_self_declared_peer_header_is_not_an_identitysrc/tree_transfer.rs:1690 | fn | 6 | 1 | 0 | 4 | 0.5 | |
| a_foreign_signer_is_refused_before_the_body_is_readsrc/tree_transfer.rs:1698 | fn | 19 | 1 | 0 | 5 | 0.5 | |
| a_trusted_signer_reaches_the_body_parsersrc/tree_transfer.rs:1719 | fn | 17 | 1 | 0 | 5 | 0.5 | |
| a_devnet_node_serves_an_unsigned_caller_exactly_as_beforesrc/tree_transfer.rs:1738 | fn | 6 | 1 | 0 | 4 | 0.5 | |
| the_ingest_gate_still_precedes_the_caller_gatesrc/tree_transfer.rs:1746 | fn | 8 | 1 | 0 | 4 | 0.5 | |
| MemoryTree::part_bytessrc/tree_transfer.rs:1764 | trait impl | 3 | 1 | 0 | 0 | 0.5 | |
| MemorySink::part_bytessrc/tree_transfer.rs:1837 | trait impl | 3 | 1 | 0 | 0 | 0.5 | |
| MemorySink::store_partsrc/tree_transfer.rs:1841 | trait impl | 6 | 1 | 0 | 1 | 0.5 | |
| MemorySink::finishsrc/tree_transfer.rs:1848 | trait impl | 6 | 1 | 0 | 1 | 0.5 | |
| enumeration_is_manifest_files_recipes_chunks_deduplicatedsrc/tree_transfer.rs:1883 | fn | 16 | 1 | 0 | 3 | 0.5 | |
| cold_pull_stores_every_partsrc/tree_transfer.rs:1901 | fn | 24 | 2 | 0 | 7 | 0.5 | |
| second_pull_reuses_everything_and_ships_no_payloadsrc/tree_transfer.rs:1927 | fn | 16 | 1 | 0 | 6 | 0.5 | |
| edited_tree_with_new_manifest_ships_only_the_differencesrc/tree_transfer.rs:1945 | fn | 35 | 1 | 0 | 8 | 0.5 | |
| cut_then_resume_takes_two_attempts_and_less_on_the_secondsrc/tree_transfer.rs:1982 | fn | 33 | 1 | 0 | 8 | 0.5 | |
| corrupt_part_is_rejected_then_resent_cleansrc/tree_transfer.rs:2017 | fn | 19 | 1 | 0 | 6 | 0.5 | |
| transport_error_retries_and_gives_up_at_max_attemptssrc/tree_transfer.rs:2038 | fn | 19 | 1 | 0 | 4 | 0.5 | |
| v3_pull_sends_the_part_list_once_and_deltas_a_warm_probesrc/tree_transfer.rs:2063 | fn | 61 | 1 | 0 | 9 | 0.5 | |
| hello_body_accepts_raw_frame_or_json_envelopesrc/tree_transfer.rs:2126 | fn | 17 | 1 | 0 | 3 | 0.5 | |
| fault_specs_round_tripsrc/tree_transfer.rs:2145 | fn | 8 | 1 | 0 | 2 | 0.5 | |
| manifest_and_directory_root_hashes_agree_on_a_byte_exact_restoresrc/tree_transfer.rs:2155 | fn | 18 | 1 | 0 | 2 | 0.5 | |
| atom_store_source_and_sink_round_trip_in_a_temp_storesrc/tree_transfer.rs:2175 | fn | 37 | 2 | 0 | 8 | 0.5 |
Source not readable from this process.