1 viewer
rust 1,859,968 · typescript 235,218 · javascript 132,952 · python 20,426 · 6,406 files · digest c536f05fc420 · built in 1.4 s · crystals off
crates/cre8-app-compute/src/compute_market_authority.rs
Items
const COMPUTE_MARKET_LOTS_TABLE struct AuthenticatedComputeMarketBuyer impl AuthenticatedComputeMarketBuyer struct AuthenticatedComputeMarketExecutor impl AuthenticatedComputeMarketExecutor enum ComputeMarketLotAuthorityError type ComputeMarketLotAuthorityResult trait ComputeMarketAuthorityClock struct PlatformComputeMarketAuthorityClock impl ComputeMarketAuthorityClock for PlatformComputeMarketAuthorityClock trait ComputeMarketLotAuthority struct SqliteComputeMarketLotAuthority impl SqliteComputeMarketLotAuthority impl ComputeMarketLotAuthority for SqliteComputeMarketLotAuthority struct PersistedLotFields impl PersistedLotFields static NEXT_TEST_DB struct TestComputeMarketClock impl TestComputeMarketClock impl ComputeMarketAuthorityClock for TestComputeMarketClock
Functions
By call-graph weight (PageRank; 1.0 is the average function). 85 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| storage_errorsrc/compute_market_authority.rs:1120 | fn | 3 | 1 | 21 | 0 | 5 | |
| canonical_trusted_identitysrc/compute_market_authority.rs:1100 | fn | 7 | 3 | 2 | 0 | 4.1 | |
| AuthenticatedComputeMarketBuyer::from_authenticated_sessionsrc/compute_market_authority.rs:58 | method | 12 | 1 | 5 | 1 | 2.6 | |
| AuthenticatedComputeMarketBuyer::payer_account_idsrc/compute_market_authority.rs:75 | method | 3 | 1 | 16 | 0 | 2.3 | |
| SqliteComputeMarketLotAuthority::observesrc/compute_market_authority.rs:754 | trait impl | 16 | 1 | 5 | 4 | 2.1 | |
| SqliteComputeMarketLotAuthority::compare_and_swapsrc/compute_market_authority.rs:693 | method | 42 | 6 | 7 | 5 | 2.1 | |
| buyer_namedsrc/compute_market_authority.rs:1221 | fn | 3 | 1 | 7 | 1 | 1.9 | |
| cleanupsrc/compute_market_authority.rs:1211 | fn | 5 | 2 | 17 | 0 | 1.7 | |
| AuthenticatedComputeMarketExecutor::from_authenticated_sessionsrc/compute_market_authority.rs:89 | method | 12 | 1 | 6 | 1 | 1.7 | |
| lot_forsrc/compute_market_authority.rs:1294 | fn | 22 | 1 | 5 | 3 | 1.5 | |
| SqliteComputeMarketLotAuthority::from_shared_truthsrc/compute_market_authority.rs:418 | method | 3 | 1 | 10 | 2 | 1.5 | |
| require_canonical_lot_idsrc/compute_market_authority.rs:1108 | fn | 7 | 3 | 3 | 0 | 1.5 | |
| SqliteComputeMarketLotAuthority::from_shared_truth_with_clocksrc/compute_market_authority.rs:422 | method | 11 | 2 | 3 | 0 | 1.4 | |
| authoritysrc/compute_market_authority.rs:1201 | fn | 9 | 1 | 15 | 5 | 1.4 | |
| PersistedLotFields::insert_paramssrc/compute_market_authority.rs:951 | method | 18 | 1 | 2 | 0 | 1.3 | |
| SqliteComputeMarketLotAuthority::observe_funding_authorizationsrc/compute_market_authority.rs:582 | method | 23 | 1 | 3 | 4 | 1.3 | |
| PersistedLotFields::from_lotsrc/compute_market_authority.rs:930 | method | 20 | 1 | 6 | 4 | 1.3 | |
| AuthenticatedComputeMarketExecutor::payout_account_idsrc/compute_market_authority.rs:106 | method | 3 | 1 | 10 | 0 | 1.3 | |
| stored_mismatchsrc/compute_market_authority.rs:1124 | fn | 3 | 1 | 4 | 0 | 1.2 | |
| stored_textsrc/compute_market_authority.rs:1128 | fn | 4 | 1 | 4 | 2 | 1.2 | |
| fused_reservationsrc/compute_market_authority.rs:1234 | fn | 43 | 1 | 7 | 3 | 1.2 | |
| SqliteComputeMarketLotAuthority::compute_premium_owner_competitorsrc/compute_market_authority.rs:659 | method | 33 | 4 | 3 | 5 | 1.2 | |
| same_immutable_termssrc/compute_market_authority.rs:1046 | fn | 12 | 10 | 3 | 0 | 1.1 | |
| configured_compute_market_lot_authoritysrc/compute_market_authority.rs:155 | fn | 18 | 3 | 2 | 4 | 1.1 | |
| buyersrc/compute_market_authority.rs:1217 | fn | 3 | 1 | 9 | 1 | 1 | |
| stored_lot_from_rowsrc/compute_market_authority.rs:991 | fn | 54 | 15 | 1 | 7 | 0.9 | |
| SqliteComputeMarketLotAuthority::reserve_with_execution_requestsrc/compute_market_authority.rs:298 | method | 95 | 18 | 1 | 11 | 0.9 | |
| SqliteComputeMarketLotAuthority::begin_execution_after_fundingsrc/compute_market_authority.rs:397 | method | 20 | 4 | 1 | 3 | 0.9 | |
| SqliteComputeMarketLotAuthority::begin_funding_with_authorizationsrc/compute_market_authority.rs:509 | method | 72 | 15 | 1 | 8 | 0.9 | |
| TestComputeMarketClock::newsrc/compute_market_authority.rs:1178 | method | 3 | 1 | 3 | 0 | 0.8 | |
| SqliteComputeMarketLotAuthority::reconcile_transitionsrc/compute_market_authority.rs:736 | method | 11 | 4 | 1 | 1 | 0.8 | |
| test_db_pathsrc/compute_market_authority.rs:1193 | fn | 7 | 1 | 2 | 0 | 0.8 | |
| lotsrc/compute_market_authority.rs:1230 | fn | 3 | 1 | 5 | 1 | 0.8 | |
| retains_compute_premium_ownershipsrc/compute_market_authority.rs:1063 | fn | 13 | 2 | 2 | 0 | 0.8 | |
| fee_kind_textsrc/compute_market_authority.rs:1077 | fn | 8 | 4 | 1 | 0 | 0.8 | |
| state_textsrc/compute_market_authority.rs:1086 | fn | 13 | 9 | 1 | 0 | 0.8 | |
| sqlite_i64src/compute_market_authority.rs:1116 | fn | 3 | 1 | 1 | 0 | 0.8 | |
| TestComputeMarketClock::set_now_mssrc/compute_market_authority.rs:1182 | method | 3 | 1 | 5 | 0 | 0.8 | |
| fused_reservesrc/compute_market_authority.rs:1278 | fn | 15 | 1 | 4 | 2 | 0.7 | |
| executorsrc/compute_market_authority.rs:1225 | fn | 4 | 1 | 4 | 1 | 0.7 | |
| SqliteComputeMarketLotAuthority::insert_if_absentsrc/compute_market_authority.rs:606 | method | 30 | 7 | 1 | 6 | 0.6 | |
| AuthenticatedComputeMarketBuyer::transport_peer_idsrc/compute_market_authority.rs:71 | method | 3 | 1 | 2 | 0 | 0.6 | |
| stored_i64src/compute_market_authority.rs:1133 | fn | 3 | 1 | 1 | 2 | 0.6 | |
| stored_opt_textsrc/compute_market_authority.rs:1137 | fn | 13 | 3 | 1 | 3 | 0.6 | |
| stored_opt_i64src/compute_market_authority.rs:1151 | fn | 9 | 3 | 1 | 3 | 0.6 | |
| SqliteComputeMarketLotAuthority::reconcile_reservationsrc/compute_market_authority.rs:637 | method | 7 | 4 | 1 | 1 | 0.6 | |
| SqliteComputeMarketLotAuthority::reject_competing_compute_premium_ownersrc/compute_market_authority.rs:645 | method | 13 | 2 | 1 | 1 | 0.6 | |
| SqliteComputeMarketLotAuthority::expiresrc/compute_market_authority.rs:905 | trait impl | 5 | 1 | 1 | 1 | 0.6 | |
| paid_legacy_lot_forsrc/compute_market_authority.rs:1319 | fn | 18 | 1 | 1 | 2 | 0.5 | |
| AuthenticatedComputeMarketExecutor::peer_idsrc/compute_market_authority.rs:102 | method | 3 | 1 | 0 | 0 | 0.5 | |
| PlatformComputeMarketAuthorityClock::now_mssrc/compute_market_authority.rs:184 | trait impl | 3 | 1 | 0 | 1 | 0.5 | |
| SqliteComputeMarketLotAuthority::truthsrc/compute_market_authority.rs:434 | method | 3 | 1 | 0 | 0 | 0.5 | |
| SqliteComputeMarketLotAuthority::ensure_schemasrc/compute_market_authority.rs:438 | method | 66 | 2 | 0 | 4 | 0.5 | |
| SqliteComputeMarketLotAuthority::authority_backendsrc/compute_market_authority.rs:750 | trait impl | 3 | 1 | 0 | 0 | 0.5 | |
| SqliteComputeMarketLotAuthority::observe_execution_requestsrc/compute_market_authority.rs:771 | trait impl | 7 | 1 | 0 | 1 | 0.5 | |
| SqliteComputeMarketLotAuthority::reserve_with_execution_requestsrc/compute_market_authority.rs:779 | trait impl | 19 | 1 | 0 | 1 | 0.5 | |
| SqliteComputeMarketLotAuthority::begin_funding_with_authorizationsrc/compute_market_authority.rs:799 | trait impl | 13 | 1 | 0 | 1 | 0.5 | |
| SqliteComputeMarketLotAuthority::observe_funding_authorizationsrc/compute_market_authority.rs:813 | trait impl | 6 | 1 | 0 | 1 | 0.5 | |
| SqliteComputeMarketLotAuthority::begin_execution_after_fundingsrc/compute_market_authority.rs:820 | trait impl | 7 | 1 | 0 | 1 | 0.5 | |
| SqliteComputeMarketLotAuthority::reservesrc/compute_market_authority.rs:828 | trait impl | 16 | 3 | 0 | 3 | 0.5 | |
| SqliteComputeMarketLotAuthority::acceptsrc/compute_market_authority.rs:845 | trait impl | 17 | 1 | 0 | 4 | 0.5 | |
| SqliteComputeMarketLotAuthority::begin_executionsrc/compute_market_authority.rs:864 | trait impl | 10 | 1 | 0 | 4 | 0.5 | |
| SqliteComputeMarketLotAuthority::begin_fundingsrc/compute_market_authority.rs:876 | trait impl | 12 | 1 | 0 | 6 | 0.5 | |
| SqliteComputeMarketLotAuthority::begin_funding_expirysrc/compute_market_authority.rs:889 | trait impl | 5 | 1 | 0 | 1 | 0.5 | |
| SqliteComputeMarketLotAuthority::refundsrc/compute_market_authority.rs:895 | trait impl | 9 | 1 | 0 | 3 | 0.5 | |
| PersistedLotFields::insert_statementsrc/compute_market_authority.rs:970 | method | 13 | 1 | 0 | 1 | 0.5 | |
| PersistedLotFields::cas_paramssrc/compute_market_authority.rs:984 | method | 5 | 1 | 0 | 1 | 0.5 | |
| TestComputeMarketClock::now_mssrc/compute_market_authority.rs:1188 | trait impl | 3 | 1 | 0 | 0 | 0.5 | |
| concurrent_accept_has_one_winner_and_exact_cas_guardsrc/compute_market_authority.rs:1339 | fn | 26 | 2 | 0 | 7 | 0.5 | |
| exact_retries_reconcile_and_reopen_preserves_canonical_lotsrc/compute_market_authority.rs:1367 | fn | 14 | 1 | 0 | 7 | 0.5 | |
| fused_reserve_rolls_back_request_when_lot_insert_abortssrc/compute_market_authority.rs:1383 | fn | 24 | 1 | 0 | 7 | 0.5 | |
| fused_reserve_heals_an_identical_standalone_request_orphansrc/compute_market_authority.rs:1409 | fn | 18 | 1 | 0 | 6 | 0.5 | |
| fused_reserve_rejects_a_conflicting_orphan_without_creating_a_lotsrc/compute_market_authority.rs:1429 | fn | 27 | 1 | 0 | 8 | 0.5 | |
| concurrent_exact_fused_reserve_retries_converge_on_both_rowssrc/compute_market_authority.rs:1458 | fn | 16 | 1 | 0 | 6 | 0.5 | |
| concurrent_competing_fused_reservations_commit_one_complete_owner_onlysrc/compute_market_authority.rs:1476 | fn | 21 | 2 | 0 | 7 | 0.5 | |
| competing_fused_reserve_leaves_no_orphan_then_reclaims_expired_ownersrc/compute_market_authority.rs:1499 | fn | 32 | 1 | 0 | 8 | 0.5 | |
| competing_fused_reserve_reclaims_expired_accepted_ownersrc/compute_market_authority.rs:1533 | fn | 21 | 1 | 0 | 8 | 0.5 | |
| fused_reserve_rechecks_authority_clock_before_durable_insertsrc/compute_market_authority.rs:1556 | fn | 17 | 1 | 0 | 7 | 0.5 | |
| v2_storage_is_not_guessed_as_v3src/compute_market_authority.rs:1575 | fn | 34 | 1 | 0 | 5 | 0.5 | |
| compute_premium_owner_has_one_buyer_obligation_per_work_keysrc/compute_market_authority.rs:1611 | fn | 24 | 1 | 0 | 8 | 0.5 | |
| reopened_paid_legacy_premium_keeps_work_key_ownershipsrc/compute_market_authority.rs:1637 | fn | 39 | 1 | 0 | 11 | 0.5 | |
| concurrent_competing_compute_premium_reservations_have_one_ownersrc/compute_market_authority.rs:1678 | fn | 26 | 1 | 0 | 6 | 0.5 | |
| trusted_identities_and_expiry_are_fail_closedsrc/compute_market_authority.rs:1706 | fn | 46 | 1 | 0 | 11 | 0.5 | |
| materialized_column_tampering_is_rejected_on_observesrc/compute_market_authority.rs:1754 | fn | 17 | 1 | 0 | 6 | 0.5 | |
| non_sqlite_truth_is_rejectedsrc/compute_market_authority.rs:1773 | fn | 11 | 1 | 0 | 2 | 0.5 |
Source not readable from this process.