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-compute/src/work_lease_authority.rs

cre8-app-compute · module work_lease_authority · src · 2,129 lines (1,929 code, 77 comment) · sha d9d50293892da278

Items

const EXECUTION_WORK_LEASES_TABLE const EXECUTION_WORK_EFFECT_CLAIMS_TABLE const EXECUTION_WORK_EFFECT_CLAIM_SCHEMA const EXECUTION_WORK_EFFECT_CLAIM_PREFIX enum ExecutionWorkLeaseAuthorityError type ExecutionWorkLeaseAuthorityResult enum ExecutionWorkEffectKind impl ExecutionWorkEffectKind enum ExecutionWorkEffectClaimStatus impl ExecutionWorkEffectClaimStatus struct ExecutionWorkEffectClaim impl ExecutionWorkEffectClaim trait ExecutionWorkLeaseAuthority struct SqliteExecutionWorkLeaseAuthority impl SqliteExecutionWorkLeaseAuthority impl ExecutionWorkLeaseAuthority for SqliteExecutionWorkLeaseAuthority struct PersistedLeaseFields impl PersistedLeaseFields struct PersistedEffectClaimFields impl PersistedEffectClaimFields static NEXT_TEST_DB

Functions

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

functionkindlinescyclomaticcallerscalleesweightcrystal
storage_errorsrc/work_lease_authority.rs:1322fn313005.9
canonical_authenticated_ownersrc/work_lease_authority.rs:1361fn73902.6
SqliteExecutionWorkLeaseAuthority::ensure_configured_coordinatorsrc/work_lease_authority.rs:741method122902.4
hash_claim_partsrc/work_lease_authority.rs:1408fn41202.1
SqliteExecutionWorkLeaseAuthority::from_shared_truthsrc/work_lease_authority.rs:517method122701.8
SqliteExecutionWorkLeaseAuthority::compare_and_swapsrc/work_lease_authority.rs:685method553741.5
ExecutionWorkEffectClaim::derived_claim_idsrc/work_lease_authority.rs:360method212311.4
cleanupsrc/work_lease_authority.rs:1673fn521201.3
authoritysrc/work_lease_authority.rs:1667fn511131.2
work_keysrc/work_lease_authority.rs:1679fn411111.2
canonical_effect_keysrc/work_lease_authority.rs:1392fn73401.2
ensure_authenticated_ownersrc/work_lease_authority.rs:1369fn142611.2
sqlite_i64src/work_lease_authority.rs:1413fn31401.2
ExecutionWorkEffectClaim::same_immutable_bindingsrc/work_lease_authority.rs:343method1614701.2
coordinatorsrc/work_lease_authority.rs:1689fn31611.1
stored_textsrc/work_lease_authority.rs:1423fn41421.1
canonical_effect_receiptsrc/work_lease_authority.rs:1400fn73201
SqliteExecutionWorkLeaseAuthority::opensrc/work_lease_authority.rs:510method61411
PersistedLeaseFields::from_leasesrc/work_lease_authority.rs:1189method201230.9
cache_keysrc/work_lease_authority.rs:1684fn41710.9
SqliteExecutionWorkLeaseAuthority::next_fencing_tokensrc/work_lease_authority.rs:754method92310.9
PersistedLeaseFields::insert_paramssrc/work_lease_authority.rs:1210method191100.9
lease_status_textsrc/work_lease_authority.rs:1641fn84300.9
test_db_pathsrc/work_lease_authority.rs:1659fn71200.9
stored_effect_claim_from_rowsrc/work_lease_authority.rs:1577fn638350.9
ExecutionWorkEffectClaim::validatesrc/work_lease_authority.rs:263method6112130.8
ExecutionWorkEffectClaim::committedsrc/work_lease_authority.rs:325method172420.8
stored_u64src/work_lease_authority.rs:1417fn51220.7
SqliteExecutionWorkLeaseAuthority::lease_column_namessrc/work_lease_authority.rs:648method81230.7
ExecutionWorkEffectClaim::from_completed_leasesrc/work_lease_authority.rs:188method403420.7
require_canonical_identifiersrc/work_lease_authority.rs:1384fn73200.7
stored_effect_opt_textsrc/work_lease_authority.rs:1533fn153120.6
stored_effect_opt_u64src/work_lease_authority.rs:1549fn273120.6
SqliteExecutionWorkLeaseAuthority::ensure_lease_completion_columnssrc/work_lease_authority.rs:610method375130.6
SqliteExecutionWorkLeaseAuthority::insert_if_absentsrc/work_lease_authority.rs:657method272140.6
completed_generation_matchessrc/work_lease_authority.rs:1326fn1715200.6
completed_artifact_bindings_matchsrc/work_lease_authority.rs:1344fn165200.6
PersistedEffectClaimFields::from_claimsrc/work_lease_authority.rs:1269method271220.6
stored_opt_textsrc/work_lease_authority.rs:1428fn123130.6
stored_lease_from_rowsrc/work_lease_authority.rs:1441fn9114150.6
SqliteExecutionWorkLeaseAuthority::observe_effect_claim_by_idsrc/work_lease_authority.rs:764method191130.6
SqliteExecutionWorkLeaseAuthority::observesrc/work_lease_authority.rs:786trait impl202150.6
SqliteExecutionWorkLeaseAuthority::observe_effect_claimsrc/work_lease_authority.rs:1064trait impl211140.5
ExecutionWorkEffectKind::as_strsrc/work_lease_authority.rs:131method73000.5
ExecutionWorkEffectClaimStatus::as_strsrc/work_lease_authority.rs:151method62000.5
ExecutionWorkEffectClaim::stable_hashsrc/work_lease_authority.rs:231method31010.5
ExecutionWorkEffectClaim::record_hashsrc/work_lease_authority.rs:236method262010.5
SqliteExecutionWorkLeaseAuthority::truthsrc/work_lease_authority.rs:530method31000.5
SqliteExecutionWorkLeaseAuthority::coordinatorsrc/work_lease_authority.rs:534method31000.5
SqliteExecutionWorkLeaseAuthority::ensure_schemasrc/work_lease_authority.rs:538method711030.5
SqliteExecutionWorkLeaseAuthority::acquiresrc/work_lease_authority.rs:807trait impl191030.5
SqliteExecutionWorkLeaseAuthority::renewsrc/work_lease_authority.rs:827trait impl141030.5
SqliteExecutionWorkLeaseAuthority::expiresrc/work_lease_authority.rs:842trait impl101020.5
SqliteExecutionWorkLeaseAuthority::takeoversrc/work_lease_authority.rs:853trait impl131030.5
SqliteExecutionWorkLeaseAuthority::releasesrc/work_lease_authority.rs:867trait impl131030.5
SqliteExecutionWorkLeaseAuthority::reclaim_releasedsrc/work_lease_authority.rs:881trait impl131030.5
SqliteExecutionWorkLeaseAuthority::restart_completed_for_unmet_admissionsrc/work_lease_authority.rs:895trait impl181030.5
SqliteExecutionWorkLeaseAuthority::finalizesrc/work_lease_authority.rs:914trait impl6810070.5
SqliteExecutionWorkLeaseAuthority::claim_effectsrc/work_lease_authority.rs:983trait impl8060100.5
SqliteExecutionWorkLeaseAuthority::list_pending_effect_claimssrc/work_lease_authority.rs:1086trait impl252040.5
SqliteExecutionWorkLeaseAuthority::mark_effect_committedsrc/work_lease_authority.rs:1112trait impl569060.5
PersistedLeaseFields::cas_paramssrc/work_lease_authority.rs:1230method141010.5
PersistedEffectClaimFields::insert_paramssrc/work_lease_authority.rs:1297method231000.5
concurrent_acquire_has_exactly_one_sqlite_winnersrc/work_lease_authority.rs:1694fn172060.5
stale_worker_cannot_renew_finalize_or_release_after_takeoversrc/work_lease_authority.rs:1713fn321060.5
finalized_completion_survives_reopen_after_crash_boundarysrc/work_lease_authority.rs:1747fn231080.5
released_work_reclaims_immediately_through_authoritysrc/work_lease_authority.rs:1772fn131050.5
completed_restart_requires_explicit_authority_path_and_invalidates_old_fencesrc/work_lease_authority.rs:1787fn341070.5
configured_coordinator_rejects_foreign_records_before_mutationsrc/work_lease_authority.rs:1823fn201060.5
fencing_token_exhaustion_fails_closed_without_replacing_current_leasesrc/work_lease_authority.rs:1845fn221060.5
finalize_retry_reconciles_a_lost_success_response_without_accepting_conflictsrc/work_lease_authority.rs:1869fn441060.5
current_completed_effect_claim_is_idempotent_and_survives_reopen_pendingsrc/work_lease_authority.rs:1915fn571080.5
stale_completion_after_restart_cannot_create_new_effect_and_old_claim_survivessrc/work_lease_authority.rs:1974fn431060.5
effect_key_conflict_and_commit_receipt_are_idempotentsrc/work_lease_authority.rs:2019fn561060.5
concurrent_legacy_schema_startup_accepts_the_other_authoritys_completed_migrationsrc/work_lease_authority.rs:2077fn522080.5

Source not readable from this process.