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-compute/src/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/market_authority.rs:1120 | fn | 3 | 1 | 21 | 0 | 5 | |
| canonical_trusted_identitysrc/market_authority.rs:1100 | fn | 7 | 3 | 2 | 0 | 4.1 | |
| AuthenticatedComputeMarketBuyer::from_authenticated_sessionsrc/market_authority.rs:58 | method | 12 | 1 | 5 | 1 | 2.6 | |
| AuthenticatedComputeMarketBuyer::payer_account_idsrc/market_authority.rs:75 | method | 3 | 1 | 16 | 0 | 2.2 | |
| SqliteComputeMarketLotAuthority::observesrc/market_authority.rs:754 | trait impl | 16 | 1 | 5 | 4 | 2.1 | |
| SqliteComputeMarketLotAuthority::compare_and_swapsrc/market_authority.rs:693 | method | 42 | 6 | 7 | 5 | 2.1 | |
| buyer_namedsrc/market_authority.rs:1221 | fn | 3 | 1 | 7 | 1 | 1.9 | |
| cleanupsrc/market_authority.rs:1211 | fn | 5 | 2 | 17 | 0 | 1.7 | |
| AuthenticatedComputeMarketExecutor::from_authenticated_sessionsrc/market_authority.rs:89 | method | 12 | 1 | 6 | 1 | 1.6 | |
| lot_forsrc/market_authority.rs:1294 | fn | 22 | 1 | 5 | 3 | 1.5 | |
| SqliteComputeMarketLotAuthority::from_shared_truthsrc/market_authority.rs:418 | method | 3 | 1 | 10 | 2 | 1.5 | |
| require_canonical_lot_idsrc/market_authority.rs:1108 | fn | 7 | 3 | 3 | 0 | 1.5 | |
| SqliteComputeMarketLotAuthority::from_shared_truth_with_clocksrc/market_authority.rs:422 | method | 11 | 2 | 3 | 0 | 1.4 | |
| authoritysrc/market_authority.rs:1201 | fn | 9 | 1 | 15 | 5 | 1.4 | |
| PersistedLotFields::insert_paramssrc/market_authority.rs:951 | method | 18 | 1 | 2 | 0 | 1.3 | |
| SqliteComputeMarketLotAuthority::observe_funding_authorizationsrc/market_authority.rs:582 | method | 23 | 1 | 3 | 4 | 1.3 | |
| PersistedLotFields::from_lotsrc/market_authority.rs:930 | method | 20 | 1 | 6 | 4 | 1.3 | |
| AuthenticatedComputeMarketExecutor::payout_account_idsrc/market_authority.rs:106 | method | 3 | 1 | 10 | 0 | 1.2 | |
| stored_mismatchsrc/market_authority.rs:1124 | fn | 3 | 1 | 4 | 0 | 1.2 | |
| stored_textsrc/market_authority.rs:1128 | fn | 4 | 1 | 4 | 2 | 1.2 | |
| fused_reservationsrc/market_authority.rs:1234 | fn | 43 | 1 | 7 | 3 | 1.1 | |
| SqliteComputeMarketLotAuthority::compute_premium_owner_competitorsrc/market_authority.rs:659 | method | 33 | 4 | 3 | 5 | 1.1 | |
| same_immutable_termssrc/market_authority.rs:1046 | fn | 12 | 10 | 3 | 0 | 1.1 | |
| configured_compute_market_lot_authoritysrc/market_authority.rs:155 | fn | 18 | 3 | 2 | 4 | 1.1 | |
| buyersrc/market_authority.rs:1217 | fn | 3 | 1 | 9 | 1 | 1 | |
| stored_lot_from_rowsrc/market_authority.rs:991 | fn | 54 | 15 | 1 | 7 | 0.9 | |
| SqliteComputeMarketLotAuthority::reserve_with_execution_requestsrc/market_authority.rs:298 | method | 95 | 18 | 1 | 11 | 0.9 | |
| SqliteComputeMarketLotAuthority::begin_execution_after_fundingsrc/market_authority.rs:397 | method | 20 | 4 | 1 | 3 | 0.9 | |
| SqliteComputeMarketLotAuthority::begin_funding_with_authorizationsrc/market_authority.rs:509 | method | 72 | 15 | 1 | 8 | 0.9 | |
| TestComputeMarketClock::newsrc/market_authority.rs:1178 | method | 3 | 1 | 3 | 0 | 0.8 | |
| SqliteComputeMarketLotAuthority::reconcile_transitionsrc/market_authority.rs:736 | method | 11 | 4 | 1 | 1 | 0.8 | |
| test_db_pathsrc/market_authority.rs:1193 | fn | 7 | 1 | 2 | 0 | 0.8 | |
| lotsrc/market_authority.rs:1230 | fn | 3 | 1 | 5 | 1 | 0.8 | |
| retains_compute_premium_ownershipsrc/market_authority.rs:1063 | fn | 13 | 2 | 2 | 0 | 0.8 | |
| fee_kind_textsrc/market_authority.rs:1077 | fn | 8 | 4 | 1 | 0 | 0.8 | |
| state_textsrc/market_authority.rs:1086 | fn | 13 | 9 | 1 | 0 | 0.8 | |
| sqlite_i64src/market_authority.rs:1116 | fn | 3 | 1 | 1 | 0 | 0.8 | |
| TestComputeMarketClock::set_now_mssrc/market_authority.rs:1182 | method | 3 | 1 | 5 | 0 | 0.7 | |
| fused_reservesrc/market_authority.rs:1278 | fn | 15 | 1 | 4 | 2 | 0.7 | |
| executorsrc/market_authority.rs:1225 | fn | 4 | 1 | 4 | 1 | 0.7 | |
| SqliteComputeMarketLotAuthority::insert_if_absentsrc/market_authority.rs:606 | method | 30 | 7 | 1 | 6 | 0.6 | |
| AuthenticatedComputeMarketBuyer::transport_peer_idsrc/market_authority.rs:71 | method | 3 | 1 | 2 | 0 | 0.6 | |
| stored_i64src/market_authority.rs:1133 | fn | 3 | 1 | 1 | 2 | 0.6 | |
| stored_opt_textsrc/market_authority.rs:1137 | fn | 13 | 3 | 1 | 3 | 0.6 | |
| stored_opt_i64src/market_authority.rs:1151 | fn | 9 | 3 | 1 | 3 | 0.6 | |
| SqliteComputeMarketLotAuthority::reconcile_reservationsrc/market_authority.rs:637 | method | 7 | 4 | 1 | 1 | 0.6 | |
| SqliteComputeMarketLotAuthority::reject_competing_compute_premium_ownersrc/market_authority.rs:645 | method | 13 | 2 | 1 | 1 | 0.6 | |
| SqliteComputeMarketLotAuthority::expiresrc/market_authority.rs:905 | trait impl | 5 | 1 | 1 | 1 | 0.6 | |
| paid_legacy_lot_forsrc/market_authority.rs:1319 | fn | 18 | 1 | 1 | 2 | 0.5 | |
| AuthenticatedComputeMarketExecutor::peer_idsrc/market_authority.rs:102 | method | 3 | 1 | 0 | 0 | 0.5 | |
| PlatformComputeMarketAuthorityClock::now_mssrc/market_authority.rs:184 | trait impl | 3 | 1 | 0 | 1 | 0.5 | |
| SqliteComputeMarketLotAuthority::truthsrc/market_authority.rs:434 | method | 3 | 1 | 0 | 0 | 0.5 | |
| SqliteComputeMarketLotAuthority::ensure_schemasrc/market_authority.rs:438 | method | 66 | 2 | 0 | 4 | 0.5 | |
| SqliteComputeMarketLotAuthority::authority_backendsrc/market_authority.rs:750 | trait impl | 3 | 1 | 0 | 0 | 0.5 | |
| SqliteComputeMarketLotAuthority::observe_execution_requestsrc/market_authority.rs:771 | trait impl | 7 | 1 | 0 | 1 | 0.5 | |
| SqliteComputeMarketLotAuthority::reserve_with_execution_requestsrc/market_authority.rs:779 | trait impl | 19 | 1 | 0 | 1 | 0.5 | |
| SqliteComputeMarketLotAuthority::begin_funding_with_authorizationsrc/market_authority.rs:799 | trait impl | 13 | 1 | 0 | 1 | 0.5 | |
| SqliteComputeMarketLotAuthority::observe_funding_authorizationsrc/market_authority.rs:813 | trait impl | 6 | 1 | 0 | 1 | 0.5 | |
| SqliteComputeMarketLotAuthority::begin_execution_after_fundingsrc/market_authority.rs:820 | trait impl | 7 | 1 | 0 | 1 | 0.5 | |
| SqliteComputeMarketLotAuthority::reservesrc/market_authority.rs:828 | trait impl | 16 | 3 | 0 | 3 | 0.5 | |
| SqliteComputeMarketLotAuthority::acceptsrc/market_authority.rs:845 | trait impl | 17 | 1 | 0 | 4 | 0.5 | |
| SqliteComputeMarketLotAuthority::begin_executionsrc/market_authority.rs:864 | trait impl | 10 | 1 | 0 | 4 | 0.5 | |
| SqliteComputeMarketLotAuthority::begin_fundingsrc/market_authority.rs:876 | trait impl | 12 | 1 | 0 | 6 | 0.5 | |
| SqliteComputeMarketLotAuthority::begin_funding_expirysrc/market_authority.rs:889 | trait impl | 5 | 1 | 0 | 1 | 0.5 | |
| SqliteComputeMarketLotAuthority::refundsrc/market_authority.rs:895 | trait impl | 9 | 1 | 0 | 3 | 0.5 | |
| PersistedLotFields::insert_statementsrc/market_authority.rs:970 | method | 13 | 1 | 0 | 1 | 0.5 | |
| PersistedLotFields::cas_paramssrc/market_authority.rs:984 | method | 5 | 1 | 0 | 1 | 0.5 | |
| TestComputeMarketClock::now_mssrc/market_authority.rs:1188 | trait impl | 3 | 1 | 0 | 0 | 0.5 | |
| concurrent_accept_has_one_winner_and_exact_cas_guardsrc/market_authority.rs:1339 | fn | 26 | 2 | 0 | 7 | 0.5 | |
| exact_retries_reconcile_and_reopen_preserves_canonical_lotsrc/market_authority.rs:1367 | fn | 14 | 1 | 0 | 7 | 0.5 | |
| fused_reserve_rolls_back_request_when_lot_insert_abortssrc/market_authority.rs:1383 | fn | 24 | 1 | 0 | 7 | 0.5 | |
| fused_reserve_heals_an_identical_standalone_request_orphansrc/market_authority.rs:1409 | fn | 18 | 1 | 0 | 6 | 0.5 | |
| fused_reserve_rejects_a_conflicting_orphan_without_creating_a_lotsrc/market_authority.rs:1429 | fn | 27 | 1 | 0 | 8 | 0.5 | |
| concurrent_exact_fused_reserve_retries_converge_on_both_rowssrc/market_authority.rs:1458 | fn | 16 | 1 | 0 | 6 | 0.5 | |
| concurrent_competing_fused_reservations_commit_one_complete_owner_onlysrc/market_authority.rs:1476 | fn | 21 | 2 | 0 | 7 | 0.5 | |
| competing_fused_reserve_leaves_no_orphan_then_reclaims_expired_ownersrc/market_authority.rs:1499 | fn | 32 | 1 | 0 | 8 | 0.5 | |
| competing_fused_reserve_reclaims_expired_accepted_ownersrc/market_authority.rs:1533 | fn | 21 | 1 | 0 | 8 | 0.5 | |
| fused_reserve_rechecks_authority_clock_before_durable_insertsrc/market_authority.rs:1556 | fn | 17 | 1 | 0 | 7 | 0.5 | |
| v2_storage_is_not_guessed_as_v3src/market_authority.rs:1575 | fn | 34 | 1 | 0 | 5 | 0.5 | |
| compute_premium_owner_has_one_buyer_obligation_per_work_keysrc/market_authority.rs:1611 | fn | 24 | 1 | 0 | 8 | 0.5 | |
| reopened_paid_legacy_premium_keeps_work_key_ownershipsrc/market_authority.rs:1637 | fn | 39 | 1 | 0 | 11 | 0.5 | |
| concurrent_competing_compute_premium_reservations_have_one_ownersrc/market_authority.rs:1678 | fn | 26 | 1 | 0 | 6 | 0.5 | |
| trusted_identities_and_expiry_are_fail_closedsrc/market_authority.rs:1706 | fn | 46 | 1 | 0 | 11 | 0.5 | |
| materialized_column_tampering_is_rejected_on_observesrc/market_authority.rs:1754 | fn | 17 | 1 | 0 | 6 | 0.5 | |
| non_sqlite_truth_is_rejectedsrc/market_authority.rs:1773 | fn | 11 | 1 | 0 | 2 | 0.5 |
Source not readable from this process.