Skip to content
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-capitalstrategy/src/capture_preregistration_quorum_store.rs

cre8-app-capitalstrategy · module capture_preregistration_quorum_store · src · 1,729 lines (1,556 code, 83 comment) · sha e9f1096412323847

Items

const RECEIVER_STATE_SCHEMA const STORED_RECEIPT_SCHEMA const DURABLE_ADMISSION_SCHEMA const RECEIVER_STATE_KIND const STORED_RECEIPT_KIND const DURABLE_ADMISSION_KIND const SECURE_RECEIVER_ENV const SECURE_RECEIVER_SERVICE_KIND const SECURE_RECEIVER_SNAPSHOT_FILE const SECURE_RECEIVER_WAL_FILE const MAX_PEER_RECEIPT_BYTES const MAX_QUORUM_RECEIPTS const MAX_TRUSTED_IDENTITIES const MAX_IDENTITY_BYTES const MAX_PUBLIC_KEY_B64_BYTES const MAX_SIGNATURE_B64_BYTES const MAX_TRUST_CONTEXT_BYTES struct PeerReceiptSubmission impl PeerReceiptSubmission struct StoredPeerReceiptAck struct QuorumAuthorityBoundary impl QuorumAuthorityBoundary struct DurableVerificationContext impl DurableVerificationContext struct DurableQuorumAdmission enum QuorumStoreError impl Display for QuorumStoreError impl Error for QuorumStoreError struct ReceiverState struct StoredPeerReceipt struct VerificationContextHashPayload struct AggregateHashPayload struct SecureReceiverAuthorityBoundary impl SecureReceiverAuthorityBoundary struct SecurePeerReceiptResponse const NOW_MS

Functions

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

functionkindlinescyclomaticcallerscalleesweightcrystal
stable_vertex_idsrc/capture_preregistration_quorum_store.rs:509fn92312.9
require_non_emptysrc/capture_preregistration_quorum_store.rs:329fn32102.3
require_bounded_textsrc/capture_preregistration_quorum_store.rs:333fn164612.2
verification_context_snapshot_sha256src/capture_preregistration_quorum_store.rs:487fn211211.9
submissionsrc/capture_preregistration_quorum_store.rs:1251fn151341.7
commitmentssrc/capture_preregistration_quorum_store.rs:1242fn81901.3
state_vertex_idsrc/capture_preregistration_quorum_store.rs:519fn31311.2
load_durable_quorum_admissionsrc/capture_preregistration_quorum_store.rs:1045fn138295101.1
DurableVerificationContext::recompute_snapshot_sha256src/capture_preregistration_quorum_store.rs:186method101211.1
read_valuesrc/capture_preregistration_quorum_store.rs:537fn41401.1
persist_received_peer_receiptsrc/capture_preregistration_quorum_store.rs:644fn624671.1
PeerReceiptSubmission::with_arrival_sequencesrc/capture_preregistration_quorum_store.rs:93method121401
verifiersrc/capture_preregistration_quorum_store.rs:1271fn42811
vertexsrc/capture_preregistration_quorum_store.rs:531fn51301
verify_and_persist_quorum_before_observationsrc/capture_preregistration_quorum_store.rs:919fn124129141
raw_submissionsrc/capture_preregistration_quorum_store.rs:1267fn31410.9
require_sha256_hexsrc/capture_preregistration_quorum_store.rs:403fn94300.9
trusted_signerssrc/capture_preregistration_quorum_store.rs:1283fn31810.9
policysrc/capture_preregistration_quorum_store.rs:1287fn31800.9
load_and_reverify_durable_quorum_admissionsrc/capture_preregistration_quorum_store.rs:1190fn363220.9
receipt_vertex_idsrc/capture_preregistration_quorum_store.rs:523fn31410.9
load_receiver_statesrc/capture_preregistration_quorum_store.rs:542fn295520.8
DurableVerificationContext::validate_snapshot_integritysrc/capture_preregistration_quorum_store.rs:201method122230.8
graphsrc/capture_preregistration_quorum_store.rs:1238fn31700.8
trusted_sourcessrc/capture_preregistration_quorum_store.rs:1276fn61710.8
admitted_memory_graphsrc/capture_preregistration_quorum_store.rs:1568fn191380.8
require_trust_context_boundssrc/capture_preregistration_quorum_store.rs:350fn526210.8
admission_vertex_idsrc/capture_preregistration_quorum_store.rs:527fn31410.8
persist_pairsrc/capture_preregistration_quorum_store.rs:1291fn191520.7
validate_submission_fieldssrc/capture_preregistration_quorum_store.rs:413fn102210.7
decode_and_check_stored_receiptsrc/capture_preregistration_quorum_store.rs:577fn6112460.7
QuorumAuthorityBoundary::fail_closedsrc/capture_preregistration_quorum_store.rs:147method181300.7
state_write_opsrc/capture_preregistration_quorum_store.rs:572fn42220.7
secure_receiver_pathssrc/capture_preregistration_quorum_store.rs:763fn142130.6
recompute_aggregate_sha256src/capture_preregistration_quorum_store.rs:443fn181110.6
verification_contextsrc/capture_preregistration_quorum_store.rs:462fn241110.6
install_secure_capture_preregistration_receiversrc/capture_preregistration_quorum_store.rs:798fn11181130.5
SecureReceiverAuthorityBoundary::fail_closedsrc/capture_preregistration_quorum_store.rs:727method171100.5
open_secure_receiver_storesrc/capture_preregistration_quorum_store.rs:779fn111130.5
QuorumStoreError::fmtsrc/capture_preregistration_quorum_store.rs:263trait impl3817000.5
receiver_sequences_raw_bytes_and_quorum_consumption_use_requested_batchessrc/capture_preregistration_quorum_store.rs:1312fn4520110.5
duplicate_receipt_and_consumed_replay_fail_closedsrc/capture_preregistration_quorum_store.rs:1359fn441090.5
verification_failure_mutates_neither_replay_set_nor_observation_barriersrc/capture_preregistration_quorum_store.rs:1405fn2010100.5
mid_batch_admission_collision_rolls_back_receipt_and_state_updatessrc/capture_preregistration_quorum_store.rs:1427fn4510140.5
source_peer_must_be_trusted_and_bound_to_the_signersrc/capture_preregistration_quorum_store.rs:1474fn221080.5
peer_wire_shape_rejects_receiver_sequence_and_authority_fieldssrc/capture_preregistration_quorum_store.rs:1498fn91010.5
peer_payload_and_quorum_inputs_are_hard_boundedsrc/capture_preregistration_quorum_store.rs:1509fn581090.5
admission_reload_rejects_trust_snapshot_and_authority_tamperingsrc/capture_preregistration_quorum_store.rs:1589fn351040.5
admission_reload_is_bound_to_receiver_state_and_consumed_receipt_verticessrc/capture_preregistration_quorum_store.rs:1626fn351050.5
admission_reload_can_reproduce_signature_and_aggregate_verificationsrc/capture_preregistration_quorum_store.rs:1663fn151030.5
file_storage_restart_preserves_receipt_replay_rejection_and_admissionsrc/capture_preregistration_quorum_store.rs:1681fn481090.5

Source not readable from this process.