radroots_storage.txt (253395B)
1 pub mod radroots_storage 2 pub mod radroots_storage::atomic 3 pub enum radroots_storage::atomic::AtomicCommitDisposition 4 pub radroots_storage::atomic::AtomicCommitDisposition::Committed 5 pub radroots_storage::atomic::AtomicCommitDisposition::Replay 6 pub enum radroots_storage::atomic::AtomicCommitOutcome 7 pub radroots_storage::atomic::AtomicCommitOutcome::Ingested 8 pub radroots_storage::atomic::AtomicCommitOutcome::Ingested::admission: radroots_storage::event::AdmissionReceipt 9 pub radroots_storage::atomic::AtomicCommitOutcome::Ingested::projection: core::option::Option<alloc::boxed::Box<radroots_storage::projection::ProjectionStatus>> 10 impl radroots_storage::atomic::AtomicCommitOutcome 11 pub const fn radroots_storage::atomic::AtomicCommitOutcome::kind(&self) -> radroots_storage::atomic::AtomicWorkflowKind 12 pub enum radroots_storage::atomic::AtomicWorkflow 13 pub radroots_storage::atomic::AtomicWorkflow::Ingested(alloc::boxed::Box<radroots_storage::atomic::CommitIngested>) 14 impl radroots_storage::atomic::AtomicWorkflow 15 pub const fn radroots_storage::atomic::AtomicWorkflow::kind(&self) -> radroots_storage::atomic::AtomicWorkflowKind 16 pub enum radroots_storage::atomic::AtomicWorkflowKind 17 pub radroots_storage::atomic::AtomicWorkflowKind::Ingested 18 pub struct radroots_storage::atomic::AtomicCommit 19 impl radroots_storage::atomic::AtomicCommit 20 pub const fn radroots_storage::atomic::AtomicCommit::commit_id(&self) -> radroots_storage::atomic::AtomicCommitId 21 pub const fn radroots_storage::atomic::AtomicCommit::digest(&self) -> radroots_storage::atomic::AtomicCommitDigest 22 pub fn radroots_storage::atomic::AtomicCommit::new(radroots_storage::atomic::AtomicCommitId, radroots_storage::atomic::AtomicCommitDigest, u64, radroots_storage::atomic::AtomicWorkflow) -> core::result::Result<Self, radroots_storage::Error> 23 pub const fn radroots_storage::atomic::AtomicCommit::requested_at_unix_ms(&self) -> u64 24 pub const fn radroots_storage::atomic::AtomicCommit::workflow(&self) -> &radroots_storage::atomic::AtomicWorkflow 25 pub struct radroots_storage::atomic::AtomicCommitDigest(_) 26 impl radroots_storage::atomic::AtomicCommitDigest 27 pub const fn radroots_storage::atomic::AtomicCommitDigest::as_bytes(&self) -> &[u8; 32] 28 pub const fn radroots_storage::atomic::AtomicCommitDigest::new([u8; 32]) -> Self 29 pub struct radroots_storage::atomic::AtomicCommitId(_) 30 impl radroots_storage::atomic::AtomicCommitId 31 pub const fn radroots_storage::atomic::AtomicCommitId::as_bytes(&self) -> &[u8; 16] 32 pub const fn radroots_storage::atomic::AtomicCommitId::new([u8; 16]) -> core::result::Result<Self, radroots_storage::Error> 33 pub struct radroots_storage::atomic::AtomicCommitReceipt 34 impl radroots_storage::atomic::AtomicCommitReceipt 35 pub const fn radroots_storage::atomic::AtomicCommitReceipt::commit_id(&self) -> radroots_storage::atomic::AtomicCommitId 36 pub const fn radroots_storage::atomic::AtomicCommitReceipt::committed_at_unix_ms(&self) -> u64 37 pub const fn radroots_storage::atomic::AtomicCommitReceipt::digest(&self) -> radroots_storage::atomic::AtomicCommitDigest 38 pub const fn radroots_storage::atomic::AtomicCommitReceipt::disposition(&self) -> radroots_storage::atomic::AtomicCommitDisposition 39 pub fn radroots_storage::atomic::AtomicCommitReceipt::from_durable_parts(radroots_storage::atomic::AtomicCommitId, radroots_storage::atomic::AtomicCommitDigest, radroots_storage::atomic::AtomicCommitDisposition, u64, u64, radroots_storage::atomic::AtomicWorkflowKind, radroots_storage::atomic::AtomicCommitOutcome) -> core::result::Result<Self, radroots_storage::Error> 40 pub fn radroots_storage::atomic::AtomicCommitReceipt::new(&radroots_storage::atomic::AtomicCommit, radroots_storage::atomic::AtomicCommitDisposition, u64, radroots_storage::atomic::AtomicCommitOutcome) -> core::result::Result<Self, radroots_storage::Error> 41 pub const fn radroots_storage::atomic::AtomicCommitReceipt::outcome(&self) -> &radroots_storage::atomic::AtomicCommitOutcome 42 pub struct radroots_storage::atomic::CommitIngested 43 impl radroots_storage::atomic::CommitIngested 44 pub const fn radroots_storage::atomic::CommitIngested::admission(&self) -> &radroots_storage::event::EventAdmission 45 pub const fn radroots_storage::atomic::CommitIngested::new(radroots_storage::event::EventAdmission, core::option::Option<radroots_storage::projection::ProjectionCheckpoint>) -> Self 46 pub const fn radroots_storage::atomic::CommitIngested::projection(&self) -> core::option::Option<&radroots_storage::projection::ProjectionCheckpoint> 47 pub trait radroots_storage::atomic::AtomicStorage: core::marker::Send + core::marker::Sync 48 pub fn radroots_storage::atomic::AtomicStorage::commit(&self, radroots_storage::atomic::AtomicCommit) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::atomic::AtomicCommitReceipt, radroots_storage::Error>> 49 pub fn radroots_storage::atomic::AtomicStorage::receipt(&self, radroots_storage::atomic::AtomicCommitId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::atomic::AtomicCommitReceipt>, radroots_storage::Error>> 50 impl radroots_storage::atomic::AtomicStorage for radroots_storage::memory::MemoryStorage 51 pub fn radroots_storage::memory::MemoryStorage::commit(&self, radroots_storage::atomic::AtomicCommit) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::atomic::AtomicCommitReceipt, radroots_storage::Error>> 52 pub fn radroots_storage::memory::MemoryStorage::receipt(&self, radroots_storage::atomic::AtomicCommitId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::atomic::AtomicCommitReceipt>, radroots_storage::Error>> 53 pub mod radroots_storage::authored 54 pub enum radroots_storage::authored::AdmissionState 55 pub radroots_storage::authored::AdmissionState::Cancelled 56 pub radroots_storage::authored::AdmissionState::Duplicate 57 pub radroots_storage::authored::AdmissionState::Inserted 58 pub radroots_storage::authored::AdmissionState::Pending 59 pub radroots_storage::authored::AdmissionState::Rejected 60 pub radroots_storage::authored::AdmissionState::Retryable 61 impl radroots_storage::authored::AdmissionState 62 pub const fn radroots_storage::authored::AdmissionState::is_admitted(self) -> bool 63 pub enum radroots_storage::authored::ArtifactOrigin 64 pub radroots_storage::authored::ArtifactOrigin::ImportedSigned 65 pub radroots_storage::authored::ArtifactOrigin::Planned 66 impl radroots_storage::authored::ArtifactOrigin 67 pub const fn radroots_storage::authored::ArtifactOrigin::is_resignable(self) -> bool 68 pub enum radroots_storage::authored::FailureClass 69 pub radroots_storage::authored::FailureClass::Indeterminate 70 pub radroots_storage::authored::FailureClass::Retryable 71 pub radroots_storage::authored::FailureClass::Terminal 72 pub enum radroots_storage::authored::SigningState 73 pub radroots_storage::authored::SigningState::Cancelled 74 pub radroots_storage::authored::SigningState::FailedTerminal 75 pub radroots_storage::authored::SigningState::Indeterminate 76 pub radroots_storage::authored::SigningState::Planned 77 pub radroots_storage::authored::SigningState::Retryable 78 pub radroots_storage::authored::SigningState::Signed 79 pub enum radroots_storage::authored::WorkPhase 80 pub radroots_storage::authored::WorkPhase::Admission 81 pub radroots_storage::authored::WorkPhase::Delivery 82 pub radroots_storage::authored::WorkPhase::Signing 83 pub struct radroots_storage::authored::AuthoredArtifact 84 impl radroots_storage::authored::AuthoredArtifact 85 pub const fn radroots_storage::authored::AuthoredArtifact::admission_claim(&self) -> core::option::Option<&radroots_storage::authored::WorkClaim> 86 pub const fn radroots_storage::authored::AuthoredArtifact::admission_retry(&self) -> core::option::Option<&radroots_storage::authored::RetrySchedule> 87 pub const fn radroots_storage::authored::AuthoredArtifact::admission_state(&self) -> radroots_storage::authored::AdmissionState 88 pub const fn radroots_storage::authored::AuthoredArtifact::artifact_id(&self) -> radroots_storage::authored::AuthoredArtifactId 89 pub fn radroots_storage::authored::AuthoredArtifact::cancel_signing(&mut self, u64) -> core::result::Result<(), radroots_storage::Error> 90 pub const fn radroots_storage::authored::AuthoredArtifact::created_at_unix_ms(&self) -> u64 91 pub fn radroots_storage::authored::AuthoredArtifact::imported_signed(radroots_storage::authored::AuthoredArtifactId, radroots_storage::journal::OperationInstanceId, u16, radroots_event::draft::SignedEvent, u64) -> core::result::Result<Self, radroots_storage::Error> 92 pub const fn radroots_storage::authored::AuthoredArtifact::last_failure(&self) -> core::option::Option<&radroots_storage::authored::WorkFailure> 93 pub const fn radroots_storage::authored::AuthoredArtifact::operation_id(&self) -> radroots_storage::journal::OperationInstanceId 94 pub const fn radroots_storage::authored::AuthoredArtifact::ordinal(&self) -> u16 95 pub const fn radroots_storage::authored::AuthoredArtifact::origin(&self) -> radroots_storage::authored::ArtifactOrigin 96 pub const fn radroots_storage::authored::AuthoredArtifact::plan(&self) -> core::option::Option<&radroots_storage::authored::DurableAuthoredPlan> 97 pub fn radroots_storage::authored::AuthoredArtifact::planned(radroots_storage::authored::AuthoredArtifactId, radroots_storage::journal::OperationInstanceId, u16, &radroots_event_codec::authoring::AuthoredEventPlan, u64) -> core::result::Result<Self, radroots_storage::Error> 98 pub fn radroots_storage::authored::AuthoredArtifact::reconstruct(Self) -> core::result::Result<Self, radroots_storage::Error> 99 pub fn radroots_storage::authored::AuthoredArtifact::record_admission(&mut self, radroots_storage::authored::AdmissionState, core::option::Option<radroots_storage::authored::WorkFailure>, core::option::Option<radroots_storage::authored::RetrySchedule>, u64) -> core::result::Result<(), radroots_storage::Error> 100 pub fn radroots_storage::authored::AuthoredArtifact::record_signed(&mut self, radroots_event::draft::SignedEvent, u64) -> core::result::Result<(), radroots_storage::Error> 101 pub fn radroots_storage::authored::AuthoredArtifact::record_signing_failure(&mut self, radroots_storage::authored::WorkFailure, core::option::Option<radroots_storage::authored::RetrySchedule>, u64) -> core::result::Result<(), radroots_storage::Error> 102 pub const fn radroots_storage::authored::AuthoredArtifact::revision(&self) -> core::num::nonzero::NonZeroU64 103 pub fn radroots_storage::authored::AuthoredArtifact::set_admission_claim(&mut self, radroots_storage::authored::WorkClaim, u64) -> core::result::Result<(), radroots_storage::Error> 104 pub fn radroots_storage::authored::AuthoredArtifact::set_signing_claim(&mut self, radroots_storage::authored::WorkClaim, u64) -> core::result::Result<(), radroots_storage::Error> 105 pub const fn radroots_storage::authored::AuthoredArtifact::signed(&self) -> core::option::Option<&radroots_storage::authored::ExactSignedArtifact> 106 pub const fn radroots_storage::authored::AuthoredArtifact::signing_claim(&self) -> core::option::Option<&radroots_storage::authored::WorkClaim> 107 pub const fn radroots_storage::authored::AuthoredArtifact::signing_retry(&self) -> core::option::Option<&radroots_storage::authored::RetrySchedule> 108 pub const fn radroots_storage::authored::AuthoredArtifact::signing_state(&self) -> radroots_storage::authored::SigningState 109 pub const fn radroots_storage::authored::AuthoredArtifact::updated_at_unix_ms(&self) -> u64 110 pub fn radroots_storage::authored::AuthoredArtifact::validate(&self) -> core::result::Result<(), radroots_storage::Error> 111 pub struct radroots_storage::authored::AuthoredArtifactId(_) 112 impl radroots_storage::authored::AuthoredArtifactId 113 pub const fn radroots_storage::authored::AuthoredArtifactId::as_bytes(&self) -> &[u8; 16] 114 pub const fn radroots_storage::authored::AuthoredArtifactId::new([u8; 16]) -> core::result::Result<Self, radroots_storage::Error> 115 impl core::convert::From<radroots_storage::authored::AuthoredArtifactId> for [u8; 16] 116 pub fn [u8; 16]::from(radroots_storage::authored::AuthoredArtifactId) -> Self 117 impl core::convert::TryFrom<[u8; 16]> for radroots_storage::authored::AuthoredArtifactId 118 pub type radroots_storage::authored::AuthoredArtifactId::Error = radroots_storage::Error 119 pub fn radroots_storage::authored::AuthoredArtifactId::try_from([u8; 16]) -> core::result::Result<Self, Self::Error> 120 pub struct radroots_storage::authored::AuthoredOperation 121 impl radroots_storage::authored::AuthoredOperation 122 pub fn radroots_storage::authored::AuthoredOperation::artifact_ids(&self) -> &[radroots_storage::authored::AuthoredArtifactId] 123 pub const fn radroots_storage::authored::AuthoredOperation::created_at_unix_ms(&self) -> u64 124 pub fn radroots_storage::authored::AuthoredOperation::new(radroots_storage::journal::OperationInstanceId, alloc::vec::Vec<radroots_storage::authored::AuthoredArtifactId>, u64) -> core::result::Result<Self, radroots_storage::Error> 125 pub const fn radroots_storage::authored::AuthoredOperation::operation_id(&self) -> radroots_storage::journal::OperationInstanceId 126 pub fn radroots_storage::authored::AuthoredOperation::reconstruct(radroots_storage::journal::OperationInstanceId, alloc::vec::Vec<radroots_storage::authored::AuthoredArtifactId>, u64, u64, core::num::nonzero::NonZeroU64) -> core::result::Result<Self, radroots_storage::Error> 127 pub const fn radroots_storage::authored::AuthoredOperation::revision(&self) -> core::num::nonzero::NonZeroU64 128 pub const fn radroots_storage::authored::AuthoredOperation::updated_at_unix_ms(&self) -> u64 129 pub struct radroots_storage::authored::DurableAuthoredPlan 130 impl radroots_storage::authored::DurableAuthoredPlan 131 pub fn radroots_storage::authored::DurableAuthoredPlan::decode(&self) -> core::result::Result<radroots_event_codec::authoring::wire::HistoricalPlanIntegrity, radroots_storage::Error> 132 pub fn radroots_storage::authored::DurableAuthoredPlan::from_plan(&radroots_event_codec::authoring::AuthoredEventPlan) -> core::result::Result<Self, radroots_storage::Error> 133 pub fn radroots_storage::authored::DurableAuthoredPlan::reconstruct(alloc::vec::Vec<u8>) -> core::result::Result<Self, radroots_storage::Error> 134 pub fn radroots_storage::authored::DurableAuthoredPlan::wire_json(&self) -> &[u8] 135 pub struct radroots_storage::authored::ExactSignedArtifact 136 impl radroots_storage::authored::ExactSignedArtifact 137 pub const fn radroots_storage::authored::ExactSignedArtifact::event(&self) -> &radroots_event::draft::SignedEvent 138 pub fn radroots_storage::authored::ExactSignedArtifact::new(radroots_event::draft::SignedEvent) -> Self 139 pub const fn radroots_storage::authored::ExactSignedArtifact::raw_json_sha256(&self) -> &[u8; 32] 140 pub fn radroots_storage::authored::ExactSignedArtifact::reconstruct(radroots_event::draft::SignedEvent, [u8; 32]) -> core::result::Result<Self, radroots_storage::Error> 141 pub struct radroots_storage::authored::OperationSettlement 142 impl radroots_storage::authored::OperationSettlement 143 pub const fn radroots_storage::authored::OperationSettlement::admitted(self) -> u16 144 pub const fn radroots_storage::authored::OperationSettlement::artifacts(self) -> u16 145 pub const fn radroots_storage::authored::OperationSettlement::cancelled(self) -> u16 146 pub const fn radroots_storage::authored::OperationSettlement::delivery_cancelled(self) -> u16 147 pub const fn radroots_storage::authored::OperationSettlement::delivery_exhausted(self) -> u16 148 pub const fn radroots_storage::authored::OperationSettlement::delivery_failed_terminal(self) -> u16 149 pub const fn radroots_storage::authored::OperationSettlement::delivery_pending(self) -> u16 150 pub const fn radroots_storage::authored::OperationSettlement::delivery_plans(self) -> u16 151 pub const fn radroots_storage::authored::OperationSettlement::delivery_retryable(self) -> u16 152 pub const fn radroots_storage::authored::OperationSettlement::delivery_satisfied(self) -> u16 153 pub fn radroots_storage::authored::OperationSettlement::evaluate(&radroots_storage::authored::AuthoredOperation, &[radroots_storage::authored::AuthoredArtifact]) -> core::result::Result<Self, radroots_storage::Error> 154 pub fn radroots_storage::authored::OperationSettlement::evaluate_complete(&radroots_storage::authored::AuthoredOperation, &[radroots_storage::authored::AuthoredArtifact], &[radroots_storage::authored_delivery::AuthoredDeliveryPlan]) -> core::result::Result<Self, radroots_storage::Error> 155 pub const fn radroots_storage::authored::OperationSettlement::failed_terminal(self) -> u16 156 pub const fn radroots_storage::authored::OperationSettlement::has_failures(self) -> bool 157 pub const fn radroots_storage::authored::OperationSettlement::indeterminate(self) -> u16 158 pub const fn radroots_storage::authored::OperationSettlement::is_settled(self) -> bool 159 pub const fn radroots_storage::authored::OperationSettlement::is_successful(self) -> bool 160 pub const fn radroots_storage::authored::OperationSettlement::pending(self) -> u16 161 pub const fn radroots_storage::authored::OperationSettlement::retryable(self) -> u16 162 pub const fn radroots_storage::authored::OperationSettlement::signed(self) -> u16 163 pub struct radroots_storage::authored::RetrySchedule 164 impl radroots_storage::authored::RetrySchedule 165 pub const fn radroots_storage::authored::RetrySchedule::attempt(&self) -> core::num::nonzero::NonZeroU32 166 pub const fn radroots_storage::authored::RetrySchedule::failure(&self) -> &radroots_storage::authored::WorkFailure 167 pub fn radroots_storage::authored::RetrySchedule::new(core::num::nonzero::NonZeroU32, u64, radroots_storage::authored::WorkFailure) -> core::result::Result<Self, radroots_storage::Error> 168 pub fn radroots_storage::authored::RetrySchedule::next_attempt(&self, u64, radroots_storage::authored::WorkFailure) -> core::result::Result<Self, radroots_storage::Error> 169 pub const fn radroots_storage::authored::RetrySchedule::not_before_unix_ms(&self) -> u64 170 pub struct radroots_storage::authored::WorkClaim 171 impl radroots_storage::authored::WorkClaim 172 pub const fn radroots_storage::authored::WorkClaim::acquired_at_unix_ms(&self) -> u64 173 pub const fn radroots_storage::authored::WorkClaim::expires_at_unix_ms(&self) -> u64 174 pub const fn radroots_storage::authored::WorkClaim::generation(&self) -> core::num::nonzero::NonZeroU64 175 pub fn radroots_storage::authored::WorkClaim::matches_fence(&self, &[u8; 16], core::num::nonzero::NonZeroU64, core::num::nonzero::NonZeroU64, u64) -> bool 176 pub fn radroots_storage::authored::WorkClaim::new([u8; 16], impl core::convert::Into<alloc::string::String>, core::num::nonzero::NonZeroU64, u64, u64, core::num::nonzero::NonZeroU64) -> core::result::Result<Self, radroots_storage::Error> 177 pub fn radroots_storage::authored::WorkClaim::owner(&self) -> &str 178 pub const fn radroots_storage::authored::WorkClaim::row_revision(&self) -> core::num::nonzero::NonZeroU64 179 pub const fn radroots_storage::authored::WorkClaim::token(&self) -> &[u8; 16] 180 pub fn radroots_storage::authored::WorkClaim::validate(&self) -> core::result::Result<(), radroots_storage::Error> 181 pub struct radroots_storage::authored::WorkFailure 182 impl radroots_storage::authored::WorkFailure 183 pub const fn radroots_storage::authored::WorkFailure::class(&self) -> radroots_storage::authored::FailureClass 184 pub fn radroots_storage::authored::WorkFailure::code(&self) -> &str 185 pub fn radroots_storage::authored::WorkFailure::diagnostic(&self) -> core::option::Option<&str> 186 pub fn radroots_storage::authored::WorkFailure::new(impl core::convert::Into<alloc::string::String>, radroots_storage::authored::WorkPhase, radroots_storage::authored::FailureClass, core::option::Option<u64>, core::option::Option<alloc::string::String>) -> core::result::Result<Self, radroots_storage::Error> 187 pub const fn radroots_storage::authored::WorkFailure::phase(&self) -> radroots_storage::authored::WorkPhase 188 pub const fn radroots_storage::authored::WorkFailure::retry_after_unix_ms(&self) -> core::option::Option<u64> 189 pub fn radroots_storage::authored::WorkFailure::validate(&self) -> core::result::Result<(), radroots_storage::Error> 190 pub const radroots_storage::authored::AUTHORED_OPERATION_ARTIFACTS_MAX: usize 191 pub const radroots_storage::authored::WORK_CLAIM_OWNER_MAX_BYTES: usize 192 pub const radroots_storage::authored::WORK_FAILURE_CODE_MAX_BYTES: usize 193 pub const radroots_storage::authored::WORK_FAILURE_DIAGNOSTIC_MAX_BYTES: usize 194 pub mod radroots_storage::authored_atomic 195 pub enum radroots_storage::authored_atomic::AuthoredAtomicCommand 196 pub radroots_storage::authored_atomic::AuthoredAtomicCommand::ApplyAdmission(radroots_storage::authored_atomic::ApplyAdmissionResult) 197 pub radroots_storage::authored_atomic::AuthoredAtomicCommand::ApplyDelivery(radroots_storage::authored_atomic::ApplyDeliveryAttempt) 198 pub radroots_storage::authored_atomic::AuthoredAtomicCommand::ApplyFailure(radroots_storage::authored_atomic::ApplyWorkFailure) 199 pub radroots_storage::authored_atomic::AuthoredAtomicCommand::ApplySigned(radroots_storage::authored_atomic::ApplySignedArtifact) 200 pub radroots_storage::authored_atomic::AuthoredAtomicCommand::Cancel(radroots_storage::authored_atomic::CancelAuthoredWork) 201 pub radroots_storage::authored_atomic::AuthoredAtomicCommand::Claim(radroots_storage::authored_atomic::ClaimAuthoredWork) 202 pub radroots_storage::authored_atomic::AuthoredAtomicCommand::Prepare(radroots_storage::authored_atomic::PrepareAuthoredOperation) 203 pub radroots_storage::authored_atomic::AuthoredAtomicCommand::PrepareFromDraft(alloc::boxed::Box<radroots_storage::authored_draft_submission::PrepareFromDraft>) 204 pub radroots_storage::authored_atomic::AuthoredAtomicCommand::ReconcileDelivery(radroots_storage::authored_atomic::ReconcileDeliveryFacts) 205 pub radroots_storage::authored_atomic::AuthoredAtomicCommand::RecordDelivery(radroots_storage::authored_atomic::RecordDeliveryFact) 206 pub radroots_storage::authored_atomic::AuthoredAtomicCommand::RecordSigned(radroots_storage::authored_atomic::RecordSignedArtifact) 207 impl radroots_storage::authored_atomic::AuthoredAtomicCommand 208 pub fn radroots_storage::authored_atomic::AuthoredAtomicCommand::commit_id(&self) -> radroots_storage::atomic::AtomicCommitId 209 pub fn radroots_storage::authored_atomic::AuthoredAtomicCommand::digest(&self) -> radroots_storage::atomic::AtomicCommitDigest 210 pub const fn radroots_storage::authored_atomic::AuthoredAtomicCommand::requested_at_unix_ms(&self) -> u64 211 pub enum radroots_storage::authored_atomic::AuthoredAtomicOutcome 212 pub radroots_storage::authored_atomic::AuthoredAtomicOutcome::Artifact(radroots_storage::authored::AuthoredArtifact) 213 pub radroots_storage::authored_atomic::AuthoredAtomicOutcome::DeliveryPlan(radroots_storage::authored_delivery::AuthoredDeliveryPlan) 214 pub radroots_storage::authored_atomic::AuthoredAtomicOutcome::Prepared 215 pub radroots_storage::authored_atomic::AuthoredAtomicOutcome::Prepared::artifacts: alloc::vec::Vec<radroots_storage::authored::AuthoredArtifact> 216 pub radroots_storage::authored_atomic::AuthoredAtomicOutcome::Prepared::delivery_plans: alloc::vec::Vec<radroots_storage::authored_delivery::AuthoredDeliveryPlan> 217 pub radroots_storage::authored_atomic::AuthoredAtomicOutcome::Prepared::operation: radroots_storage::authored::AuthoredOperation 218 pub radroots_storage::authored_atomic::AuthoredAtomicOutcome::Submitted(alloc::boxed::Box<radroots_storage::authored_draft_submission::PrepareFromDraft>) 219 pub enum radroots_storage::authored_atomic::AuthoredWorkTarget 220 pub radroots_storage::authored_atomic::AuthoredWorkTarget::Artifact(radroots_storage::authored::AuthoredArtifactId) 221 pub radroots_storage::authored_atomic::AuthoredWorkTarget::DeliveryPlan(radroots_storage::authored_delivery::AuthoredDeliveryPlanId) 222 pub enum radroots_storage::authored_atomic::CancelAuthoredTarget 223 pub radroots_storage::authored_atomic::CancelAuthoredTarget::ArtifactAdmission(radroots_storage::authored::AuthoredArtifactId) 224 pub radroots_storage::authored_atomic::CancelAuthoredTarget::ArtifactSigning(radroots_storage::authored::AuthoredArtifactId) 225 pub radroots_storage::authored_atomic::CancelAuthoredTarget::DeliveryPlan(radroots_storage::authored_delivery::AuthoredDeliveryPlanId) 226 pub enum radroots_storage::authored_atomic::ClaimAuthoredTarget 227 pub radroots_storage::authored_atomic::ClaimAuthoredTarget::ArtifactAdmission(radroots_storage::authored::AuthoredArtifactId) 228 pub radroots_storage::authored_atomic::ClaimAuthoredTarget::ArtifactSigning(radroots_storage::authored::AuthoredArtifactId) 229 pub radroots_storage::authored_atomic::ClaimAuthoredTarget::DeliveryPlan(radroots_storage::authored_delivery::AuthoredDeliveryPlanId) 230 pub struct radroots_storage::authored_atomic::ApplyAdmissionResult 231 impl radroots_storage::authored_atomic::ApplyAdmissionResult 232 pub const fn radroots_storage::authored_atomic::ApplyAdmissionResult::applied_at_unix_ms(&self) -> u64 233 pub const fn radroots_storage::authored_atomic::ApplyAdmissionResult::artifact_id(&self) -> radroots_storage::authored::AuthoredArtifactId 234 pub const fn radroots_storage::authored_atomic::ApplyAdmissionResult::failure(&self) -> core::option::Option<&radroots_storage::authored::WorkFailure> 235 pub const fn radroots_storage::authored_atomic::ApplyAdmissionResult::fence(&self) -> &radroots_storage::authored_atomic::WorkFence 236 pub fn radroots_storage::authored_atomic::ApplyAdmissionResult::new(radroots_storage::authored::AuthoredArtifactId, radroots_storage::authored_atomic::WorkFence, radroots_storage::authored::AdmissionState, core::option::Option<radroots_storage::authored::WorkFailure>, core::option::Option<radroots_storage::authored::RetrySchedule>, u64) -> core::result::Result<Self, radroots_storage::Error> 237 pub const fn radroots_storage::authored_atomic::ApplyAdmissionResult::retry(&self) -> core::option::Option<&radroots_storage::authored::RetrySchedule> 238 pub const fn radroots_storage::authored_atomic::ApplyAdmissionResult::state(&self) -> radroots_storage::authored::AdmissionState 239 pub struct radroots_storage::authored_atomic::ApplyDeliveryAttempt 240 impl radroots_storage::authored_atomic::ApplyDeliveryAttempt 241 pub const fn radroots_storage::authored_atomic::ApplyDeliveryAttempt::applied_at_unix_ms(&self) -> u64 242 pub const fn radroots_storage::authored_atomic::ApplyDeliveryAttempt::fence(&self) -> &radroots_storage::authored_atomic::WorkFence 243 pub fn radroots_storage::authored_atomic::ApplyDeliveryAttempt::new(radroots_storage::authored_delivery::AuthoredDeliveryPlanId, radroots_storage::authored_atomic::WorkFence, radroots_storage::authored_delivery::DeliveryAttemptOutcome, core::option::Option<radroots_storage::authored::RetrySchedule>, u64) -> core::result::Result<Self, radroots_storage::Error> 244 pub const fn radroots_storage::authored_atomic::ApplyDeliveryAttempt::outcome(&self) -> &radroots_storage::authored_delivery::DeliveryAttemptOutcome 245 pub const fn radroots_storage::authored_atomic::ApplyDeliveryAttempt::plan_id(&self) -> radroots_storage::authored_delivery::AuthoredDeliveryPlanId 246 pub const fn radroots_storage::authored_atomic::ApplyDeliveryAttempt::retry(&self) -> core::option::Option<&radroots_storage::authored::RetrySchedule> 247 pub struct radroots_storage::authored_atomic::ApplySignedArtifact 248 impl radroots_storage::authored_atomic::ApplySignedArtifact 249 pub const fn radroots_storage::authored_atomic::ApplySignedArtifact::applied_at_unix_ms(&self) -> u64 250 pub const fn radroots_storage::authored_atomic::ApplySignedArtifact::artifact_id(&self) -> radroots_storage::authored::AuthoredArtifactId 251 pub const fn radroots_storage::authored_atomic::ApplySignedArtifact::event(&self) -> &radroots_event::draft::SignedEvent 252 pub const fn radroots_storage::authored_atomic::ApplySignedArtifact::fence(&self) -> &radroots_storage::authored_atomic::WorkFence 253 pub fn radroots_storage::authored_atomic::ApplySignedArtifact::new(radroots_storage::authored::AuthoredArtifactId, radroots_storage::authored_atomic::WorkFence, radroots_event::draft::SignedEvent, u64) -> core::result::Result<Self, radroots_storage::Error> 254 pub struct radroots_storage::authored_atomic::ApplyWorkFailure 255 impl radroots_storage::authored_atomic::ApplyWorkFailure 256 pub const fn radroots_storage::authored_atomic::ApplyWorkFailure::applied_at_unix_ms(&self) -> u64 257 pub const fn radroots_storage::authored_atomic::ApplyWorkFailure::failure(&self) -> &radroots_storage::authored::WorkFailure 258 pub const fn radroots_storage::authored_atomic::ApplyWorkFailure::fence(&self) -> &radroots_storage::authored_atomic::WorkFence 259 pub fn radroots_storage::authored_atomic::ApplyWorkFailure::new(radroots_storage::authored_atomic::AuthoredWorkTarget, radroots_storage::authored_atomic::WorkFence, radroots_storage::authored::WorkFailure, core::option::Option<radroots_storage::authored::RetrySchedule>, u64) -> core::result::Result<Self, radroots_storage::Error> 260 pub const fn radroots_storage::authored_atomic::ApplyWorkFailure::retry(&self) -> core::option::Option<&radroots_storage::authored::RetrySchedule> 261 pub const fn radroots_storage::authored_atomic::ApplyWorkFailure::target(&self) -> &radroots_storage::authored_atomic::AuthoredWorkTarget 262 pub struct radroots_storage::authored_atomic::AuthoredAtomicReceipt 263 impl radroots_storage::authored_atomic::AuthoredAtomicReceipt 264 pub const fn radroots_storage::authored_atomic::AuthoredAtomicReceipt::commit_id(&self) -> radroots_storage::atomic::AtomicCommitId 265 pub const fn radroots_storage::authored_atomic::AuthoredAtomicReceipt::committed_at_unix_ms(&self) -> u64 266 pub const fn radroots_storage::authored_atomic::AuthoredAtomicReceipt::digest(&self) -> radroots_storage::atomic::AtomicCommitDigest 267 pub const fn radroots_storage::authored_atomic::AuthoredAtomicReceipt::disposition(&self) -> radroots_storage::atomic::AtomicCommitDisposition 268 pub fn radroots_storage::authored_atomic::AuthoredAtomicReceipt::from_durable_parts(radroots_storage::atomic::AtomicCommitId, radroots_storage::atomic::AtomicCommitDigest, radroots_storage::atomic::AtomicCommitDisposition, u64, radroots_storage::authored_atomic::AuthoredAtomicOutcome) -> core::result::Result<Self, radroots_storage::Error> 269 pub fn radroots_storage::authored_atomic::AuthoredAtomicReceipt::matches_command(&self, &radroots_storage::authored_atomic::AuthoredAtomicCommand) -> bool 270 pub fn radroots_storage::authored_atomic::AuthoredAtomicReceipt::new(&radroots_storage::authored_atomic::AuthoredAtomicCommand, radroots_storage::atomic::AtomicCommitDisposition, u64, radroots_storage::authored_atomic::AuthoredAtomicOutcome) -> core::result::Result<Self, radroots_storage::Error> 271 pub const fn radroots_storage::authored_atomic::AuthoredAtomicReceipt::outcome(&self) -> &radroots_storage::authored_atomic::AuthoredAtomicOutcome 272 pub struct radroots_storage::authored_atomic::CancelAuthoredWork 273 impl radroots_storage::authored_atomic::CancelAuthoredWork 274 pub const fn radroots_storage::authored_atomic::CancelAuthoredWork::cancelled_at_unix_ms(&self) -> u64 275 pub const fn radroots_storage::authored_atomic::CancelAuthoredWork::expected_revision(&self) -> core::num::nonzero::NonZeroU64 276 pub const fn radroots_storage::authored_atomic::CancelAuthoredWork::new(radroots_storage::authored_atomic::CancelAuthoredTarget, core::num::nonzero::NonZeroU64, u64) -> core::result::Result<Self, radroots_storage::Error> 277 pub const fn radroots_storage::authored_atomic::CancelAuthoredWork::target(&self) -> &radroots_storage::authored_atomic::CancelAuthoredTarget 278 pub struct radroots_storage::authored_atomic::ClaimAuthoredWork 279 impl radroots_storage::authored_atomic::ClaimAuthoredWork 280 pub const fn radroots_storage::authored_atomic::ClaimAuthoredWork::claim(&self) -> &radroots_storage::authored::WorkClaim 281 pub const fn radroots_storage::authored_atomic::ClaimAuthoredWork::new(radroots_storage::authored_atomic::ClaimAuthoredTarget, radroots_storage::authored::WorkClaim) -> Self 282 pub const fn radroots_storage::authored_atomic::ClaimAuthoredWork::target(&self) -> &radroots_storage::authored_atomic::ClaimAuthoredTarget 283 pub struct radroots_storage::authored_atomic::PrepareAuthoredOperation 284 impl radroots_storage::authored_atomic::PrepareAuthoredOperation 285 pub fn radroots_storage::authored_atomic::PrepareAuthoredOperation::artifacts(&self) -> &[radroots_storage::authored::AuthoredArtifact] 286 pub fn radroots_storage::authored_atomic::PrepareAuthoredOperation::delivery_plans(&self) -> &[radroots_storage::authored_delivery::AuthoredDeliveryPlan] 287 pub const fn radroots_storage::authored_atomic::PrepareAuthoredOperation::input_digest(&self) -> radroots_storage::atomic::AtomicCommitDigest 288 pub fn radroots_storage::authored_atomic::PrepareAuthoredOperation::new(radroots_storage::authored::AuthoredOperation, alloc::vec::Vec<radroots_storage::authored::AuthoredArtifact>, alloc::vec::Vec<radroots_storage::authored_delivery::AuthoredDeliveryPlan>, radroots_storage::atomic::AtomicCommitDigest, u64) -> core::result::Result<Self, radroots_storage::Error> 289 pub const fn radroots_storage::authored_atomic::PrepareAuthoredOperation::operation(&self) -> &radroots_storage::authored::AuthoredOperation 290 pub const fn radroots_storage::authored_atomic::PrepareAuthoredOperation::requested_at_unix_ms(&self) -> u64 291 pub struct radroots_storage::authored_atomic::ReconcileDeliveryFacts 292 impl radroots_storage::authored_atomic::ReconcileDeliveryFacts 293 pub fn radroots_storage::authored_atomic::ReconcileDeliveryFacts::apply_to(&self, &radroots_storage::authored_delivery::AuthoredDeliveryHistory) -> core::result::Result<radroots_storage::authored_delivery::AuthoredDeliveryPlan, radroots_storage::Error> 294 pub fn radroots_storage::authored_atomic::ReconcileDeliveryFacts::new(&radroots_storage::authored_delivery::AuthoredDeliveryPlan, core::option::Option<radroots_storage::authored_atomic::WorkFence>, core::option::Option<radroots_storage::authored::RetrySchedule>, u64) -> core::result::Result<Self, radroots_storage::Error> 295 pub const fn radroots_storage::authored_atomic::ReconcileDeliveryFacts::plan_id(&self) -> radroots_storage::authored_delivery::AuthoredDeliveryPlanId 296 pub const fn radroots_storage::authored_atomic::ReconcileDeliveryFacts::reconciled_at_unix_ms(&self) -> u64 297 pub const fn radroots_storage::authored_atomic::ReconcileDeliveryFacts::revision(&self) -> core::num::nonzero::NonZeroU64 298 pub struct radroots_storage::authored_atomic::RecordDeliveryFact 299 impl radroots_storage::authored_atomic::RecordDeliveryFact 300 pub fn radroots_storage::authored_atomic::RecordDeliveryFact::apply_to(&self, &mut radroots_storage::authored_delivery::AuthoredDeliveryPlan, &radroots_storage::authored_atomic::AuthoredAtomicReceipt) -> core::result::Result<(), radroots_storage::Error> 301 pub const fn radroots_storage::authored_atomic::RecordDeliveryFact::artifact_id(&self) -> radroots_storage::authored::AuthoredArtifactId 302 pub const fn radroots_storage::authored_atomic::RecordDeliveryFact::claim(&self) -> &radroots_storage::authored::WorkClaim 303 pub fn radroots_storage::authored_atomic::RecordDeliveryFact::claim_command(&self) -> radroots_storage::authored_atomic::AuthoredAtomicCommand 304 pub fn radroots_storage::authored_atomic::RecordDeliveryFact::new(radroots_storage::authored_delivery::AuthoredDeliveryPlanId, radroots_storage::authored::AuthoredArtifactId, radroots_storage::authored::WorkClaim, radroots_storage::authored_delivery::DeliveryAttemptOutcome, u64) -> core::result::Result<Self, radroots_storage::Error> 305 pub const fn radroots_storage::authored_atomic::RecordDeliveryFact::observed_at_unix_ms(&self) -> u64 306 pub const fn radroots_storage::authored_atomic::RecordDeliveryFact::outcome(&self) -> &radroots_storage::authored_delivery::DeliveryAttemptOutcome 307 pub const fn radroots_storage::authored_atomic::RecordDeliveryFact::plan_id(&self) -> radroots_storage::authored_delivery::AuthoredDeliveryPlanId 308 pub struct radroots_storage::authored_atomic::RecordSignedArtifact 309 impl radroots_storage::authored_atomic::RecordSignedArtifact 310 pub fn radroots_storage::authored_atomic::RecordSignedArtifact::apply_to(&self, &mut radroots_storage::authored::AuthoredArtifact, &radroots_storage::authored_atomic::AuthoredAtomicReceipt) -> core::result::Result<(), radroots_storage::Error> 311 pub const fn radroots_storage::authored_atomic::RecordSignedArtifact::artifact_id(&self) -> radroots_storage::authored::AuthoredArtifactId 312 pub const fn radroots_storage::authored_atomic::RecordSignedArtifact::claim(&self) -> &radroots_storage::authored::WorkClaim 313 pub fn radroots_storage::authored_atomic::RecordSignedArtifact::claim_command(&self) -> radroots_storage::authored_atomic::AuthoredAtomicCommand 314 pub const fn radroots_storage::authored_atomic::RecordSignedArtifact::event(&self) -> &radroots_event::draft::SignedEvent 315 pub fn radroots_storage::authored_atomic::RecordSignedArtifact::new(radroots_storage::journal::OperationInstanceId, radroots_storage::authored::AuthoredArtifactId, radroots_storage::authored::WorkClaim, radroots_event::draft::SignedEvent, u64) -> core::result::Result<Self, radroots_storage::Error> 316 pub const fn radroots_storage::authored_atomic::RecordSignedArtifact::observed_at_unix_ms(&self) -> u64 317 pub const fn radroots_storage::authored_atomic::RecordSignedArtifact::operation_id(&self) -> radroots_storage::journal::OperationInstanceId 318 pub struct radroots_storage::authored_atomic::WorkFence 319 impl radroots_storage::authored_atomic::WorkFence 320 pub const fn radroots_storage::authored_atomic::WorkFence::generation(&self) -> core::num::nonzero::NonZeroU64 321 pub const fn radroots_storage::authored_atomic::WorkFence::new([u8; 16], core::num::nonzero::NonZeroU64, core::num::nonzero::NonZeroU64) -> core::result::Result<Self, radroots_storage::Error> 322 pub const fn radroots_storage::authored_atomic::WorkFence::row_revision(&self) -> core::num::nonzero::NonZeroU64 323 pub const fn radroots_storage::authored_atomic::WorkFence::token(&self) -> &[u8; 16] 324 pub trait radroots_storage::authored_atomic::AuthoredAtomicStorage: core::marker::Send + core::marker::Sync 325 pub fn radroots_storage::authored_atomic::AuthoredAtomicStorage::authored_artifact(&self, radroots_storage::authored::AuthoredArtifactId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::authored::AuthoredArtifact>, radroots_storage::Error>> 326 pub fn radroots_storage::authored_atomic::AuthoredAtomicStorage::authored_delivery_history(&self, radroots_storage::authored_delivery::AuthoredDeliveryPlanId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::authored_delivery::AuthoredDeliveryHistory>, radroots_storage::Error>> 327 pub fn radroots_storage::authored_atomic::AuthoredAtomicStorage::authored_delivery_plan(&self, radroots_storage::authored_delivery::AuthoredDeliveryPlanId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::authored_delivery::AuthoredDeliveryPlan>, radroots_storage::Error>> 328 pub fn radroots_storage::authored_atomic::AuthoredAtomicStorage::authored_operation(&self, radroots_storage::journal::OperationInstanceId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::authored::AuthoredOperation>, radroots_storage::Error>> 329 pub fn radroots_storage::authored_atomic::AuthoredAtomicStorage::authored_receipt(&self, radroots_storage::atomic::AtomicCommitId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::authored_atomic::AuthoredAtomicReceipt>, radroots_storage::Error>> 330 pub fn radroots_storage::authored_atomic::AuthoredAtomicStorage::execute_authored(&self, radroots_storage::authored_atomic::AuthoredAtomicCommand) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::authored_atomic::AuthoredAtomicReceipt, radroots_storage::Error>> 331 impl radroots_storage::authored_atomic::AuthoredAtomicStorage for radroots_storage::memory::MemoryStorage 332 pub fn radroots_storage::memory::MemoryStorage::authored_artifact(&self, radroots_storage::authored::AuthoredArtifactId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::authored::AuthoredArtifact>, radroots_storage::Error>> 333 pub fn radroots_storage::memory::MemoryStorage::authored_delivery_history(&self, radroots_storage::authored_delivery::AuthoredDeliveryPlanId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::authored_delivery::AuthoredDeliveryHistory>, radroots_storage::Error>> 334 pub fn radroots_storage::memory::MemoryStorage::authored_delivery_plan(&self, radroots_storage::authored_delivery::AuthoredDeliveryPlanId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::authored_delivery::AuthoredDeliveryPlan>, radroots_storage::Error>> 335 pub fn radroots_storage::memory::MemoryStorage::authored_operation(&self, radroots_storage::journal::OperationInstanceId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::authored::AuthoredOperation>, radroots_storage::Error>> 336 pub fn radroots_storage::memory::MemoryStorage::authored_receipt(&self, radroots_storage::atomic::AtomicCommitId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::authored_atomic::AuthoredAtomicReceipt>, radroots_storage::Error>> 337 pub fn radroots_storage::memory::MemoryStorage::execute_authored(&self, radroots_storage::authored_atomic::AuthoredAtomicCommand) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::authored_atomic::AuthoredAtomicReceipt, radroots_storage::Error>> 338 pub mod radroots_storage::authored_delivery 339 pub enum radroots_storage::authored_delivery::AuthoredDeliveryState 340 pub radroots_storage::authored_delivery::AuthoredDeliveryState::Cancelled 341 pub radroots_storage::authored_delivery::AuthoredDeliveryState::Exhausted 342 pub radroots_storage::authored_delivery::AuthoredDeliveryState::FailedTerminal 343 pub radroots_storage::authored_delivery::AuthoredDeliveryState::Pending 344 pub radroots_storage::authored_delivery::AuthoredDeliveryState::Retryable 345 pub radroots_storage::authored_delivery::AuthoredDeliveryState::Satisfied 346 impl radroots_storage::authored_delivery::AuthoredDeliveryState 347 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryState::is_terminal(self) -> bool 348 pub enum radroots_storage::authored_delivery::DeliveryAttemptOutcome 349 pub radroots_storage::authored_delivery::DeliveryAttemptOutcome::Receipt(radroots_transport::sink::DeliveryReceipt) 350 pub radroots_storage::authored_delivery::DeliveryAttemptOutcome::SinkFailure(radroots_transport::sink::SinkFailure) 351 pub struct radroots_storage::authored_delivery::AuthoredDeliveryAttempt 352 impl radroots_storage::authored_delivery::AuthoredDeliveryAttempt 353 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryAttempt::attempt(&self) -> core::num::nonzero::NonZeroU32 354 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryAttempt::claim_evidence(&self) -> core::option::Option<&radroots_storage::authored::WorkClaim> 355 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryAttempt::outcome(&self) -> &radroots_storage::authored_delivery::DeliveryAttemptOutcome 356 pub fn radroots_storage::authored_delivery::AuthoredDeliveryAttempt::reconstruct(core::num::nonzero::NonZeroU32, u64, radroots_storage::authored_delivery::DeliveryAttemptOutcome, radroots_transport::policy::SatisfactionState) -> core::result::Result<Self, radroots_storage::Error> 357 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryAttempt::recorded_at_unix_ms(&self) -> u64 358 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryAttempt::satisfaction(&self) -> radroots_transport::policy::SatisfactionState 359 pub struct radroots_storage::authored_delivery::AuthoredDeliveryClaim 360 impl radroots_storage::authored_delivery::AuthoredDeliveryClaim 361 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryClaim::claim(&self) -> &radroots_storage::authored::WorkClaim 362 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryClaim::prior_attempt_count(&self) -> u32 363 pub struct radroots_storage::authored_delivery::AuthoredDeliveryFact 364 impl radroots_storage::authored_delivery::AuthoredDeliveryFact 365 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryFact::claim(&self) -> &radroots_storage::authored::WorkClaim 366 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryFact::observed_at_unix_ms(&self) -> u64 367 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryFact::outcome(&self) -> &radroots_storage::authored_delivery::DeliveryAttemptOutcome 368 pub struct radroots_storage::authored_delivery::AuthoredDeliveryHistory 369 impl radroots_storage::authored_delivery::AuthoredDeliveryHistory 370 pub fn radroots_storage::authored_delivery::AuthoredDeliveryHistory::claims(&self) -> &[radroots_storage::authored_delivery::AuthoredDeliveryClaim] 371 pub fn radroots_storage::authored_delivery::AuthoredDeliveryHistory::has_unresolved_claims(&self) -> bool 372 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryHistory::is_complete(&self) -> bool 373 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryHistory::is_truncated(&self) -> bool 374 pub fn radroots_storage::authored_delivery::AuthoredDeliveryHistory::mark_truncated(&mut self) 375 pub fn radroots_storage::authored_delivery::AuthoredDeliveryHistory::new(radroots_storage::authored_delivery::AuthoredDeliveryPlan, core::option::Option<&radroots_storage::authored_atomic::AuthoredAtomicReceipt>) -> core::result::Result<Self, radroots_storage::Error> 376 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryHistory::plan(&self) -> &radroots_storage::authored_delivery::AuthoredDeliveryPlan 377 pub fn radroots_storage::authored_delivery::AuthoredDeliveryHistory::proves_no_issued_attempt(&self) -> bool 378 pub fn radroots_storage::authored_delivery::AuthoredDeliveryHistory::push_claim(&mut self, &radroots_storage::authored_atomic::AuthoredAtomicReceipt) -> core::result::Result<(), radroots_storage::Error> 379 pub fn radroots_storage::authored_delivery::AuthoredDeliveryHistory::require_pending_fact_provenance(&self) -> core::result::Result<(), radroots_storage::Error> 380 pub fn radroots_storage::authored_delivery::AuthoredDeliveryHistory::validate(&self) -> core::result::Result<(), radroots_storage::Error> 381 pub struct radroots_storage::authored_delivery::AuthoredDeliveryIntent 382 impl radroots_storage::authored_delivery::AuthoredDeliveryIntent 383 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryIntent::deadline_unix_ms(&self) -> u64 384 pub fn radroots_storage::authored_delivery::AuthoredDeliveryIntent::from_request(&radroots_transport::sink::DeliveryRequest) -> Self 385 pub fn radroots_storage::authored_delivery::AuthoredDeliveryIntent::materialize(&self, radroots_transport::sink::DeliveryPayload) -> core::result::Result<radroots_transport::sink::DeliveryRequest, radroots_storage::Error> 386 pub fn radroots_storage::authored_delivery::AuthoredDeliveryIntent::new(impl core::convert::Into<alloc::string::String>, radroots_transport::target::TargetSet, radroots_transport::policy::SatisfactionPolicy, u64) -> core::result::Result<Self, radroots_storage::Error> 387 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryIntent::request_id(&self) -> &radroots_transport::sink::DeliveryRequestId 388 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryIntent::satisfaction(&self) -> &radroots_transport::policy::SatisfactionPolicy 389 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryIntent::target_set(&self) -> &radroots_transport::target::TargetSet 390 pub struct radroots_storage::authored_delivery::AuthoredDeliveryPlan 391 impl radroots_storage::authored_delivery::AuthoredDeliveryPlan 392 pub fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::apply_receipt(&mut self, &[u8; 16], core::num::nonzero::NonZeroU64, core::num::nonzero::NonZeroU64, radroots_transport::sink::DeliveryReceipt, core::option::Option<radroots_storage::authored::RetrySchedule>, u64) -> core::result::Result<(), radroots_storage::Error> 393 pub fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::apply_sink_failure(&mut self, &[u8; 16], core::num::nonzero::NonZeroU64, core::num::nonzero::NonZeroU64, radroots_transport::sink::SinkFailure, core::option::Option<radroots_storage::authored::RetrySchedule>, u64) -> core::result::Result<(), radroots_storage::Error> 394 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::artifact_id(&self) -> radroots_storage::authored::AuthoredArtifactId 395 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::attempt_count(&self) -> u32 396 pub fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::attempts(&self) -> &[radroots_storage::authored_delivery::AuthoredDeliveryAttempt] 397 pub fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::bind_signed_event(&mut self, radroots_event::draft::SignedEvent, u64) -> core::result::Result<(), radroots_storage::Error> 398 pub fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::cancel(&mut self, u64) -> core::result::Result<(), radroots_storage::Error> 399 pub fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::claim(&mut self, radroots_storage::authored::WorkClaim, u64) -> core::result::Result<(), radroots_storage::Error> 400 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::claim_evidence(&self) -> core::option::Option<&radroots_storage::authored::WorkClaim> 401 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::created_at_unix_ms(&self) -> u64 402 pub fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::evaluate_next_attempt(&self, &radroots_storage::authored_delivery::DeliveryAttemptOutcome) -> core::result::Result<radroots_transport::policy::SatisfactionState, radroots_storage::Error> 403 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::intent(&self) -> &radroots_storage::authored_delivery::AuthoredDeliveryIntent 404 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::last_failure(&self) -> core::option::Option<&radroots_storage::authored::WorkFailure> 405 pub fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::new(radroots_storage::authored_delivery::AuthoredDeliveryPlanId, radroots_storage::authored::AuthoredArtifactId, radroots_storage::authored_delivery::AuthoredDeliveryIntent, u64) -> core::result::Result<Self, radroots_storage::Error> 406 pub fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::new_bound(radroots_storage::authored_delivery::AuthoredDeliveryPlanId, radroots_storage::authored::AuthoredArtifactId, radroots_transport::sink::DeliveryRequest, u64) -> core::result::Result<Self, radroots_storage::Error> 407 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::plan_id(&self) -> radroots_storage::authored_delivery::AuthoredDeliveryPlanId 408 pub fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::reconstruct(Self) -> core::result::Result<Self, radroots_storage::Error> 409 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::request(&self) -> core::option::Option<&radroots_transport::sink::DeliveryRequest> 410 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::request_digest(&self) -> &[u8; 32] 411 pub fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::request_stop(&mut self, u64) -> core::result::Result<(), radroots_storage::Error> 412 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::retry(&self) -> core::option::Option<&radroots_storage::authored::RetrySchedule> 413 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::revision(&self) -> core::num::nonzero::NonZeroU64 414 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::state(&self) -> radroots_storage::authored_delivery::AuthoredDeliveryState 415 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::updated_at_unix_ms(&self) -> u64 416 pub fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::validate(&self) -> core::result::Result<(), radroots_storage::Error> 417 impl radroots_storage::authored_delivery::AuthoredDeliveryPlan 418 pub fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::delivery_facts(&self) -> &[radroots_storage::authored_delivery::AuthoredDeliveryFact] 419 pub fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::delivery_satisfaction(&self) -> core::result::Result<radroots_transport::policy::SatisfactionState, radroots_storage::Error> 420 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::stop_requested_at_unix_ms(&self) -> core::option::Option<u64> 421 impl radroots_storage::authored_delivery::AuthoredDeliveryPlan 422 pub fn radroots_storage::authored_delivery::AuthoredDeliveryPlan::pending_delivery_facts(&self) -> impl core::iter::traits::iterator::Iterator<Item = &radroots_storage::authored_delivery::AuthoredDeliveryFact> 423 pub struct radroots_storage::authored_delivery::AuthoredDeliveryPlanId(_) 424 impl radroots_storage::authored_delivery::AuthoredDeliveryPlanId 425 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryPlanId::as_bytes(&self) -> &[u8; 16] 426 pub const fn radroots_storage::authored_delivery::AuthoredDeliveryPlanId::new([u8; 16]) -> core::result::Result<Self, radroots_storage::Error> 427 impl core::convert::From<radroots_storage::authored_delivery::AuthoredDeliveryPlanId> for [u8; 16] 428 pub fn [u8; 16]::from(radroots_storage::authored_delivery::AuthoredDeliveryPlanId) -> Self 429 impl core::convert::TryFrom<[u8; 16]> for radroots_storage::authored_delivery::AuthoredDeliveryPlanId 430 pub type radroots_storage::authored_delivery::AuthoredDeliveryPlanId::Error = radroots_storage::Error 431 pub fn radroots_storage::authored_delivery::AuthoredDeliveryPlanId::try_from([u8; 16]) -> core::result::Result<Self, Self::Error> 432 pub const radroots_storage::authored_delivery::DELIVERY_PLAN_ATTEMPTS_MAX: u32 433 pub mod radroots_storage::authored_draft 434 pub enum radroots_storage::authored_draft::AuthoredDraftStage 435 pub radroots_storage::authored_draft::AuthoredDraftStage::Cancelled 436 pub radroots_storage::authored_draft::AuthoredDraftStage::Draft 437 pub radroots_storage::authored_draft::AuthoredDraftStage::MediaPreparing 438 pub radroots_storage::authored_draft::AuthoredDraftStage::MediaUploading 439 pub radroots_storage::authored_draft::AuthoredDraftStage::Queued 440 pub radroots_storage::authored_draft::AuthoredDraftStage::ReadyToSign 441 impl radroots_storage::authored_draft::AuthoredDraftStage 442 pub const fn radroots_storage::authored_draft::AuthoredDraftStage::is_terminal(self) -> bool 443 pub enum radroots_storage::authored_draft::DraftAppendDisposition 444 pub radroots_storage::authored_draft::DraftAppendDisposition::Inserted 445 pub radroots_storage::authored_draft::DraftAppendDisposition::Replay 446 pub struct radroots_storage::authored_draft::AuthoredDraft 447 impl radroots_storage::authored_draft::AuthoredDraft 448 pub const fn radroots_storage::authored_draft::AuthoredDraft::author(&self) -> &[u8; 32] 449 pub const fn radroots_storage::authored_draft::AuthoredDraft::created_at_unix_ms(&self) -> u64 450 pub const fn radroots_storage::authored_draft::AuthoredDraft::draft_id(&self) -> radroots_storage::authored_draft::AuthoredDraftId 451 pub fn radroots_storage::authored_draft::AuthoredDraft::initial(radroots_storage::authored_draft::AuthoredDraftId, [u8; 32], impl core::convert::Into<alloc::string::String>, alloc::vec::Vec<u8>, radroots_storage::authored_draft::AuthoredDraftStage, core::option::Option<radroots_storage::journal::OperationInstanceId>, u64) -> core::result::Result<Self, radroots_storage::Error> 452 pub const fn radroots_storage::authored_draft::AuthoredDraft::operation_id(&self) -> core::option::Option<radroots_storage::journal::OperationInstanceId> 453 pub fn radroots_storage::authored_draft::AuthoredDraft::payload(&self) -> &[u8] 454 pub fn radroots_storage::authored_draft::AuthoredDraft::payload_schema(&self) -> &str 455 pub const fn radroots_storage::authored_draft::AuthoredDraft::payload_sha256(&self) -> &[u8; 32] 456 pub fn radroots_storage::authored_draft::AuthoredDraft::reconstruct(radroots_storage::authored_draft::AuthoredDraftId, radroots_storage::authored_draft::AuthoredDraftRevision, [u8; 32], impl core::convert::Into<alloc::string::String>, alloc::vec::Vec<u8>, [u8; 32], radroots_storage::authored_draft::AuthoredDraftStage, core::option::Option<radroots_storage::journal::OperationInstanceId>, u64, u64) -> core::result::Result<Self, radroots_storage::Error> 457 pub const fn radroots_storage::authored_draft::AuthoredDraft::revision(&self) -> radroots_storage::authored_draft::AuthoredDraftRevision 458 pub const fn radroots_storage::authored_draft::AuthoredDraft::scope(&self) -> core::option::Option<radroots_storage::authored_draft_query::AuthoredDraftScope> 459 pub const fn radroots_storage::authored_draft::AuthoredDraft::stage(&self) -> radroots_storage::authored_draft::AuthoredDraftStage 460 pub fn radroots_storage::authored_draft::AuthoredDraft::successor(&self, alloc::vec::Vec<u8>, radroots_storage::authored_draft::AuthoredDraftStage, core::option::Option<radroots_storage::journal::OperationInstanceId>, u64) -> core::result::Result<Self, radroots_storage::Error> 461 pub const fn radroots_storage::authored_draft::AuthoredDraft::updated_at_unix_ms(&self) -> u64 462 pub fn radroots_storage::authored_draft::AuthoredDraft::validate(&self) -> core::result::Result<(), radroots_storage::Error> 463 pub fn radroots_storage::authored_draft::AuthoredDraft::validate_successor_of(&self, &Self) -> core::result::Result<(), radroots_storage::Error> 464 pub fn radroots_storage::authored_draft::AuthoredDraft::with_scope(self, radroots_storage::authored_draft_query::AuthoredDraftScope) -> core::result::Result<Self, radroots_storage::Error> 465 pub struct radroots_storage::authored_draft::AuthoredDraftId(_) 466 impl radroots_storage::authored_draft::AuthoredDraftId 467 pub const fn radroots_storage::authored_draft::AuthoredDraftId::as_bytes(&self) -> &[u8; 16] 468 pub const fn radroots_storage::authored_draft::AuthoredDraftId::new([u8; 16]) -> core::result::Result<Self, radroots_storage::Error> 469 impl core::convert::From<radroots_storage::authored_draft::AuthoredDraftId> for [u8; 16] 470 pub fn [u8; 16]::from(radroots_storage::authored_draft::AuthoredDraftId) -> Self 471 impl core::convert::TryFrom<[u8; 16]> for radroots_storage::authored_draft::AuthoredDraftId 472 pub type radroots_storage::authored_draft::AuthoredDraftId::Error = radroots_storage::Error 473 pub fn radroots_storage::authored_draft::AuthoredDraftId::try_from([u8; 16]) -> core::result::Result<Self, Self::Error> 474 pub struct radroots_storage::authored_draft::AuthoredDraftRevision(_) 475 impl radroots_storage::authored_draft::AuthoredDraftRevision 476 pub const radroots_storage::authored_draft::AuthoredDraftRevision::INITIAL: Self 477 pub const fn radroots_storage::authored_draft::AuthoredDraftRevision::get(self) -> u64 478 pub const fn radroots_storage::authored_draft::AuthoredDraftRevision::new(u64) -> core::result::Result<Self, radroots_storage::Error> 479 pub fn radroots_storage::authored_draft::AuthoredDraftRevision::next(self) -> core::result::Result<Self, radroots_storage::Error> 480 impl core::convert::From<radroots_storage::authored_draft::AuthoredDraftRevision> for u64 481 pub fn u64::from(radroots_storage::authored_draft::AuthoredDraftRevision) -> Self 482 impl core::convert::TryFrom<u64> for radroots_storage::authored_draft::AuthoredDraftRevision 483 pub type radroots_storage::authored_draft::AuthoredDraftRevision::Error = radroots_storage::Error 484 pub fn radroots_storage::authored_draft::AuthoredDraftRevision::try_from(u64) -> core::result::Result<Self, Self::Error> 485 pub struct radroots_storage::authored_draft::DraftAppendReceipt 486 impl radroots_storage::authored_draft::DraftAppendReceipt 487 pub const fn radroots_storage::authored_draft::DraftAppendReceipt::disposition(&self) -> radroots_storage::authored_draft::DraftAppendDisposition 488 pub const fn radroots_storage::authored_draft::DraftAppendReceipt::draft(&self) -> &radroots_storage::authored_draft::AuthoredDraft 489 pub const fn radroots_storage::authored_draft::DraftAppendReceipt::new(radroots_storage::authored_draft::AuthoredDraft, radroots_storage::authored_draft::DraftAppendDisposition) -> Self 490 pub const radroots_storage::authored_draft::AUTHORED_DRAFT_PAYLOAD_MAX_BYTES: usize 491 pub const radroots_storage::authored_draft::AUTHORED_DRAFT_QUERY_LIMIT_MAX: u16 492 pub const radroots_storage::authored_draft::AUTHORED_DRAFT_SCHEMA_MAX_BYTES: usize 493 pub trait radroots_storage::authored_draft::AuthoredDraftStore: core::marker::Send + core::marker::Sync 494 pub fn radroots_storage::authored_draft::AuthoredDraftStore::append_authored_draft(&self, radroots_storage::authored_draft::AuthoredDraft, core::option::Option<radroots_storage::authored_draft::AuthoredDraftRevision>) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::authored_draft::DraftAppendReceipt, radroots_storage::Error>> 495 pub fn radroots_storage::authored_draft::AuthoredDraftStore::append_authored_draft_pair(&self, radroots_storage::authored_draft_pair::AuthoredDraftPair) -> radroots_transport::source::BoxFuture<'_, core::result::Result<[radroots_storage::authored_draft::DraftAppendReceipt; 2], radroots_storage::Error>> 496 pub fn radroots_storage::authored_draft::AuthoredDraftStore::authored_draft_head(&self, radroots_storage::authored_draft::AuthoredDraftId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::authored_draft::AuthoredDraft>, radroots_storage::Error>> 497 pub fn radroots_storage::authored_draft::AuthoredDraftStore::authored_draft_heads(&self, [u8; 32], u16) -> radroots_transport::source::BoxFuture<'_, core::result::Result<alloc::vec::Vec<radroots_storage::authored_draft::AuthoredDraft>, radroots_storage::Error>> 498 pub fn radroots_storage::authored_draft::AuthoredDraftStore::authored_draft_revision(&self, radroots_storage::authored_draft::AuthoredDraftId, radroots_storage::authored_draft::AuthoredDraftRevision) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::authored_draft::AuthoredDraft>, radroots_storage::Error>> 499 pub fn radroots_storage::authored_draft::AuthoredDraftStore::query_authored_drafts(&self, radroots_storage::authored_draft_query::AuthoredDraftQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::authored_draft_query::AuthoredDraftPage, radroots_storage::Error>> 500 impl radroots_storage::authored_draft::AuthoredDraftStore for radroots_storage::memory::MemoryStorage 501 pub fn radroots_storage::memory::MemoryStorage::append_authored_draft(&self, radroots_storage::authored_draft::AuthoredDraft, core::option::Option<radroots_storage::authored_draft::AuthoredDraftRevision>) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::authored_draft::DraftAppendReceipt, radroots_storage::Error>> 502 pub fn radroots_storage::memory::MemoryStorage::append_authored_draft_pair(&self, radroots_storage::authored_draft_pair::AuthoredDraftPair) -> radroots_transport::source::BoxFuture<'_, core::result::Result<[radroots_storage::authored_draft::DraftAppendReceipt; 2], radroots_storage::Error>> 503 pub fn radroots_storage::memory::MemoryStorage::authored_draft_head(&self, radroots_storage::authored_draft::AuthoredDraftId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::authored_draft::AuthoredDraft>, radroots_storage::Error>> 504 pub fn radroots_storage::memory::MemoryStorage::authored_draft_heads(&self, [u8; 32], u16) -> radroots_transport::source::BoxFuture<'_, core::result::Result<alloc::vec::Vec<radroots_storage::authored_draft::AuthoredDraft>, radroots_storage::Error>> 505 pub fn radroots_storage::memory::MemoryStorage::authored_draft_revision(&self, radroots_storage::authored_draft::AuthoredDraftId, radroots_storage::authored_draft::AuthoredDraftRevision) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::authored_draft::AuthoredDraft>, radroots_storage::Error>> 506 pub fn radroots_storage::memory::MemoryStorage::query_authored_drafts(&self, radroots_storage::authored_draft_query::AuthoredDraftQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::authored_draft_query::AuthoredDraftPage, radroots_storage::Error>> 507 pub mod radroots_storage::authored_draft_pair 508 pub struct radroots_storage::authored_draft_pair::AuthoredDraftPair 509 impl radroots_storage::authored_draft_pair::AuthoredDraftPair 510 pub const fn radroots_storage::authored_draft_pair::AuthoredDraftPair::drafts(&self) -> &[radroots_storage::authored_draft::AuthoredDraft; 2] 511 pub const fn radroots_storage::authored_draft_pair::AuthoredDraftPair::expected_heads(&self) -> &[core::option::Option<radroots_storage::authored_draft::AuthoredDraftRevision>; 2] 512 pub fn radroots_storage::authored_draft_pair::AuthoredDraftPair::new(radroots_storage::authored_draft::AuthoredDraft, core::option::Option<radroots_storage::authored_draft::AuthoredDraftRevision>, radroots_storage::authored_draft::AuthoredDraft, core::option::Option<radroots_storage::authored_draft::AuthoredDraftRevision>) -> core::result::Result<Self, radroots_storage::Error> 513 pub mod radroots_storage::authored_draft_query 514 pub enum radroots_storage::authored_draft_query::AuthoredDraftQueryRecord 515 pub radroots_storage::authored_draft_query::AuthoredDraftQueryRecord::Corrupt 516 pub radroots_storage::authored_draft_query::AuthoredDraftQueryRecord::Corrupt::draft_key: [u8; 16] 517 pub radroots_storage::authored_draft_query::AuthoredDraftQueryRecord::Corrupt::revision: radroots_storage::authored_draft::AuthoredDraftRevision 518 pub radroots_storage::authored_draft_query::AuthoredDraftQueryRecord::Draft(radroots_storage::authored_draft::AuthoredDraft) 519 impl radroots_storage::authored_draft_query::AuthoredDraftQueryRecord 520 pub fn radroots_storage::authored_draft_query::AuthoredDraftQueryRecord::draft_id(&self) -> core::result::Result<radroots_storage::authored_draft::AuthoredDraftId, radroots_storage::Error> 521 pub fn radroots_storage::authored_draft_query::AuthoredDraftQueryRecord::draft_key(&self) -> [u8; 16] 522 pub const fn radroots_storage::authored_draft_query::AuthoredDraftQueryRecord::revision(&self) -> radroots_storage::authored_draft::AuthoredDraftRevision 523 impl core::fmt::Debug for radroots_storage::authored_draft_query::AuthoredDraftQueryRecord 524 pub fn radroots_storage::authored_draft_query::AuthoredDraftQueryRecord::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 525 pub struct radroots_storage::authored_draft_query::AuthoredDraftCursor 526 pub struct radroots_storage::authored_draft_query::AuthoredDraftPage 527 impl radroots_storage::authored_draft_query::AuthoredDraftPage 528 pub fn radroots_storage::authored_draft_query::AuthoredDraftPage::into_records(self) -> alloc::vec::Vec<radroots_storage::authored_draft_query::AuthoredDraftQueryRecord> 529 pub fn radroots_storage::authored_draft_query::AuthoredDraftPage::new(&radroots_storage::authored_draft_query::AuthoredDraftQuery, alloc::vec::Vec<radroots_storage::authored_draft_query::AuthoredDraftQueryRecord>, bool) -> core::result::Result<Self, radroots_storage::Error> 530 pub const fn radroots_storage::authored_draft_query::AuthoredDraftPage::next_cursor(&self) -> core::option::Option<&radroots_storage::authored_draft_query::AuthoredDraftCursor> 531 pub fn radroots_storage::authored_draft_query::AuthoredDraftPage::records(&self) -> &[radroots_storage::authored_draft_query::AuthoredDraftQueryRecord] 532 pub struct radroots_storage::authored_draft_query::AuthoredDraftQuery 533 impl radroots_storage::authored_draft_query::AuthoredDraftQuery 534 pub const fn radroots_storage::authored_draft_query::AuthoredDraftQuery::after(&self) -> core::option::Option<[u8; 16]> 535 pub const fn radroots_storage::authored_draft_query::AuthoredDraftQuery::author(&self) -> &[u8; 32] 536 pub fn radroots_storage::authored_draft_query::AuthoredDraftQuery::cursor_after(&self, [u8; 16]) -> radroots_storage::authored_draft_query::AuthoredDraftCursor 537 pub fn radroots_storage::authored_draft_query::AuthoredDraftQuery::for_author([u8; 32], impl core::convert::AsRef<str>, u16) -> core::result::Result<Self, radroots_storage::Error> 538 pub fn radroots_storage::authored_draft_query::AuthoredDraftQuery::for_author_all_schemas([u8; 32], u16) -> core::result::Result<Self, radroots_storage::Error> 539 pub const fn radroots_storage::authored_draft_query::AuthoredDraftQuery::is_author_wide(&self) -> bool 540 pub const fn radroots_storage::authored_draft_query::AuthoredDraftQuery::limit(&self) -> u16 541 pub fn radroots_storage::authored_draft_query::AuthoredDraftQuery::matches(&self, &radroots_storage::authored_draft::AuthoredDraft) -> bool 542 pub fn radroots_storage::authored_draft_query::AuthoredDraftQuery::new([u8; 32], impl core::convert::AsRef<str>, core::option::Option<radroots_storage::authored_draft_query::AuthoredDraftScope>, u16) -> core::result::Result<Self, radroots_storage::Error> 543 pub fn radroots_storage::authored_draft_query::AuthoredDraftQuery::payload_schema(&self) -> core::option::Option<&str> 544 pub const fn radroots_storage::authored_draft_query::AuthoredDraftQuery::scope(&self) -> core::option::Option<radroots_storage::authored_draft_query::AuthoredDraftScope> 545 pub fn radroots_storage::authored_draft_query::AuthoredDraftQuery::with_cursor(self, &radroots_storage::authored_draft_query::AuthoredDraftCursor) -> core::result::Result<Self, radroots_storage::Error> 546 pub struct radroots_storage::authored_draft_query::AuthoredDraftScope(_) 547 impl radroots_storage::authored_draft_query::AuthoredDraftScope 548 pub const fn radroots_storage::authored_draft_query::AuthoredDraftScope::as_bytes(&self) -> &[u8; 32] 549 pub fn radroots_storage::authored_draft_query::AuthoredDraftScope::new([u8; 32]) -> core::result::Result<Self, radroots_storage::Error> 550 impl core::convert::From<radroots_storage::authored_draft_query::AuthoredDraftScope> for [u8; 32] 551 pub fn [u8; 32]::from(radroots_storage::authored_draft_query::AuthoredDraftScope) -> Self 552 impl core::convert::TryFrom<[u8; 32]> for radroots_storage::authored_draft_query::AuthoredDraftScope 553 pub type radroots_storage::authored_draft_query::AuthoredDraftScope::Error = radroots_storage::Error 554 pub fn radroots_storage::authored_draft_query::AuthoredDraftScope::try_from([u8; 32]) -> core::result::Result<Self, radroots_storage::Error> 555 pub const radroots_storage::authored_draft_query::AUTHORED_DRAFT_ALL_SCHEMAS_CURSOR_SCHEMA_VERSION: u16 556 pub const radroots_storage::authored_draft_query::AUTHORED_DRAFT_AUTHOR_CURSOR_SCHEMA_VERSION: u16 557 pub const radroots_storage::authored_draft_query::AUTHORED_DRAFT_CURSOR_SCHEMA_VERSION: u16 558 pub const radroots_storage::authored_draft_query::AUTHORED_DRAFT_PAGE_PAYLOAD_MAX_BYTES: usize 559 pub const radroots_storage::authored_draft_query::AUTHORED_DRAFT_PAGE_SNAPSHOT_MAX_BYTES: usize 560 pub mod radroots_storage::authored_draft_submission 561 pub struct radroots_storage::authored_draft_submission::AuthoredDraftSource 562 impl radroots_storage::authored_draft_submission::AuthoredDraftSource 563 pub const fn radroots_storage::authored_draft_submission::AuthoredDraftSource::author(&self) -> &[u8; 32] 564 pub fn radroots_storage::authored_draft_submission::AuthoredDraftSource::capture(&radroots_storage::authored_draft::AuthoredDraft) -> core::result::Result<Self, radroots_storage::Error> 565 pub const fn radroots_storage::authored_draft_submission::AuthoredDraftSource::draft_id(&self) -> radroots_storage::authored_draft::AuthoredDraftId 566 pub fn radroots_storage::authored_draft_submission::AuthoredDraftSource::matches(&self, &radroots_storage::authored_draft::AuthoredDraft) -> bool 567 pub fn radroots_storage::authored_draft_submission::AuthoredDraftSource::payload_schema(&self) -> &str 568 pub const fn radroots_storage::authored_draft_submission::AuthoredDraftSource::payload_sha256(&self) -> &[u8; 32] 569 pub const fn radroots_storage::authored_draft_submission::AuthoredDraftSource::revision(&self) -> radroots_storage::authored_draft::AuthoredDraftRevision 570 pub const fn radroots_storage::authored_draft_submission::AuthoredDraftSource::scope(&self) -> core::option::Option<radroots_storage::authored_draft_query::AuthoredDraftScope> 571 pub struct radroots_storage::authored_draft_submission::PrepareFromDraft 572 impl radroots_storage::authored_draft_submission::PrepareFromDraft 573 pub const fn radroots_storage::authored_draft_submission::PrepareFromDraft::command_id(&self) -> radroots_storage::atomic::AtomicCommitId 574 pub fn radroots_storage::authored_draft_submission::PrepareFromDraft::commit_id(&self) -> radroots_storage::atomic::AtomicCommitId 575 pub fn radroots_storage::authored_draft_submission::PrepareFromDraft::commit_id_for(&[u8; 32], radroots_storage::atomic::AtomicCommitId) -> radroots_storage::atomic::AtomicCommitId 576 pub const fn radroots_storage::authored_draft_submission::PrepareFromDraft::intent(&self) -> &radroots_storage::authored_draft::AuthoredDraft 577 pub fn radroots_storage::authored_draft_submission::PrepareFromDraft::new(radroots_storage::atomic::AtomicCommitId, radroots_storage::authored_draft_submission::AuthoredDraftSource, radroots_storage::authored_draft::AuthoredDraft, radroots_storage::authored_atomic::PrepareAuthoredOperation) -> core::result::Result<Self, radroots_storage::Error> 578 pub fn radroots_storage::authored_draft_submission::PrepareFromDraft::new_waiting(radroots_storage::atomic::AtomicCommitId, radroots_storage::authored_draft_submission::AuthoredDraftSource, radroots_storage::authored_draft::AuthoredDraft, radroots_storage::authored_atomic::PrepareAuthoredOperation) -> core::result::Result<Self, radroots_storage::Error> 579 pub const fn radroots_storage::authored_draft_submission::PrepareFromDraft::preparation(&self) -> &radroots_storage::authored_atomic::PrepareAuthoredOperation 580 pub const fn radroots_storage::authored_draft_submission::PrepareFromDraft::source(&self) -> &radroots_storage::authored_draft_submission::AuthoredDraftSource 581 pub fn radroots_storage::authored_draft_submission::PrepareFromDraft::validate(&self) -> core::result::Result<(), radroots_storage::Error> 582 impl core::fmt::Debug for radroots_storage::authored_draft_submission::PrepareFromDraft 583 pub fn radroots_storage::authored_draft_submission::PrepareFromDraft::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 584 pub mod radroots_storage::backup 585 #[non_exhaustive] pub enum radroots_storage::backup::BackupCapabilityError 586 pub radroots_storage::backup::BackupCapabilityError::Conflict 587 pub radroots_storage::backup::BackupCapabilityError::Failed 588 pub radroots_storage::backup::BackupCapabilityError::InvalidConfiguration 589 pub radroots_storage::backup::BackupCapabilityError::Unavailable 590 pub radroots_storage::backup::BackupCapabilityError::Unsupported 591 pub radroots_storage::backup::BackupCapabilityError::UnsupportedVersion 592 pub radroots_storage::backup::BackupCapabilityError::VerificationFailed 593 impl core::error::Error for radroots_storage::backup::BackupCapabilityError 594 impl core::fmt::Display for radroots_storage::backup::BackupCapabilityError 595 pub fn radroots_storage::backup::BackupCapabilityError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 596 pub enum radroots_storage::backup::BackupMemberKind 597 pub radroots_storage::backup::BackupMemberKind::Metadata 598 pub radroots_storage::backup::BackupMemberKind::Protected 599 pub radroots_storage::backup::BackupMemberKind::Runtime 600 pub enum radroots_storage::backup::BackupSecretPolicy 601 pub radroots_storage::backup::BackupSecretPolicy::ExcludeProtectedStorage 602 pub radroots_storage::backup::BackupSecretPolicy::IncludeProtectedStorage 603 pub enum radroots_storage::backup::BackupStage 604 pub radroots_storage::backup::BackupStage::Captured 605 pub radroots_storage::backup::BackupStage::Failed 606 pub radroots_storage::backup::BackupStage::Finalized 607 pub radroots_storage::backup::BackupStage::Planned 608 pub radroots_storage::backup::BackupStage::Verified 609 pub enum radroots_storage::backup::BackupTransition 610 pub radroots_storage::backup::BackupTransition::Captured(radroots_storage::backup::BackupManifest) 611 pub radroots_storage::backup::BackupTransition::Fail 612 pub radroots_storage::backup::BackupTransition::Finalize 613 pub radroots_storage::backup::BackupTransition::Verified 614 pub enum radroots_storage::backup::MemberVerification 615 pub radroots_storage::backup::MemberVerification::HashMismatch 616 pub radroots_storage::backup::MemberVerification::LengthMismatch 617 pub radroots_storage::backup::MemberVerification::Missing 618 pub radroots_storage::backup::MemberVerification::Unexpected 619 pub radroots_storage::backup::MemberVerification::UnsafePath 620 pub radroots_storage::backup::MemberVerification::Verified 621 #[non_exhaustive] pub enum radroots_storage::backup::RestoreCapabilityError 622 pub radroots_storage::backup::RestoreCapabilityError::Conflict 623 pub radroots_storage::backup::RestoreCapabilityError::Failed 624 pub radroots_storage::backup::RestoreCapabilityError::InvalidConfiguration 625 pub radroots_storage::backup::RestoreCapabilityError::Unavailable 626 pub radroots_storage::backup::RestoreCapabilityError::Unsupported 627 pub radroots_storage::backup::RestoreCapabilityError::UnsupportedVersion 628 pub radroots_storage::backup::RestoreCapabilityError::VerificationFailed 629 impl core::error::Error for radroots_storage::backup::RestoreCapabilityError 630 impl core::fmt::Display for radroots_storage::backup::RestoreCapabilityError 631 pub fn radroots_storage::backup::RestoreCapabilityError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 632 pub enum radroots_storage::backup::RestoreStage 633 pub radroots_storage::backup::RestoreStage::Failed 634 pub radroots_storage::backup::RestoreStage::Finalized 635 pub radroots_storage::backup::RestoreStage::Finalizing 636 pub radroots_storage::backup::RestoreStage::Staging 637 pub radroots_storage::backup::RestoreStage::Verifying 638 pub enum radroots_storage::backup::RestoreTransition 639 pub radroots_storage::backup::RestoreTransition::Fail 640 pub radroots_storage::backup::RestoreTransition::Finalize 641 pub radroots_storage::backup::RestoreTransition::Staged 642 pub radroots_storage::backup::RestoreTransition::Verified(alloc::vec::Vec<radroots_storage::backup::RestoreMemberStatus>) 643 pub struct radroots_storage::backup::BackupFormatVersion(_) 644 impl radroots_storage::backup::BackupFormatVersion 645 pub const radroots_storage::backup::BackupFormatVersion::V1: Self 646 pub const fn radroots_storage::backup::BackupFormatVersion::get(self) -> u16 647 pub const fn radroots_storage::backup::BackupFormatVersion::new(u16) -> core::result::Result<Self, radroots_storage::Error> 648 impl<'de> serde_core::de::Deserialize<'de> for radroots_storage::backup::BackupFormatVersion 649 pub fn radroots_storage::backup::BackupFormatVersion::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 650 pub struct radroots_storage::backup::BackupId(_) 651 impl radroots_storage::backup::BackupId 652 pub const fn radroots_storage::backup::BackupId::as_bytes(&self) -> &[u8; 16] 653 pub const fn radroots_storage::backup::BackupId::new([u8; 16]) -> core::result::Result<Self, radroots_storage::Error> 654 impl<'de> serde_core::de::Deserialize<'de> for radroots_storage::backup::BackupId 655 pub fn radroots_storage::backup::BackupId::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 656 pub struct radroots_storage::backup::BackupManifest 657 impl radroots_storage::backup::BackupManifest 658 pub const fn radroots_storage::backup::BackupManifest::backup_id(&self) -> radroots_storage::backup::BackupId 659 pub const fn radroots_storage::backup::BackupManifest::created_at_unix_ms(&self) -> u64 660 pub const fn radroots_storage::backup::BackupManifest::format_version(&self) -> radroots_storage::backup::BackupFormatVersion 661 pub fn radroots_storage::backup::BackupManifest::member(&self, &str) -> core::option::Option<&radroots_storage::backup::BackupMember> 662 pub fn radroots_storage::backup::BackupManifest::members(&self) -> &[radroots_storage::backup::BackupMember] 663 pub fn radroots_storage::backup::BackupManifest::new(radroots_storage::backup::BackupFormatVersion, radroots_storage::backup::BackupId, u64, radroots_storage::backup::BackupSecretPolicy, alloc::vec::Vec<radroots_storage::backup::BackupMember>) -> core::result::Result<Self, radroots_storage::Error> 664 pub const fn radroots_storage::backup::BackupManifest::secret_policy(&self) -> radroots_storage::backup::BackupSecretPolicy 665 pub const fn radroots_storage::backup::BackupManifest::total_bytes(&self) -> u64 666 impl<'de> serde_core::de::Deserialize<'de> for radroots_storage::backup::BackupManifest 667 pub fn radroots_storage::backup::BackupManifest::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 668 pub struct radroots_storage::backup::BackupMember 669 impl radroots_storage::backup::BackupMember 670 pub const fn radroots_storage::backup::BackupMember::byte_length(&self) -> u64 671 pub const fn radroots_storage::backup::BackupMember::kind(&self) -> radroots_storage::backup::BackupMemberKind 672 pub fn radroots_storage::backup::BackupMember::new(impl core::convert::Into<alloc::string::String>, radroots_storage::backup::BackupMemberKind, u64, radroots_storage::backup::MemberDigest) -> core::result::Result<Self, radroots_storage::Error> 673 pub fn radroots_storage::backup::BackupMember::relative_path(&self) -> &str 674 pub const fn radroots_storage::backup::BackupMember::sha256(&self) -> radroots_storage::backup::MemberDigest 675 impl<'de> serde_core::de::Deserialize<'de> for radroots_storage::backup::BackupMember 676 pub fn radroots_storage::backup::BackupMember::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 677 pub struct radroots_storage::backup::BackupOperation 678 impl radroots_storage::backup::BackupOperation 679 pub const fn radroots_storage::backup::BackupOperation::manifest(&self) -> core::option::Option<&radroots_storage::backup::BackupManifest> 680 pub const fn radroots_storage::backup::BackupOperation::plan(&self) -> &radroots_storage::backup::BackupPlan 681 pub const fn radroots_storage::backup::BackupOperation::planned(radroots_storage::backup::BackupPlan) -> Self 682 pub const fn radroots_storage::backup::BackupOperation::revision(&self) -> radroots_storage::backup::ReliabilityRevision 683 pub const fn radroots_storage::backup::BackupOperation::stage(&self) -> radroots_storage::backup::BackupStage 684 pub fn radroots_storage::backup::BackupOperation::transition(&self, radroots_storage::backup::ReliabilityRevision, radroots_storage::backup::BackupTransition, u64) -> core::result::Result<Self, radroots_storage::Error> 685 pub const fn radroots_storage::backup::BackupOperation::updated_at_unix_ms(&self) -> u64 686 pub struct radroots_storage::backup::BackupPlan 687 impl radroots_storage::backup::BackupPlan 688 pub const fn radroots_storage::backup::BackupPlan::backup_id(&self) -> radroots_storage::backup::BackupId 689 pub const fn radroots_storage::backup::BackupPlan::format_version(&self) -> radroots_storage::backup::BackupFormatVersion 690 pub const fn radroots_storage::backup::BackupPlan::new(radroots_storage::backup::BackupId, radroots_storage::backup::BackupFormatVersion, radroots_storage::backup::BackupSecretPolicy, u64) -> core::result::Result<Self, radroots_storage::Error> 691 pub const fn radroots_storage::backup::BackupPlan::requested_at_unix_ms(&self) -> u64 692 pub const fn radroots_storage::backup::BackupPlan::secret_policy(&self) -> radroots_storage::backup::BackupSecretPolicy 693 impl<'de> serde_core::de::Deserialize<'de> for radroots_storage::backup::BackupPlan 694 pub fn radroots_storage::backup::BackupPlan::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 695 pub struct radroots_storage::backup::MemberDigest(_) 696 impl radroots_storage::backup::MemberDigest 697 pub const fn radroots_storage::backup::MemberDigest::as_bytes(&self) -> &[u8; 32] 698 pub const fn radroots_storage::backup::MemberDigest::new([u8; 32]) -> Self 699 pub struct radroots_storage::backup::ReliabilityRevision(_) 700 impl radroots_storage::backup::ReliabilityRevision 701 pub const radroots_storage::backup::ReliabilityRevision::INITIAL: Self 702 pub const fn radroots_storage::backup::ReliabilityRevision::get(self) -> u64 703 pub const fn radroots_storage::backup::ReliabilityRevision::new(u64) -> core::result::Result<Self, radroots_storage::Error> 704 impl<'de> serde_core::de::Deserialize<'de> for radroots_storage::backup::ReliabilityRevision 705 pub fn radroots_storage::backup::ReliabilityRevision::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 706 pub struct radroots_storage::backup::RestoreMemberStatus 707 impl radroots_storage::backup::RestoreMemberStatus 708 pub fn radroots_storage::backup::RestoreMemberStatus::new(impl core::convert::Into<alloc::string::String>, radroots_storage::backup::MemberVerification) -> core::result::Result<Self, radroots_storage::Error> 709 pub fn radroots_storage::backup::RestoreMemberStatus::relative_path(&self) -> &str 710 pub const fn radroots_storage::backup::RestoreMemberStatus::verification(&self) -> radroots_storage::backup::MemberVerification 711 impl<'de> serde_core::de::Deserialize<'de> for radroots_storage::backup::RestoreMemberStatus 712 pub fn radroots_storage::backup::RestoreMemberStatus::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 713 pub struct radroots_storage::backup::RestoreOperation 714 impl radroots_storage::backup::RestoreOperation 715 pub fn radroots_storage::backup::RestoreOperation::member_status(&self) -> &[radroots_storage::backup::RestoreMemberStatus] 716 pub const fn radroots_storage::backup::RestoreOperation::plan(&self) -> &radroots_storage::backup::RestorePlan 717 pub const fn radroots_storage::backup::RestoreOperation::revision(&self) -> radroots_storage::backup::ReliabilityRevision 718 pub const fn radroots_storage::backup::RestoreOperation::stage(&self) -> radroots_storage::backup::RestoreStage 719 pub const fn radroots_storage::backup::RestoreOperation::staging(radroots_storage::backup::RestorePlan) -> Self 720 pub fn radroots_storage::backup::RestoreOperation::transition(&self, radroots_storage::backup::ReliabilityRevision, radroots_storage::backup::RestoreTransition, u64) -> core::result::Result<Self, radroots_storage::Error> 721 pub struct radroots_storage::backup::RestorePlan 722 impl radroots_storage::backup::RestorePlan 723 pub const fn radroots_storage::backup::RestorePlan::accepted_secret_policy(&self) -> radroots_storage::backup::BackupSecretPolicy 724 pub const fn radroots_storage::backup::RestorePlan::manifest(&self) -> &radroots_storage::backup::BackupManifest 725 pub fn radroots_storage::backup::RestorePlan::new(radroots_storage::backup::BackupManifest, radroots_storage::backup::BackupSecretPolicy, u64) -> core::result::Result<Self, radroots_storage::Error> 726 pub const fn radroots_storage::backup::RestorePlan::requested_at_unix_ms(&self) -> u64 727 impl<'de> serde_core::de::Deserialize<'de> for radroots_storage::backup::RestorePlan 728 pub fn radroots_storage::backup::RestorePlan::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 729 pub const radroots_storage::backup::BACKUP_MEMBER_MAX: usize 730 pub const radroots_storage::backup::BACKUP_MEMBER_PATH_MAX_BYTES: usize 731 pub trait radroots_storage::backup::StorageReliability: core::marker::Send + core::marker::Sync 732 pub fn radroots_storage::backup::StorageReliability::begin_backup(&self, radroots_storage::backup::BackupPlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::BackupOperation, radroots_storage::Error>> 733 pub fn radroots_storage::backup::StorageReliability::begin_restore(&self, radroots_storage::backup::RestorePlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::RestoreOperation, radroots_storage::Error>> 734 pub fn radroots_storage::backup::StorageReliability::capture_backup(&self, radroots_storage::backup::BackupPlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::BackupManifest, radroots_storage::backup::BackupCapabilityError>> 735 pub fn radroots_storage::backup::StorageReliability::close(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::StorageStatus, radroots_storage::Error>> 736 pub fn radroots_storage::backup::StorageReliability::finalize_backup(&self, radroots_storage::backup::BackupPlan, radroots_storage::backup::BackupManifest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::backup::BackupCapabilityError>> 737 pub fn radroots_storage::backup::StorageReliability::finalize_restore(&self, radroots_storage::backup::RestorePlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::backup::RestoreCapabilityError>> 738 pub fn radroots_storage::backup::StorageReliability::integrity(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::IntegrityStatus, radroots_storage::Error>> 739 pub fn radroots_storage::backup::StorageReliability::settle_backup_writes(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::backup::BackupCapabilityError>> 740 pub fn radroots_storage::backup::StorageReliability::stage_restore(&self, radroots_storage::backup::RestorePlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<alloc::vec::Vec<radroots_storage::backup::RestoreMemberStatus>, radroots_storage::backup::RestoreCapabilityError>> 741 pub fn radroots_storage::backup::StorageReliability::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::StorageStatus, radroots_storage::Error>> 742 pub fn radroots_storage::backup::StorageReliability::transition_backup(&self, radroots_storage::backup::BackupId, radroots_storage::backup::ReliabilityRevision, radroots_storage::backup::BackupTransition, u64) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::BackupOperation, radroots_storage::Error>> 743 pub fn radroots_storage::backup::StorageReliability::transition_restore(&self, radroots_storage::backup::BackupId, radroots_storage::backup::ReliabilityRevision, radroots_storage::backup::RestoreTransition, u64) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::RestoreOperation, radroots_storage::Error>> 744 pub fn radroots_storage::backup::StorageReliability::verify_backup(&self, radroots_storage::backup::BackupPlan, radroots_storage::backup::BackupManifest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::backup::BackupCapabilityError>> 745 impl radroots_storage::backup::StorageReliability for radroots_storage::memory::MemoryStorage 746 pub fn radroots_storage::memory::MemoryStorage::begin_backup(&self, radroots_storage::backup::BackupPlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::BackupOperation, radroots_storage::Error>> 747 pub fn radroots_storage::memory::MemoryStorage::begin_restore(&self, radroots_storage::backup::RestorePlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::RestoreOperation, radroots_storage::Error>> 748 pub fn radroots_storage::memory::MemoryStorage::capture_backup(&self, radroots_storage::backup::BackupPlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::BackupManifest, radroots_storage::backup::BackupCapabilityError>> 749 pub fn radroots_storage::memory::MemoryStorage::close(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::StorageStatus, radroots_storage::Error>> 750 pub fn radroots_storage::memory::MemoryStorage::finalize_backup(&self, radroots_storage::backup::BackupPlan, radroots_storage::backup::BackupManifest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::backup::BackupCapabilityError>> 751 pub fn radroots_storage::memory::MemoryStorage::finalize_restore(&self, radroots_storage::backup::RestorePlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::backup::RestoreCapabilityError>> 752 pub fn radroots_storage::memory::MemoryStorage::integrity(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::IntegrityStatus, radroots_storage::Error>> 753 pub fn radroots_storage::memory::MemoryStorage::settle_backup_writes(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::backup::BackupCapabilityError>> 754 pub fn radroots_storage::memory::MemoryStorage::stage_restore(&self, radroots_storage::backup::RestorePlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<alloc::vec::Vec<radroots_storage::backup::RestoreMemberStatus>, radroots_storage::backup::RestoreCapabilityError>> 755 pub fn radroots_storage::memory::MemoryStorage::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::StorageStatus, radroots_storage::Error>> 756 pub fn radroots_storage::memory::MemoryStorage::transition_backup(&self, radroots_storage::backup::BackupId, radroots_storage::backup::ReliabilityRevision, radroots_storage::backup::BackupTransition, u64) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::BackupOperation, radroots_storage::Error>> 757 pub fn radroots_storage::memory::MemoryStorage::transition_restore(&self, radroots_storage::backup::BackupId, radroots_storage::backup::ReliabilityRevision, radroots_storage::backup::RestoreTransition, u64) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::RestoreOperation, radroots_storage::Error>> 758 pub fn radroots_storage::memory::MemoryStorage::verify_backup(&self, radroots_storage::backup::BackupPlan, radroots_storage::backup::BackupManifest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::backup::BackupCapabilityError>> 759 pub mod radroots_storage::event 760 pub use radroots_storage::event::BoxFuture 761 pub use radroots_storage::event::EventId 762 pub enum radroots_storage::event::AdmissionDisposition 763 pub radroots_storage::event::AdmissionDisposition::Advanced 764 pub radroots_storage::event::AdmissionDisposition::Duplicate 765 pub radroots_storage::event::AdmissionDisposition::Inserted 766 pub enum radroots_storage::event::AdmissionStage 767 pub radroots_storage::event::AdmissionStage::Raw 768 pub radroots_storage::event::AdmissionStage::Verified 769 pub radroots_storage::event::AdmissionStage::Visible 770 pub struct radroots_storage::event::AdmissionReceipt 771 impl radroots_storage::event::AdmissionReceipt 772 pub const fn radroots_storage::event::AdmissionReceipt::disposition(&self) -> radroots_storage::event::AdmissionDisposition 773 pub const fn radroots_storage::event::AdmissionReceipt::event_id(&self) -> &radroots_event::id::EventId 774 pub const fn radroots_storage::event::AdmissionReceipt::new(radroots_event::id::EventId, radroots_storage::event::EventPosition, radroots_storage::event::AdmissionStage, radroots_storage::event::AdmissionDisposition) -> Self 775 pub const fn radroots_storage::event::AdmissionReceipt::position(&self) -> radroots_storage::event::EventPosition 776 pub const fn radroots_storage::event::AdmissionReceipt::stage(&self) -> radroots_storage::event::AdmissionStage 777 pub struct radroots_storage::event::EventAdmission 778 impl radroots_storage::event::EventAdmission 779 pub const fn radroots_storage::event::EventAdmission::event(&self) -> &radroots_event::draft::SignedEvent 780 pub fn radroots_storage::event::EventAdmission::event_id(&self) -> &radroots_event::id::EventId 781 pub const fn radroots_storage::event::EventAdmission::provenance(&self) -> &radroots_transport::source::EventProvenance 782 pub const fn radroots_storage::event::EventAdmission::raw(radroots_transport::source::ObservedEvent) -> Self 783 pub const fn radroots_storage::event::EventAdmission::stage(&self) -> radroots_storage::event::AdmissionStage 784 pub fn radroots_storage::event::EventAdmission::verified(radroots_transport::source::ObservedEvent, radroots_event::verification::SignatureVerifiedEvent) -> core::result::Result<Self, radroots_storage::Error> 785 pub const fn radroots_storage::event::EventAdmission::verified_event(&self) -> core::option::Option<&radroots_event::verification::SignatureVerifiedEvent> 786 pub fn radroots_storage::event::EventAdmission::visible(radroots_transport::source::ObservedEvent, radroots_event::admission::VisibleEvent) -> core::result::Result<Self, radroots_storage::Error> 787 pub const fn radroots_storage::event::EventAdmission::visible_event(&self) -> core::option::Option<&radroots_event::admission::VisibleEvent> 788 pub struct radroots_storage::event::EventPage<T> 789 impl<T> radroots_storage::event::EventPage<T> 790 pub const fn radroots_storage::event::EventPage<T>::generation(&self) -> radroots_storage::event::SourceGeneration 791 pub fn radroots_storage::event::EventPage<T>::items(&self) -> &[T] 792 pub fn radroots_storage::event::EventPage<T>::new(radroots_storage::event::SourceGeneration, alloc::vec::Vec<T>, core::option::Option<radroots_storage::event::EventCursor>, radroots_storage::event::EventQueryBounds) -> core::result::Result<Self, radroots_storage::Error> 793 pub const fn radroots_storage::event::EventPage<T>::next_cursor(&self) -> core::option::Option<radroots_storage::event::EventCursor> 794 pub struct radroots_storage::event::EventPosition 795 impl radroots_storage::event::EventPosition 796 pub const fn radroots_storage::event::EventPosition::generation(self) -> radroots_storage::event::SourceGeneration 797 pub const fn radroots_storage::event::EventPosition::new(radroots_storage::event::SourceGeneration, radroots_storage::event::EventSequence) -> Self 798 pub const fn radroots_storage::event::EventPosition::sequence(self) -> radroots_storage::event::EventSequence 799 pub struct radroots_storage::event::EventQuery 800 impl radroots_storage::event::EventQuery 801 pub const fn radroots_storage::event::EventQuery::all(radroots_storage::event::EventQueryBounds) -> Self 802 pub const fn radroots_storage::event::EventQuery::bounds(&self) -> radroots_storage::event::EventQueryBounds 803 pub fn radroots_storage::event::EventQuery::event_ids(&self) -> &[radroots_event::id::EventId] 804 pub fn radroots_storage::event::EventQuery::for_ids(radroots_storage::event::EventQueryBounds, alloc::vec::Vec<radroots_event::id::EventId>) -> core::result::Result<Self, radroots_storage::Error> 805 pub fn radroots_storage::event::EventQuery::selects(&self, &radroots_event::id::EventId) -> bool 806 pub struct radroots_storage::event::EventQueryBounds 807 impl radroots_storage::event::EventQueryBounds 808 pub const fn radroots_storage::event::EventQueryBounds::after(self, radroots_storage::event::EventCursor) -> Self 809 pub const fn radroots_storage::event::EventQueryBounds::cursor(self) -> core::option::Option<radroots_storage::event::EventCursor> 810 pub const fn radroots_storage::event::EventQueryBounds::first(u16) -> core::result::Result<Self, radroots_storage::Error> 811 pub const fn radroots_storage::event::EventQueryBounds::limit(self) -> u16 812 pub struct radroots_storage::event::EventSequence(_) 813 impl radroots_storage::event::EventSequence 814 pub const fn radroots_storage::event::EventSequence::get(self) -> u64 815 pub const fn radroots_storage::event::EventSequence::new(u64) -> core::result::Result<Self, radroots_storage::Error> 816 pub struct radroots_storage::event::SourceGeneration(_) 817 impl radroots_storage::event::SourceGeneration 818 pub const fn radroots_storage::event::SourceGeneration::as_bytes(&self) -> &[u8; 32] 819 pub const fn radroots_storage::event::SourceGeneration::new([u8; 32]) -> core::result::Result<Self, radroots_storage::Error> 820 pub struct radroots_storage::event::StoredEventProvenance 821 impl radroots_storage::event::StoredEventProvenance 822 pub fn radroots_storage::event::StoredEventProvenance::from_stored_parts(radroots_storage::event::EventPosition, &str, &str, u64, core::option::Option<&str>) -> core::result::Result<Self, radroots_storage::Error> 823 pub const fn radroots_storage::event::StoredEventProvenance::new(radroots_storage::event::EventPosition, radroots_transport::source::EventProvenance) -> Self 824 pub const fn radroots_storage::event::StoredEventProvenance::position(&self) -> radroots_storage::event::EventPosition 825 pub const fn radroots_storage::event::StoredEventProvenance::provenance(&self) -> &radroots_transport::source::EventProvenance 826 pub struct radroots_storage::event::StoredRawEvent 827 impl radroots_storage::event::StoredRawEvent 828 pub const fn radroots_storage::event::StoredRawEvent::event(&self) -> &radroots_event::draft::SignedEvent 829 pub const fn radroots_storage::event::StoredRawEvent::new(radroots_storage::event::EventPosition, radroots_event::draft::SignedEvent, radroots_storage::event::AdmissionStage) -> Self 830 pub const fn radroots_storage::event::StoredRawEvent::position(&self) -> radroots_storage::event::EventPosition 831 pub const fn radroots_storage::event::StoredRawEvent::stage(&self) -> radroots_storage::event::AdmissionStage 832 pub struct radroots_storage::event::StoredVerifiedEvent 833 impl radroots_storage::event::StoredVerifiedEvent 834 pub const fn radroots_storage::event::StoredVerifiedEvent::event(&self) -> &radroots_event::draft::SignedEvent 835 pub const fn radroots_storage::event::StoredVerifiedEvent::new(radroots_storage::event::EventPosition, radroots_event::draft::SignedEvent) -> Self 836 pub const fn radroots_storage::event::StoredVerifiedEvent::position(&self) -> radroots_storage::event::EventPosition 837 pub struct radroots_storage::event::StoredVisibleEvent 838 impl radroots_storage::event::StoredVisibleEvent 839 pub const fn radroots_storage::event::StoredVisibleEvent::event(&self) -> &radroots_event::draft::SignedEvent 840 pub const fn radroots_storage::event::StoredVisibleEvent::new(radroots_storage::event::EventPosition, radroots_event::draft::SignedEvent) -> Self 841 pub const fn radroots_storage::event::StoredVisibleEvent::position(&self) -> radroots_storage::event::EventPosition 842 pub struct radroots_storage::event::VisibilityDigest(_) 843 impl radroots_storage::event::VisibilityDigest 844 pub const fn radroots_storage::event::VisibilityDigest::as_bytes(&self) -> &[u8; 32] 845 pub struct radroots_storage::event::VisibilitySnapshot 846 impl radroots_storage::event::VisibilitySnapshot 847 pub fn radroots_storage::event::VisibilitySnapshot::current_heads(&self) -> &[radroots_event::envelope::event_head::v1::CurrentEventHead] 848 pub fn radroots_storage::event::VisibilitySnapshot::deletion_request_ids(&self) -> &[radroots_event::id::EventId] 849 pub const fn radroots_storage::event::VisibilitySnapshot::digest(&self) -> radroots_storage::event::VisibilityDigest 850 pub const fn radroots_storage::event::VisibilitySnapshot::generation(&self) -> radroots_storage::event::SourceGeneration 851 pub fn radroots_storage::event::VisibilitySnapshot::superseded_event_ids(&self) -> &[radroots_event::id::EventId] 852 pub fn radroots_storage::event::VisibilitySnapshot::suppressed_event_ids(&self) -> &[radroots_event::id::EventId] 853 pub fn radroots_storage::event::VisibilitySnapshot::visible_event_ids(&self) -> &[radroots_event::id::EventId] 854 pub const radroots_storage::event::EVENT_QUERY_ID_MAX: usize 855 pub const radroots_storage::event::EVENT_QUERY_LIMIT_MAX: u16 856 pub trait radroots_storage::event::EventStore: core::marker::Send + core::marker::Sync 857 pub fn radroots_storage::event::EventStore::admit(&self, radroots_storage::event::EventAdmission) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::AdmissionReceipt, radroots_storage::Error>> 858 pub fn radroots_storage::event::EventStore::query_provenance(&self, radroots_event::id::EventId, radroots_storage::event::EventQueryBounds) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::EventPage<radroots_storage::event::StoredEventProvenance>, radroots_storage::Error>> 859 pub fn radroots_storage::event::EventStore::query_raw(&self, radroots_storage::event::EventQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::EventPage<radroots_storage::event::StoredRawEvent>, radroots_storage::Error>> 860 pub fn radroots_storage::event::EventStore::query_verified(&self, radroots_storage::event::EventQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::EventPage<radroots_storage::event::StoredVerifiedEvent>, radroots_storage::Error>> 861 pub fn radroots_storage::event::EventStore::query_visible(&self, radroots_storage::event::EventQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::EventPage<radroots_storage::event::StoredVisibleEvent>, radroots_storage::Error>> 862 pub fn radroots_storage::event::EventStore::rebuild_visibility(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::VisibilitySnapshot, radroots_storage::Error>> 863 pub fn radroots_storage::event::EventStore::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::EventStoreStatus, radroots_storage::Error>> 864 impl radroots_storage::event::EventStore for radroots_storage::memory::MemoryStorage 865 pub fn radroots_storage::memory::MemoryStorage::admit(&self, radroots_storage::event::EventAdmission) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::AdmissionReceipt, radroots_storage::Error>> 866 pub fn radroots_storage::memory::MemoryStorage::query_provenance(&self, radroots_event::id::EventId, radroots_storage::event::EventQueryBounds) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::EventPage<radroots_storage::event::StoredEventProvenance>, radroots_storage::Error>> 867 pub fn radroots_storage::memory::MemoryStorage::query_raw(&self, radroots_storage::event::EventQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::EventPage<radroots_storage::event::StoredRawEvent>, radroots_storage::Error>> 868 pub fn radroots_storage::memory::MemoryStorage::query_verified(&self, radroots_storage::event::EventQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::EventPage<radroots_storage::event::StoredVerifiedEvent>, radroots_storage::Error>> 869 pub fn radroots_storage::memory::MemoryStorage::query_visible(&self, radroots_storage::event::EventQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::EventPage<radroots_storage::event::StoredVisibleEvent>, radroots_storage::Error>> 870 pub fn radroots_storage::memory::MemoryStorage::rebuild_visibility(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::VisibilitySnapshot, radroots_storage::Error>> 871 pub fn radroots_storage::memory::MemoryStorage::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::EventStoreStatus, radroots_storage::Error>> 872 pub type radroots_storage::event::EventCursor = radroots_storage::event::EventPosition 873 pub mod radroots_storage::journal 874 pub use radroots_storage::journal::BoxFuture 875 pub use radroots_storage::journal::EventId 876 pub use radroots_storage::journal::OperationId 877 pub enum radroots_storage::journal::CancellationState 878 pub radroots_storage::journal::CancellationState::CancelledBeforeCommit 879 pub radroots_storage::journal::CancellationState::NotRequested 880 pub radroots_storage::journal::CancellationState::ObservedAfterCommit 881 pub enum radroots_storage::journal::JournalStage 882 pub radroots_storage::journal::JournalStage::Committed 883 pub radroots_storage::journal::JournalStage::Prepared 884 pub radroots_storage::journal::JournalStage::Recoverable 885 pub radroots_storage::journal::JournalStage::Signed 886 pub enum radroots_storage::journal::JournalState 887 pub radroots_storage::journal::JournalState::Committed 888 pub radroots_storage::journal::JournalState::Committed::committed_at_unix_ms: u64 889 pub radroots_storage::journal::JournalState::Committed::event_id: radroots_event::id::EventId 890 pub radroots_storage::journal::JournalState::Prepared 891 pub radroots_storage::journal::JournalState::Recoverable(radroots_storage::journal::RecoveryRecord) 892 pub radroots_storage::journal::JournalState::Signed 893 pub radroots_storage::journal::JournalState::Signed::event_id: radroots_event::id::EventId 894 impl radroots_storage::journal::JournalState 895 pub const fn radroots_storage::journal::JournalState::stage(&self) -> radroots_storage::journal::JournalStage 896 pub enum radroots_storage::journal::PrepareDisposition 897 pub radroots_storage::journal::PrepareDisposition::Created 898 pub radroots_storage::journal::PrepareDisposition::Replay 899 pub enum radroots_storage::journal::RecoveryPoint 900 pub radroots_storage::journal::RecoveryPoint::Prepared 901 pub radroots_storage::journal::RecoveryPoint::Signed 902 pub radroots_storage::journal::RecoveryPoint::Signed::event_id: radroots_event::id::EventId 903 pub enum radroots_storage::journal::RecoveryReason 904 pub radroots_storage::journal::RecoveryReason::CancelledBeforeCommit 905 pub radroots_storage::journal::RecoveryReason::DeadlineExceeded 906 pub radroots_storage::journal::RecoveryReason::Interrupted 907 pub radroots_storage::journal::RecoveryReason::SignerUnavailable 908 pub radroots_storage::journal::RecoveryReason::StorageUnavailable 909 pub radroots_storage::journal::RecoveryReason::TransportUnavailable 910 pub struct radroots_storage::journal::IdempotencyDigest(_) 911 impl radroots_storage::journal::IdempotencyDigest 912 pub const fn radroots_storage::journal::IdempotencyDigest::as_bytes(&self) -> &[u8; 32] 913 pub const fn radroots_storage::journal::IdempotencyDigest::new([u8; 32]) -> Self 914 pub struct radroots_storage::journal::IdempotencyKey(_) 915 impl radroots_storage::journal::IdempotencyKey 916 pub fn radroots_storage::journal::IdempotencyKey::as_str(&self) -> &str 917 pub fn radroots_storage::journal::IdempotencyKey::parse(impl core::convert::AsRef<str>) -> core::result::Result<Self, radroots_storage::Error> 918 impl core::fmt::Debug for radroots_storage::journal::IdempotencyKey 919 pub fn radroots_storage::journal::IdempotencyKey::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 920 impl serde_core::ser::Serialize for radroots_storage::journal::IdempotencyKey 921 pub fn radroots_storage::journal::IdempotencyKey::serialize<S>(&self, S) -> core::result::Result<<S as serde_core::ser::Serializer>::Ok, <S as serde_core::ser::Serializer>::Error> where S: serde_core::ser::Serializer 922 impl<'de> serde_core::de::Deserialize<'de> for radroots_storage::journal::IdempotencyKey 923 pub fn radroots_storage::journal::IdempotencyKey::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 924 pub struct radroots_storage::journal::JournalRevision(_) 925 impl radroots_storage::journal::JournalRevision 926 pub const radroots_storage::journal::JournalRevision::INITIAL: Self 927 pub const fn radroots_storage::journal::JournalRevision::get(self) -> u64 928 pub const fn radroots_storage::journal::JournalRevision::new(u64) -> core::result::Result<Self, radroots_storage::Error> 929 pub struct radroots_storage::journal::JournalTransition 930 impl radroots_storage::journal::JournalTransition 931 pub const fn radroots_storage::journal::JournalTransition::cancelled(radroots_storage::journal::OperationInstanceId, radroots_storage::journal::JournalRevision, u64) -> Self 932 pub const fn radroots_storage::journal::JournalTransition::committed(radroots_storage::journal::OperationInstanceId, radroots_storage::journal::JournalRevision, radroots_event::id::EventId, u64) -> Self 933 pub const fn radroots_storage::journal::JournalTransition::instance_id(&self) -> radroots_storage::journal::OperationInstanceId 934 pub const fn radroots_storage::journal::JournalTransition::recoverable(radroots_storage::journal::OperationInstanceId, radroots_storage::journal::JournalRevision, radroots_storage::journal::RecoveryRecord) -> Self 935 pub const fn radroots_storage::journal::JournalTransition::resume(radroots_storage::journal::OperationInstanceId, radroots_storage::journal::JournalRevision) -> Self 936 pub const fn radroots_storage::journal::JournalTransition::signed(radroots_storage::journal::OperationInstanceId, radroots_storage::journal::JournalRevision, radroots_event::id::EventId) -> Self 937 pub struct radroots_storage::journal::OperationInstanceId(_) 938 impl radroots_storage::journal::OperationInstanceId 939 pub const fn radroots_storage::journal::OperationInstanceId::as_bytes(&self) -> &[u8; 16] 940 pub const fn radroots_storage::journal::OperationInstanceId::new([u8; 16]) -> core::result::Result<Self, radroots_storage::Error> 941 pub struct radroots_storage::journal::OperationRecord 942 impl radroots_storage::journal::OperationRecord 943 pub const fn radroots_storage::journal::OperationRecord::cancellation(&self) -> radroots_storage::journal::CancellationState 944 pub fn radroots_storage::journal::OperationRecord::from_parts(radroots_storage::journal::OperationInstanceId, radroots_protocol::runtime::v1::OperationId, radroots_storage::journal::IdempotencyKey, radroots_storage::journal::IdempotencyDigest, u64, radroots_storage::journal::JournalRevision, radroots_storage::journal::JournalState, radroots_storage::journal::CancellationState) -> core::result::Result<Self, radroots_storage::Error> 945 pub const fn radroots_storage::journal::OperationRecord::idempotency_key(&self) -> &radroots_storage::journal::IdempotencyKey 946 pub const fn radroots_storage::journal::OperationRecord::input_digest(&self) -> radroots_storage::journal::IdempotencyDigest 947 pub const fn radroots_storage::journal::OperationRecord::instance_id(&self) -> radroots_storage::journal::OperationInstanceId 948 pub const fn radroots_storage::journal::OperationRecord::operation_id(&self) -> radroots_protocol::runtime::v1::OperationId 949 pub const fn radroots_storage::journal::OperationRecord::prepared_at_unix_ms(&self) -> u64 950 pub const fn radroots_storage::journal::OperationRecord::revision(&self) -> radroots_storage::journal::JournalRevision 951 pub const fn radroots_storage::journal::OperationRecord::state(&self) -> &radroots_storage::journal::JournalState 952 pub fn radroots_storage::journal::OperationRecord::transition(&self, &radroots_storage::journal::JournalTransition) -> core::result::Result<Self, radroots_storage::Error> 953 pub struct radroots_storage::journal::PrepareOperation 954 impl radroots_storage::journal::PrepareOperation 955 pub const fn radroots_storage::journal::PrepareOperation::idempotency_key(&self) -> &radroots_storage::journal::IdempotencyKey 956 pub const fn radroots_storage::journal::PrepareOperation::input_digest(&self) -> radroots_storage::journal::IdempotencyDigest 957 pub const fn radroots_storage::journal::PrepareOperation::instance_id(&self) -> radroots_storage::journal::OperationInstanceId 958 pub fn radroots_storage::journal::PrepareOperation::into_record(self) -> core::result::Result<radroots_storage::journal::OperationRecord, radroots_storage::Error> 959 pub fn radroots_storage::journal::PrepareOperation::new(radroots_storage::journal::OperationInstanceId, radroots_protocol::runtime::v1::OperationId, radroots_storage::journal::IdempotencyKey, radroots_storage::journal::IdempotencyDigest, u64) -> core::result::Result<Self, radroots_storage::Error> 960 pub const fn radroots_storage::journal::PrepareOperation::operation_id(&self) -> radroots_protocol::runtime::v1::OperationId 961 pub struct radroots_storage::journal::PrepareReceipt 962 impl radroots_storage::journal::PrepareReceipt 963 pub const fn radroots_storage::journal::PrepareReceipt::disposition(&self) -> radroots_storage::journal::PrepareDisposition 964 pub const fn radroots_storage::journal::PrepareReceipt::new(radroots_storage::journal::PrepareDisposition, radroots_storage::journal::OperationRecord) -> Self 965 pub const fn radroots_storage::journal::PrepareReceipt::record(&self) -> &radroots_storage::journal::OperationRecord 966 pub struct radroots_storage::journal::RecoveryRecord 967 impl radroots_storage::journal::RecoveryRecord 968 pub const fn radroots_storage::journal::RecoveryRecord::attempt(&self) -> u32 969 pub const fn radroots_storage::journal::RecoveryRecord::new(radroots_storage::journal::RecoveryPoint, radroots_storage::journal::RecoveryReason, u32, core::option::Option<u64>) -> core::result::Result<Self, radroots_storage::Error> 970 pub const fn radroots_storage::journal::RecoveryRecord::point(&self) -> &radroots_storage::journal::RecoveryPoint 971 pub const fn radroots_storage::journal::RecoveryRecord::reason(&self) -> radroots_storage::journal::RecoveryReason 972 pub const fn radroots_storage::journal::RecoveryRecord::retry_not_before_unix_ms(&self) -> core::option::Option<u64> 973 pub const radroots_storage::journal::IDEMPOTENCY_KEY_MAX_BYTES: usize 974 pub const radroots_storage::journal::RECOVERABLE_QUERY_LIMIT_MAX: u16 975 pub trait radroots_storage::journal::Journal: core::marker::Send + core::marker::Sync 976 pub fn radroots_storage::journal::Journal::by_idempotency_key(&self, radroots_protocol::runtime::v1::OperationId, radroots_storage::journal::IdempotencyKey) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::journal::OperationRecord>, radroots_storage::Error>> 977 pub fn radroots_storage::journal::Journal::operation(&self, radroots_storage::journal::OperationInstanceId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::journal::OperationRecord>, radroots_storage::Error>> 978 pub fn radroots_storage::journal::Journal::prepare(&self, radroots_storage::journal::PrepareOperation) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::journal::PrepareReceipt, radroots_storage::Error>> 979 pub fn radroots_storage::journal::Journal::recoverable(&self, u16) -> radroots_transport::source::BoxFuture<'_, core::result::Result<alloc::vec::Vec<radroots_storage::journal::OperationRecord>, radroots_storage::Error>> 980 pub fn radroots_storage::journal::Journal::transition(&self, radroots_storage::journal::JournalTransition) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::journal::OperationRecord, radroots_storage::Error>> 981 impl radroots_storage::journal::Journal for radroots_storage::memory::MemoryStorage 982 pub fn radroots_storage::memory::MemoryStorage::by_idempotency_key(&self, radroots_protocol::runtime::v1::OperationId, radroots_storage::journal::IdempotencyKey) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::journal::OperationRecord>, radroots_storage::Error>> 983 pub fn radroots_storage::memory::MemoryStorage::operation(&self, radroots_storage::journal::OperationInstanceId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::journal::OperationRecord>, radroots_storage::Error>> 984 pub fn radroots_storage::memory::MemoryStorage::prepare(&self, radroots_storage::journal::PrepareOperation) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::journal::PrepareReceipt, radroots_storage::Error>> 985 pub fn radroots_storage::memory::MemoryStorage::recoverable(&self, u16) -> radroots_transport::source::BoxFuture<'_, core::result::Result<alloc::vec::Vec<radroots_storage::journal::OperationRecord>, radroots_storage::Error>> 986 pub fn radroots_storage::memory::MemoryStorage::transition(&self, radroots_storage::journal::JournalTransition) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::journal::OperationRecord, radroots_storage::Error>> 987 pub mod radroots_storage::memory 988 pub struct radroots_storage::memory::MemoryStorage 989 impl radroots_storage::memory::MemoryStorage 990 pub const fn radroots_storage::memory::MemoryStorage::generation(&self) -> radroots_storage::event::SourceGeneration 991 pub const fn radroots_storage::memory::MemoryStorage::new(radroots_storage::event::SourceGeneration) -> Self 992 impl core::default::Default for radroots_storage::memory::MemoryStorage 993 pub fn radroots_storage::memory::MemoryStorage::default() -> Self 994 impl radroots_storage::atomic::AtomicStorage for radroots_storage::memory::MemoryStorage 995 pub fn radroots_storage::memory::MemoryStorage::commit(&self, radroots_storage::atomic::AtomicCommit) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::atomic::AtomicCommitReceipt, radroots_storage::Error>> 996 pub fn radroots_storage::memory::MemoryStorage::receipt(&self, radroots_storage::atomic::AtomicCommitId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::atomic::AtomicCommitReceipt>, radroots_storage::Error>> 997 impl radroots_storage::authored_atomic::AuthoredAtomicStorage for radroots_storage::memory::MemoryStorage 998 pub fn radroots_storage::memory::MemoryStorage::authored_artifact(&self, radroots_storage::authored::AuthoredArtifactId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::authored::AuthoredArtifact>, radroots_storage::Error>> 999 pub fn radroots_storage::memory::MemoryStorage::authored_delivery_history(&self, radroots_storage::authored_delivery::AuthoredDeliveryPlanId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::authored_delivery::AuthoredDeliveryHistory>, radroots_storage::Error>> 1000 pub fn radroots_storage::memory::MemoryStorage::authored_delivery_plan(&self, radroots_storage::authored_delivery::AuthoredDeliveryPlanId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::authored_delivery::AuthoredDeliveryPlan>, radroots_storage::Error>> 1001 pub fn radroots_storage::memory::MemoryStorage::authored_operation(&self, radroots_storage::journal::OperationInstanceId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::authored::AuthoredOperation>, radroots_storage::Error>> 1002 pub fn radroots_storage::memory::MemoryStorage::authored_receipt(&self, radroots_storage::atomic::AtomicCommitId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::authored_atomic::AuthoredAtomicReceipt>, radroots_storage::Error>> 1003 pub fn radroots_storage::memory::MemoryStorage::execute_authored(&self, radroots_storage::authored_atomic::AuthoredAtomicCommand) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::authored_atomic::AuthoredAtomicReceipt, radroots_storage::Error>> 1004 impl radroots_storage::authored_draft::AuthoredDraftStore for radroots_storage::memory::MemoryStorage 1005 pub fn radroots_storage::memory::MemoryStorage::append_authored_draft(&self, radroots_storage::authored_draft::AuthoredDraft, core::option::Option<radroots_storage::authored_draft::AuthoredDraftRevision>) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::authored_draft::DraftAppendReceipt, radroots_storage::Error>> 1006 pub fn radroots_storage::memory::MemoryStorage::append_authored_draft_pair(&self, radroots_storage::authored_draft_pair::AuthoredDraftPair) -> radroots_transport::source::BoxFuture<'_, core::result::Result<[radroots_storage::authored_draft::DraftAppendReceipt; 2], radroots_storage::Error>> 1007 pub fn radroots_storage::memory::MemoryStorage::authored_draft_head(&self, radroots_storage::authored_draft::AuthoredDraftId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::authored_draft::AuthoredDraft>, radroots_storage::Error>> 1008 pub fn radroots_storage::memory::MemoryStorage::authored_draft_heads(&self, [u8; 32], u16) -> radroots_transport::source::BoxFuture<'_, core::result::Result<alloc::vec::Vec<radroots_storage::authored_draft::AuthoredDraft>, radroots_storage::Error>> 1009 pub fn radroots_storage::memory::MemoryStorage::authored_draft_revision(&self, radroots_storage::authored_draft::AuthoredDraftId, radroots_storage::authored_draft::AuthoredDraftRevision) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::authored_draft::AuthoredDraft>, radroots_storage::Error>> 1010 pub fn radroots_storage::memory::MemoryStorage::query_authored_drafts(&self, radroots_storage::authored_draft_query::AuthoredDraftQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::authored_draft_query::AuthoredDraftPage, radroots_storage::Error>> 1011 impl radroots_storage::backup::StorageReliability for radroots_storage::memory::MemoryStorage 1012 pub fn radroots_storage::memory::MemoryStorage::begin_backup(&self, radroots_storage::backup::BackupPlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::BackupOperation, radroots_storage::Error>> 1013 pub fn radroots_storage::memory::MemoryStorage::begin_restore(&self, radroots_storage::backup::RestorePlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::RestoreOperation, radroots_storage::Error>> 1014 pub fn radroots_storage::memory::MemoryStorage::capture_backup(&self, radroots_storage::backup::BackupPlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::BackupManifest, radroots_storage::backup::BackupCapabilityError>> 1015 pub fn radroots_storage::memory::MemoryStorage::close(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::StorageStatus, radroots_storage::Error>> 1016 pub fn radroots_storage::memory::MemoryStorage::finalize_backup(&self, radroots_storage::backup::BackupPlan, radroots_storage::backup::BackupManifest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::backup::BackupCapabilityError>> 1017 pub fn radroots_storage::memory::MemoryStorage::finalize_restore(&self, radroots_storage::backup::RestorePlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::backup::RestoreCapabilityError>> 1018 pub fn radroots_storage::memory::MemoryStorage::integrity(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::IntegrityStatus, radroots_storage::Error>> 1019 pub fn radroots_storage::memory::MemoryStorage::settle_backup_writes(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::backup::BackupCapabilityError>> 1020 pub fn radroots_storage::memory::MemoryStorage::stage_restore(&self, radroots_storage::backup::RestorePlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<alloc::vec::Vec<radroots_storage::backup::RestoreMemberStatus>, radroots_storage::backup::RestoreCapabilityError>> 1021 pub fn radroots_storage::memory::MemoryStorage::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::StorageStatus, radroots_storage::Error>> 1022 pub fn radroots_storage::memory::MemoryStorage::transition_backup(&self, radroots_storage::backup::BackupId, radroots_storage::backup::ReliabilityRevision, radroots_storage::backup::BackupTransition, u64) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::BackupOperation, radroots_storage::Error>> 1023 pub fn radroots_storage::memory::MemoryStorage::transition_restore(&self, radroots_storage::backup::BackupId, radroots_storage::backup::ReliabilityRevision, radroots_storage::backup::RestoreTransition, u64) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::RestoreOperation, radroots_storage::Error>> 1024 pub fn radroots_storage::memory::MemoryStorage::verify_backup(&self, radroots_storage::backup::BackupPlan, radroots_storage::backup::BackupManifest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::backup::BackupCapabilityError>> 1025 impl radroots_storage::event::EventStore for radroots_storage::memory::MemoryStorage 1026 pub fn radroots_storage::memory::MemoryStorage::admit(&self, radroots_storage::event::EventAdmission) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::AdmissionReceipt, radroots_storage::Error>> 1027 pub fn radroots_storage::memory::MemoryStorage::query_provenance(&self, radroots_event::id::EventId, radroots_storage::event::EventQueryBounds) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::EventPage<radroots_storage::event::StoredEventProvenance>, radroots_storage::Error>> 1028 pub fn radroots_storage::memory::MemoryStorage::query_raw(&self, radroots_storage::event::EventQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::EventPage<radroots_storage::event::StoredRawEvent>, radroots_storage::Error>> 1029 pub fn radroots_storage::memory::MemoryStorage::query_verified(&self, radroots_storage::event::EventQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::EventPage<radroots_storage::event::StoredVerifiedEvent>, radroots_storage::Error>> 1030 pub fn radroots_storage::memory::MemoryStorage::query_visible(&self, radroots_storage::event::EventQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::EventPage<radroots_storage::event::StoredVisibleEvent>, radroots_storage::Error>> 1031 pub fn radroots_storage::memory::MemoryStorage::rebuild_visibility(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::VisibilitySnapshot, radroots_storage::Error>> 1032 pub fn radroots_storage::memory::MemoryStorage::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::EventStoreStatus, radroots_storage::Error>> 1033 impl radroots_storage::journal::Journal for radroots_storage::memory::MemoryStorage 1034 pub fn radroots_storage::memory::MemoryStorage::by_idempotency_key(&self, radroots_protocol::runtime::v1::OperationId, radroots_storage::journal::IdempotencyKey) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::journal::OperationRecord>, radroots_storage::Error>> 1035 pub fn radroots_storage::memory::MemoryStorage::operation(&self, radroots_storage::journal::OperationInstanceId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::journal::OperationRecord>, radroots_storage::Error>> 1036 pub fn radroots_storage::memory::MemoryStorage::prepare(&self, radroots_storage::journal::PrepareOperation) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::journal::PrepareReceipt, radroots_storage::Error>> 1037 pub fn radroots_storage::memory::MemoryStorage::recoverable(&self, u16) -> radroots_transport::source::BoxFuture<'_, core::result::Result<alloc::vec::Vec<radroots_storage::journal::OperationRecord>, radroots_storage::Error>> 1038 pub fn radroots_storage::memory::MemoryStorage::transition(&self, radroots_storage::journal::JournalTransition) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::journal::OperationRecord, radroots_storage::Error>> 1039 impl radroots_storage::outbox::Outbox for radroots_storage::memory::MemoryStorage 1040 pub fn radroots_storage::memory::MemoryStorage::claim(&self, radroots_storage::outbox::ClaimOutboxItems) -> radroots_transport::source::BoxFuture<'_, core::result::Result<alloc::vec::Vec<radroots_storage::outbox::ClaimedOutboxItem>, radroots_storage::Error>> 1041 pub fn radroots_storage::memory::MemoryStorage::enqueue(&self, radroots_storage::outbox::EnqueueOutboxItem) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::outbox::EnqueueReceipt, radroots_storage::Error>> 1042 pub fn radroots_storage::memory::MemoryStorage::item(&self, radroots_storage::outbox::OutboxItemId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::outbox::OutboxRecord>, radroots_storage::Error>> 1043 pub fn radroots_storage::memory::MemoryStorage::record_attempt(&self, radroots_storage::outbox::DeliveryAttemptEvidence) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::outbox::OutboxRecord, radroots_storage::Error>> 1044 pub fn radroots_storage::memory::MemoryStorage::release(&self, radroots_storage::outbox::OutboxItemId, radroots_storage::outbox::LeaseId, radroots_storage::outbox::OutboxRevision, u64, core::option::Option<u64>) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::outbox::OutboxRecord, radroots_storage::Error>> 1045 pub fn radroots_storage::memory::MemoryStorage::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::outbox::OutboxStatus, radroots_storage::Error>> 1046 impl radroots_storage::private_artifact::PrivateArtifactStore for radroots_storage::memory::MemoryStorage 1047 pub fn radroots_storage::memory::MemoryStorage::expired(&self, u64, u16) -> radroots_transport::source::BoxFuture<'_, core::result::Result<alloc::vec::Vec<radroots_storage::private_artifact::PrivateArtifactMetadata>, radroots_storage::Error>> 1048 pub fn radroots_storage::memory::MemoryStorage::mark_expired(&self, radroots_storage::private_artifact::PrivateArtifactId, radroots_storage::private_artifact::PrivateArtifactRevision, u64) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::private_artifact::PrivateArtifactMetadata, radroots_storage::Error>> 1049 pub fn radroots_storage::memory::MemoryStorage::metadata(&self, radroots_storage::private_artifact::PrivateArtifactId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::private_artifact::PrivateArtifactMetadata>, radroots_storage::Error>> 1050 pub fn radroots_storage::memory::MemoryStorage::put_metadata(&self, radroots_storage::private_artifact::PrivateArtifactMetadata) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::private_artifact::PrivateArtifactMetadata, radroots_storage::Error>> 1051 pub fn radroots_storage::memory::MemoryStorage::reseal_metadata(&self, radroots_storage::private_artifact::PrivateArtifactResealRequest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::private_artifact::PrivateArtifactResealReceipt, radroots_storage::Error>> 1052 pub fn radroots_storage::memory::MemoryStorage::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::private_artifact::PrivateArtifactStatus, radroots_storage::Error>> 1053 pub fn radroots_storage::memory::MemoryStorage::tombstone(&self, radroots_storage::private_artifact::PrivateArtifactId, radroots_storage::private_artifact::PrivateArtifactRevision, u64, radroots_storage::private_artifact::DeletionReason) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::private_artifact::PrivateArtifactMetadata, radroots_storage::Error>> 1054 impl radroots_storage::projection::ProjectionStore for radroots_storage::memory::MemoryStorage 1055 pub fn radroots_storage::memory::MemoryStorage::checkpoint(&self, radroots_storage::projection::ProjectionCheckpoint) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::ProjectionStatus, radroots_storage::Error>> 1056 pub fn radroots_storage::memory::MemoryStorage::event_index_checkpoint(&self, radroots_storage::projection::ProjectionGeneration) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::EventIndexCheckpoint>, radroots_storage::Error>> 1057 pub fn radroots_storage::memory::MemoryStorage::event_index_manifest(&self, radroots_storage::projection::ProjectionGeneration) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::EventIndexManifest>, radroots_storage::Error>> 1058 pub fn radroots_storage::memory::MemoryStorage::invalidate(&self, radroots_storage::projection::ProjectionInvalidation) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::ProjectionStatus, radroots_storage::Error>> 1059 pub fn radroots_storage::memory::MemoryStorage::invalidation(&self, radroots_storage::projection::ProjectionId, radroots_storage::projection::ProjectionGeneration) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::ProjectionInvalidation>, radroots_storage::Error>> 1060 pub fn radroots_storage::memory::MemoryStorage::projection_document(&self, radroots_storage::projection::ProjectionId, radroots_storage::projection::ProjectionGeneration, alloc::string::String) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::ProjectionDocument>, radroots_storage::Error>> 1061 pub fn radroots_storage::memory::MemoryStorage::projection_snapshot(&self, radroots_storage::projection::ProjectionId, [u8; 32]) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::ProjectionSnapshot>, radroots_storage::Error>> 1062 pub fn radroots_storage::memory::MemoryStorage::put_event_index_checkpoint(&self, radroots_storage::projection::EventIndexCheckpoint) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::Error>> 1063 pub fn radroots_storage::memory::MemoryStorage::put_event_index_manifest(&self, radroots_storage::projection::EventIndexManifest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::Error>> 1064 pub fn radroots_storage::memory::MemoryStorage::put_projection_document(&self, radroots_storage::projection::ProjectionId, radroots_storage::projection::ProjectionGeneration, radroots_storage::projection::ProjectionDocument) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::Error>> 1065 pub fn radroots_storage::memory::MemoryStorage::put_projection_snapshot(&self, radroots_storage::projection::ProjectionSnapshot) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::Error>> 1066 pub fn radroots_storage::memory::MemoryStorage::query_projection_documents(&self, radroots_storage::projection::document_query::ProjectionDocumentQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::document_query::ProjectionDocumentPage, radroots_storage::Error>> 1067 pub fn radroots_storage::memory::MemoryStorage::rebuild(&self, radroots_storage::projection::RebuildTicketId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::RebuildTicket>, radroots_storage::Error>> 1068 pub fn radroots_storage::memory::MemoryStorage::request_rebuild(&self, radroots_storage::projection::RebuildTicket) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::RebuildTicket, radroots_storage::Error>> 1069 pub fn radroots_storage::memory::MemoryStorage::status(&self, radroots_storage::projection::ProjectionId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::ProjectionStatus>, radroots_storage::Error>> 1070 pub fn radroots_storage::memory::MemoryStorage::transition_rebuild(&self, radroots_storage::projection::RebuildTransition) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::RebuildTicket, radroots_storage::Error>> 1071 impl radroots_storage::status::StorageStatusProvider for radroots_storage::memory::MemoryStorage 1072 pub fn radroots_storage::memory::MemoryStorage::storage_status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::StorageStatus, radroots_storage::Error>> 1073 pub mod radroots_storage::outbox 1074 pub use radroots_storage::outbox::BoxFuture 1075 pub use radroots_storage::outbox::DeliveryOutcome 1076 pub use radroots_storage::outbox::DeliveryOutcomeKind 1077 pub use radroots_storage::outbox::DeliveryPayload 1078 pub use radroots_storage::outbox::DeliveryReceipt 1079 pub use radroots_storage::outbox::DeliveryRequest 1080 pub use radroots_storage::outbox::DeliveryTargetReceipt 1081 pub use radroots_storage::outbox::Retryability 1082 pub use radroots_storage::outbox::SatisfactionClass 1083 pub use radroots_storage::outbox::SatisfactionPolicy 1084 pub use radroots_storage::outbox::SatisfactionState 1085 pub use radroots_storage::outbox::TARGET_SET_MAX_ITEMS 1086 pub use radroots_storage::outbox::Target 1087 pub use radroots_storage::outbox::TargetFingerprint 1088 pub use radroots_storage::outbox::TargetLabel 1089 pub use radroots_storage::outbox::TargetPolicy 1090 pub use radroots_storage::outbox::TargetScope 1091 pub use radroots_storage::outbox::TargetSet 1092 pub use radroots_storage::outbox::TransportId 1093 pub use radroots_storage::outbox::evaluate_transport_satisfaction 1094 pub enum radroots_storage::outbox::EnqueueDisposition 1095 pub radroots_storage::outbox::EnqueueDisposition::Created 1096 pub radroots_storage::outbox::EnqueueDisposition::Replay 1097 pub enum radroots_storage::outbox::OutboxStage 1098 pub radroots_storage::outbox::OutboxStage::Exhausted 1099 pub radroots_storage::outbox::OutboxStage::Leased 1100 pub radroots_storage::outbox::OutboxStage::Pending 1101 pub radroots_storage::outbox::OutboxStage::Retryable 1102 pub radroots_storage::outbox::OutboxStage::Satisfied 1103 impl radroots_storage::outbox::OutboxStage 1104 pub const fn radroots_storage::outbox::OutboxStage::is_terminal(self) -> bool 1105 pub enum radroots_storage::outbox::SatisfactionResult 1106 pub radroots_storage::outbox::SatisfactionResult::Exhausted 1107 pub radroots_storage::outbox::SatisfactionResult::Pending 1108 pub radroots_storage::outbox::SatisfactionResult::Satisfied 1109 pub struct radroots_storage::outbox::ClaimOutboxItems 1110 impl radroots_storage::outbox::ClaimOutboxItems 1111 pub const fn radroots_storage::outbox::ClaimOutboxItems::lease_expires_at_unix_ms(&self) -> u64 1112 pub fn radroots_storage::outbox::ClaimOutboxItems::lease_id_for(&self, radroots_storage::outbox::OutboxItemId) -> radroots_storage::outbox::LeaseId 1113 pub const fn radroots_storage::outbox::ClaimOutboxItems::lease_id_seed(&self) -> radroots_storage::outbox::LeaseId 1114 pub const fn radroots_storage::outbox::ClaimOutboxItems::limit(&self) -> u16 1115 pub fn radroots_storage::outbox::ClaimOutboxItems::new(radroots_storage::outbox::LeaseOwner, radroots_storage::outbox::LeaseId, u64, u64, u16) -> core::result::Result<Self, radroots_storage::Error> 1116 pub const fn radroots_storage::outbox::ClaimOutboxItems::now_unix_ms(&self) -> u64 1117 pub const fn radroots_storage::outbox::ClaimOutboxItems::owner(&self) -> &radroots_storage::outbox::LeaseOwner 1118 pub struct radroots_storage::outbox::ClaimedOutboxItem 1119 impl radroots_storage::outbox::ClaimedOutboxItem 1120 pub const fn radroots_storage::outbox::ClaimedOutboxItem::lease(&self) -> &radroots_storage::outbox::OutboxLease 1121 pub const fn radroots_storage::outbox::ClaimedOutboxItem::new(radroots_storage::outbox::OutboxRecord, radroots_storage::outbox::OutboxLease) -> Self 1122 pub const fn radroots_storage::outbox::ClaimedOutboxItem::record(&self) -> &radroots_storage::outbox::OutboxRecord 1123 pub struct radroots_storage::outbox::DeliveryAttempt(_) 1124 impl radroots_storage::outbox::DeliveryAttempt 1125 pub const radroots_storage::outbox::DeliveryAttempt::FIRST: Self 1126 pub const fn radroots_storage::outbox::DeliveryAttempt::get(self) -> u32 1127 pub const fn radroots_storage::outbox::DeliveryAttempt::new(u32) -> core::result::Result<Self, radroots_storage::Error> 1128 pub struct radroots_storage::outbox::DeliveryAttemptEvidence 1129 impl radroots_storage::outbox::DeliveryAttemptEvidence 1130 pub const fn radroots_storage::outbox::DeliveryAttemptEvidence::attempt(&self) -> radroots_storage::outbox::DeliveryAttempt 1131 pub const fn radroots_storage::outbox::DeliveryAttemptEvidence::expected_revision(&self) -> radroots_storage::outbox::OutboxRevision 1132 pub const fn radroots_storage::outbox::DeliveryAttemptEvidence::item_id(&self) -> radroots_storage::outbox::OutboxItemId 1133 pub const fn radroots_storage::outbox::DeliveryAttemptEvidence::lease_id(&self) -> radroots_storage::outbox::LeaseId 1134 pub fn radroots_storage::outbox::DeliveryAttemptEvidence::new(radroots_storage::outbox::OutboxItemId, radroots_storage::outbox::LeaseId, radroots_storage::outbox::OutboxRevision, radroots_storage::outbox::DeliveryAttempt, radroots_transport::sink::DeliveryReceipt, u64) -> core::result::Result<Self, radroots_storage::Error> 1135 pub const fn radroots_storage::outbox::DeliveryAttemptEvidence::receipt(&self) -> &radroots_transport::sink::DeliveryReceipt 1136 pub const fn radroots_storage::outbox::DeliveryAttemptEvidence::recorded_at_unix_ms(&self) -> u64 1137 pub struct radroots_storage::outbox::DeliveryPlanDigest(_) 1138 impl radroots_storage::outbox::DeliveryPlanDigest 1139 pub const fn radroots_storage::outbox::DeliveryPlanDigest::as_bytes(&self) -> &[u8; 32] 1140 pub const fn radroots_storage::outbox::DeliveryPlanDigest::new([u8; 32]) -> Self 1141 pub struct radroots_storage::outbox::EnqueueOutboxItem 1142 impl radroots_storage::outbox::EnqueueOutboxItem 1143 pub const fn radroots_storage::outbox::EnqueueOutboxItem::created_at_unix_ms(&self) -> u64 1144 pub fn radroots_storage::outbox::EnqueueOutboxItem::into_record(self) -> radroots_storage::outbox::OutboxRecord 1145 pub const fn radroots_storage::outbox::EnqueueOutboxItem::item_id(&self) -> radroots_storage::outbox::OutboxItemId 1146 pub fn radroots_storage::outbox::EnqueueOutboxItem::new(radroots_storage::outbox::OutboxItemId, radroots_storage::journal::OperationInstanceId, radroots_storage::outbox::DeliveryPlanDigest, radroots_transport::sink::DeliveryRequest, u64) -> core::result::Result<Self, radroots_storage::Error> 1147 pub const fn radroots_storage::outbox::EnqueueOutboxItem::operation_instance_id(&self) -> radroots_storage::journal::OperationInstanceId 1148 pub const fn radroots_storage::outbox::EnqueueOutboxItem::plan_digest(&self) -> radroots_storage::outbox::DeliveryPlanDigest 1149 pub const fn radroots_storage::outbox::EnqueueOutboxItem::request(&self) -> &radroots_transport::sink::DeliveryRequest 1150 pub struct radroots_storage::outbox::EnqueueReceipt 1151 impl radroots_storage::outbox::EnqueueReceipt 1152 pub const fn radroots_storage::outbox::EnqueueReceipt::disposition(&self) -> radroots_storage::outbox::EnqueueDisposition 1153 pub const fn radroots_storage::outbox::EnqueueReceipt::new(radroots_storage::outbox::EnqueueDisposition, radroots_storage::outbox::OutboxRecord) -> Self 1154 pub const fn radroots_storage::outbox::EnqueueReceipt::record(&self) -> &radroots_storage::outbox::OutboxRecord 1155 pub struct radroots_storage::outbox::LeaseId(_) 1156 impl radroots_storage::outbox::LeaseId 1157 pub const fn radroots_storage::outbox::LeaseId::as_bytes(&self) -> &[u8; 16] 1158 pub const fn radroots_storage::outbox::LeaseId::new([u8; 16]) -> core::result::Result<Self, radroots_storage::Error> 1159 pub struct radroots_storage::outbox::LeaseOwner(_) 1160 impl radroots_storage::outbox::LeaseOwner 1161 pub fn radroots_storage::outbox::LeaseOwner::as_str(&self) -> &str 1162 pub fn radroots_storage::outbox::LeaseOwner::parse(impl core::convert::Into<alloc::string::String>) -> core::result::Result<Self, radroots_storage::Error> 1163 impl core::fmt::Debug for radroots_storage::outbox::LeaseOwner 1164 pub fn radroots_storage::outbox::LeaseOwner::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 1165 impl serde_core::ser::Serialize for radroots_storage::outbox::LeaseOwner 1166 pub fn radroots_storage::outbox::LeaseOwner::serialize<S>(&self, S) -> core::result::Result<<S as serde_core::ser::Serializer>::Ok, <S as serde_core::ser::Serializer>::Error> where S: serde_core::ser::Serializer 1167 impl<'de> serde_core::de::Deserialize<'de> for radroots_storage::outbox::LeaseOwner 1168 pub fn radroots_storage::outbox::LeaseOwner::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 1169 pub struct radroots_storage::outbox::OutboxItemId(_) 1170 impl radroots_storage::outbox::OutboxItemId 1171 pub const fn radroots_storage::outbox::OutboxItemId::as_bytes(&self) -> &[u8; 16] 1172 pub const fn radroots_storage::outbox::OutboxItemId::new([u8; 16]) -> core::result::Result<Self, radroots_storage::Error> 1173 pub struct radroots_storage::outbox::OutboxLease 1174 impl radroots_storage::outbox::OutboxLease 1175 pub const fn radroots_storage::outbox::OutboxLease::acquired_at_unix_ms(&self) -> u64 1176 pub const fn radroots_storage::outbox::OutboxLease::expires_at_unix_ms(&self) -> u64 1177 pub const fn radroots_storage::outbox::OutboxLease::id(&self) -> radroots_storage::outbox::LeaseId 1178 pub const fn radroots_storage::outbox::OutboxLease::is_active_at(&self, u64) -> bool 1179 pub fn radroots_storage::outbox::OutboxLease::new(radroots_storage::outbox::LeaseId, radroots_storage::outbox::LeaseOwner, u64, u64) -> core::result::Result<Self, radroots_storage::Error> 1180 pub const fn radroots_storage::outbox::OutboxLease::owner(&self) -> &radroots_storage::outbox::LeaseOwner 1181 pub struct radroots_storage::outbox::OutboxRecord 1182 impl radroots_storage::outbox::OutboxRecord 1183 pub fn radroots_storage::outbox::OutboxRecord::claim(&mut self, radroots_storage::outbox::OutboxLease) -> core::result::Result<(), radroots_storage::Error> 1184 pub const fn radroots_storage::outbox::OutboxRecord::created_at_unix_ms(&self) -> u64 1185 pub fn radroots_storage::outbox::OutboxRecord::evidence(&self) -> &[radroots_storage::outbox::TargetDeliveryEvidence] 1186 pub fn radroots_storage::outbox::OutboxRecord::from_durable_parts(radroots_storage::outbox::EnqueueOutboxItem, radroots_storage::outbox::OutboxRevision, radroots_storage::outbox::OutboxStage, core::option::Option<radroots_storage::outbox::OutboxLease>, core::option::Option<radroots_storage::outbox::DeliveryAttempt>, alloc::vec::Vec<radroots_storage::outbox::TargetDeliveryEvidence>, radroots_storage::outbox::SatisfactionResult, core::option::Option<u64>, u64) -> core::result::Result<Self, radroots_storage::Error> 1187 pub const fn radroots_storage::outbox::OutboxRecord::item_id(&self) -> radroots_storage::outbox::OutboxItemId 1188 pub const fn radroots_storage::outbox::OutboxRecord::last_attempt(&self) -> core::option::Option<radroots_storage::outbox::DeliveryAttempt> 1189 pub fn radroots_storage::outbox::OutboxRecord::latest_target_evidence(&self, &radroots_transport::target::TargetFingerprint) -> core::option::Option<&radroots_storage::outbox::TargetDeliveryEvidence> 1190 pub const fn radroots_storage::outbox::OutboxRecord::lease(&self) -> core::option::Option<&radroots_storage::outbox::OutboxLease> 1191 pub const fn radroots_storage::outbox::OutboxRecord::operation_instance_id(&self) -> radroots_storage::journal::OperationInstanceId 1192 pub const fn radroots_storage::outbox::OutboxRecord::plan_digest(&self) -> radroots_storage::outbox::DeliveryPlanDigest 1193 pub fn radroots_storage::outbox::OutboxRecord::record_attempt(&mut self, radroots_storage::outbox::DeliveryAttemptEvidence) -> core::result::Result<(), radroots_storage::Error> 1194 pub fn radroots_storage::outbox::OutboxRecord::release(&mut self, radroots_storage::outbox::LeaseId, radroots_storage::outbox::OutboxRevision, u64, core::option::Option<u64>) -> core::result::Result<(), radroots_storage::Error> 1195 pub const fn radroots_storage::outbox::OutboxRecord::request(&self) -> &radroots_transport::sink::DeliveryRequest 1196 pub const fn radroots_storage::outbox::OutboxRecord::retry_not_before_unix_ms(&self) -> core::option::Option<u64> 1197 pub const fn radroots_storage::outbox::OutboxRecord::revision(&self) -> radroots_storage::outbox::OutboxRevision 1198 pub const fn radroots_storage::outbox::OutboxRecord::satisfaction(&self) -> radroots_storage::outbox::SatisfactionResult 1199 pub const fn radroots_storage::outbox::OutboxRecord::stage(&self) -> radroots_storage::outbox::OutboxStage 1200 pub const fn radroots_storage::outbox::OutboxRecord::updated_at_unix_ms(&self) -> u64 1201 pub struct radroots_storage::outbox::OutboxRevision(_) 1202 impl radroots_storage::outbox::OutboxRevision 1203 pub const radroots_storage::outbox::OutboxRevision::INITIAL: Self 1204 pub const fn radroots_storage::outbox::OutboxRevision::get(self) -> u64 1205 pub const fn radroots_storage::outbox::OutboxRevision::new(u64) -> core::result::Result<Self, radroots_storage::Error> 1206 pub struct radroots_storage::outbox::OutboxStatus 1207 pub radroots_storage::outbox::OutboxStatus::exhausted: u64 1208 pub radroots_storage::outbox::OutboxStatus::leased: u64 1209 pub radroots_storage::outbox::OutboxStatus::pending: u64 1210 pub radroots_storage::outbox::OutboxStatus::retryable: u64 1211 pub radroots_storage::outbox::OutboxStatus::satisfied: u64 1212 impl radroots_storage::outbox::OutboxStatus 1213 pub fn radroots_storage::outbox::OutboxStatus::total(self) -> core::option::Option<u64> 1214 pub struct radroots_storage::outbox::TargetDeliveryEvidence 1215 impl radroots_storage::outbox::TargetDeliveryEvidence 1216 pub const fn radroots_storage::outbox::TargetDeliveryEvidence::attempt(&self) -> radroots_storage::outbox::DeliveryAttempt 1217 pub fn radroots_storage::outbox::TargetDeliveryEvidence::new(radroots_transport::target::TargetFingerprint, radroots_storage::outbox::DeliveryAttempt, bool, radroots_transport::outcome::DeliveryOutcome, u64) -> core::result::Result<Self, radroots_storage::Error> 1218 pub const fn radroots_storage::outbox::TargetDeliveryEvidence::outcome(&self) -> &radroots_transport::outcome::DeliveryOutcome 1219 pub const fn radroots_storage::outbox::TargetDeliveryEvidence::recorded_at_unix_ms(&self) -> u64 1220 pub const fn radroots_storage::outbox::TargetDeliveryEvidence::target(&self) -> &radroots_transport::target::TargetFingerprint 1221 pub const fn radroots_storage::outbox::TargetDeliveryEvidence::was_attempted(&self) -> bool 1222 pub const radroots_storage::outbox::LEASE_OWNER_MAX_BYTES: usize 1223 pub const radroots_storage::outbox::OUTBOX_CLAIM_LIMIT_MAX: u16 1224 pub trait radroots_storage::outbox::Outbox: core::marker::Send + core::marker::Sync 1225 pub fn radroots_storage::outbox::Outbox::claim(&self, radroots_storage::outbox::ClaimOutboxItems) -> radroots_transport::source::BoxFuture<'_, core::result::Result<alloc::vec::Vec<radroots_storage::outbox::ClaimedOutboxItem>, radroots_storage::Error>> 1226 pub fn radroots_storage::outbox::Outbox::enqueue(&self, radroots_storage::outbox::EnqueueOutboxItem) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::outbox::EnqueueReceipt, radroots_storage::Error>> 1227 pub fn radroots_storage::outbox::Outbox::item(&self, radroots_storage::outbox::OutboxItemId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::outbox::OutboxRecord>, radroots_storage::Error>> 1228 pub fn radroots_storage::outbox::Outbox::record_attempt(&self, radroots_storage::outbox::DeliveryAttemptEvidence) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::outbox::OutboxRecord, radroots_storage::Error>> 1229 pub fn radroots_storage::outbox::Outbox::release(&self, radroots_storage::outbox::OutboxItemId, radroots_storage::outbox::LeaseId, radroots_storage::outbox::OutboxRevision, u64, core::option::Option<u64>) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::outbox::OutboxRecord, radroots_storage::Error>> 1230 pub fn radroots_storage::outbox::Outbox::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::outbox::OutboxStatus, radroots_storage::Error>> 1231 impl radroots_storage::outbox::Outbox for radroots_storage::memory::MemoryStorage 1232 pub fn radroots_storage::memory::MemoryStorage::claim(&self, radroots_storage::outbox::ClaimOutboxItems) -> radroots_transport::source::BoxFuture<'_, core::result::Result<alloc::vec::Vec<radroots_storage::outbox::ClaimedOutboxItem>, radroots_storage::Error>> 1233 pub fn radroots_storage::memory::MemoryStorage::enqueue(&self, radroots_storage::outbox::EnqueueOutboxItem) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::outbox::EnqueueReceipt, radroots_storage::Error>> 1234 pub fn radroots_storage::memory::MemoryStorage::item(&self, radroots_storage::outbox::OutboxItemId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::outbox::OutboxRecord>, radroots_storage::Error>> 1235 pub fn radroots_storage::memory::MemoryStorage::record_attempt(&self, radroots_storage::outbox::DeliveryAttemptEvidence) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::outbox::OutboxRecord, radroots_storage::Error>> 1236 pub fn radroots_storage::memory::MemoryStorage::release(&self, radroots_storage::outbox::OutboxItemId, radroots_storage::outbox::LeaseId, radroots_storage::outbox::OutboxRevision, u64, core::option::Option<u64>) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::outbox::OutboxRecord, radroots_storage::Error>> 1237 pub fn radroots_storage::memory::MemoryStorage::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::outbox::OutboxStatus, radroots_storage::Error>> 1238 pub mod radroots_storage::private_artifact 1239 pub enum radroots_storage::private_artifact::DeletionReason 1240 pub radroots_storage::private_artifact::DeletionReason::IntegrityFailure 1241 pub radroots_storage::private_artifact::DeletionReason::KeyRevoked 1242 pub radroots_storage::private_artifact::DeletionReason::OperatorRequested 1243 pub radroots_storage::private_artifact::DeletionReason::RetentionExpired 1244 pub radroots_storage::private_artifact::DeletionReason::UserRequested 1245 pub enum radroots_storage::private_artifact::PrivateArtifactResealDisposition 1246 pub radroots_storage::private_artifact::PrivateArtifactResealDisposition::Committed 1247 pub radroots_storage::private_artifact::PrivateArtifactResealDisposition::Replayed 1248 pub enum radroots_storage::private_artifact::PrivateArtifactStage 1249 pub radroots_storage::private_artifact::PrivateArtifactStage::Active 1250 pub radroots_storage::private_artifact::PrivateArtifactStage::Expired 1251 pub radroots_storage::private_artifact::PrivateArtifactStage::Tombstoned 1252 pub struct radroots_storage::private_artifact::ArtifactCommitment(_) 1253 impl radroots_storage::private_artifact::ArtifactCommitment 1254 pub const fn radroots_storage::private_artifact::ArtifactCommitment::as_bytes(&self) -> &[u8; 32] 1255 pub const fn radroots_storage::private_artifact::ArtifactCommitment::new([u8; 32]) -> Self 1256 pub struct radroots_storage::private_artifact::ArtifactKind(_) 1257 impl radroots_storage::private_artifact::ArtifactKind 1258 pub fn radroots_storage::private_artifact::ArtifactKind::as_str(&self) -> &str 1259 pub fn radroots_storage::private_artifact::ArtifactKind::parse(impl core::convert::Into<alloc::string::String>) -> core::result::Result<Self, radroots_storage::Error> 1260 impl serde_core::ser::Serialize for radroots_storage::private_artifact::ArtifactKind 1261 pub fn radroots_storage::private_artifact::ArtifactKind::serialize<S>(&self, S) -> core::result::Result<<S as serde_core::ser::Serializer>::Ok, <S as serde_core::ser::Serializer>::Error> where S: serde_core::ser::Serializer 1262 impl<'de> serde_core::de::Deserialize<'de> for radroots_storage::private_artifact::ArtifactKind 1263 pub fn radroots_storage::private_artifact::ArtifactKind::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 1264 pub struct radroots_storage::private_artifact::ArtifactSchemaId(_) 1265 impl radroots_storage::private_artifact::ArtifactSchemaId 1266 pub fn radroots_storage::private_artifact::ArtifactSchemaId::as_str(&self) -> &str 1267 pub fn radroots_storage::private_artifact::ArtifactSchemaId::parse(impl core::convert::Into<alloc::string::String>) -> core::result::Result<Self, radroots_storage::Error> 1268 impl serde_core::ser::Serialize for radroots_storage::private_artifact::ArtifactSchemaId 1269 pub fn radroots_storage::private_artifact::ArtifactSchemaId::serialize<S>(&self, S) -> core::result::Result<<S as serde_core::ser::Serializer>::Ok, <S as serde_core::ser::Serializer>::Error> where S: serde_core::ser::Serializer 1270 impl<'de> serde_core::de::Deserialize<'de> for radroots_storage::private_artifact::ArtifactSchemaId 1271 pub fn radroots_storage::private_artifact::ArtifactSchemaId::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 1272 pub struct radroots_storage::private_artifact::ArtifactTombstone 1273 impl radroots_storage::private_artifact::ArtifactTombstone 1274 pub const fn radroots_storage::private_artifact::ArtifactTombstone::commitment(self) -> radroots_storage::private_artifact::ArtifactCommitment 1275 pub const fn radroots_storage::private_artifact::ArtifactTombstone::deleted_at_unix_ms(self) -> u64 1276 pub const fn radroots_storage::private_artifact::ArtifactTombstone::reason(self) -> radroots_storage::private_artifact::DeletionReason 1277 pub struct radroots_storage::private_artifact::DurableSecretReference 1278 impl radroots_storage::private_artifact::DurableSecretReference 1279 pub const fn radroots_storage::private_artifact::DurableSecretReference::key_version(&self) -> u32 1280 pub fn radroots_storage::private_artifact::DurableSecretReference::new(impl core::convert::Into<alloc::string::String>, impl core::convert::Into<alloc::string::String>, u32) -> core::result::Result<Self, radroots_storage::Error> 1281 pub fn radroots_storage::private_artifact::DurableSecretReference::opaque_reference(&self) -> &str 1282 pub fn radroots_storage::private_artifact::DurableSecretReference::provider(&self) -> &str 1283 impl core::fmt::Debug for radroots_storage::private_artifact::DurableSecretReference 1284 pub fn radroots_storage::private_artifact::DurableSecretReference::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 1285 impl serde_core::ser::Serialize for radroots_storage::private_artifact::DurableSecretReference 1286 pub fn radroots_storage::private_artifact::DurableSecretReference::serialize<S>(&self, S) -> core::result::Result<<S as serde_core::ser::Serializer>::Ok, <S as serde_core::ser::Serializer>::Error> where S: serde_core::ser::Serializer 1287 impl<'de> serde_core::de::Deserialize<'de> for radroots_storage::private_artifact::DurableSecretReference 1288 pub fn radroots_storage::private_artifact::DurableSecretReference::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 1289 pub struct radroots_storage::private_artifact::PrivateArtifactEnvelopeContext 1290 impl radroots_storage::private_artifact::PrivateArtifactEnvelopeContext 1291 pub fn radroots_storage::private_artifact::PrivateArtifactEnvelopeContext::fingerprint(&self) -> [u8; 32] 1292 pub fn radroots_storage::private_artifact::PrivateArtifactEnvelopeContext::payload_schema(&self) -> &str 1293 pub fn radroots_storage::private_artifact::PrivateArtifactEnvelopeContext::purpose(&self) -> &str 1294 pub fn radroots_storage::private_artifact::PrivateArtifactEnvelopeContext::subject(&self) -> &str 1295 pub const fn radroots_storage::private_artifact::PrivateArtifactEnvelopeContext::subject_type(&self) -> &'static str 1296 impl core::fmt::Debug for radroots_storage::private_artifact::PrivateArtifactEnvelopeContext 1297 pub fn radroots_storage::private_artifact::PrivateArtifactEnvelopeContext::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 1298 pub struct radroots_storage::private_artifact::PrivateArtifactEnvelopeMigrationStatus 1299 pub radroots_storage::private_artifact::PrivateArtifactEnvelopeMigrationStatus::blocked_provider: u64 1300 pub radroots_storage::private_artifact::PrivateArtifactEnvelopeMigrationStatus::conflicted: u64 1301 pub radroots_storage::private_artifact::PrivateArtifactEnvelopeMigrationStatus::corrupt: u64 1302 pub radroots_storage::private_artifact::PrivateArtifactEnvelopeMigrationStatus::v1_pending: u64 1303 pub radroots_storage::private_artifact::PrivateArtifactEnvelopeMigrationStatus::v2_current: u64 1304 impl radroots_storage::private_artifact::PrivateArtifactEnvelopeMigrationStatus 1305 pub fn radroots_storage::private_artifact::PrivateArtifactEnvelopeMigrationStatus::total(self) -> core::option::Option<u64> 1306 pub struct radroots_storage::private_artifact::PrivateArtifactId(_) 1307 impl radroots_storage::private_artifact::PrivateArtifactId 1308 pub const fn radroots_storage::private_artifact::PrivateArtifactId::as_bytes(&self) -> &[u8; 16] 1309 pub const fn radroots_storage::private_artifact::PrivateArtifactId::new([u8; 16]) -> core::result::Result<Self, radroots_storage::Error> 1310 impl core::fmt::Debug for radroots_storage::private_artifact::PrivateArtifactId 1311 pub fn radroots_storage::private_artifact::PrivateArtifactId::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 1312 impl serde_core::ser::Serialize for radroots_storage::private_artifact::PrivateArtifactId 1313 pub fn radroots_storage::private_artifact::PrivateArtifactId::serialize<S>(&self, S) -> core::result::Result<<S as serde_core::ser::Serializer>::Ok, <S as serde_core::ser::Serializer>::Error> where S: serde_core::ser::Serializer 1314 impl<'de> serde_core::de::Deserialize<'de> for radroots_storage::private_artifact::PrivateArtifactId 1315 pub fn radroots_storage::private_artifact::PrivateArtifactId::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 1316 pub struct radroots_storage::private_artifact::PrivateArtifactMetadata 1317 impl radroots_storage::private_artifact::PrivateArtifactMetadata 1318 pub const fn radroots_storage::private_artifact::PrivateArtifactMetadata::artifact_id(&self) -> radroots_storage::private_artifact::PrivateArtifactId 1319 pub const fn radroots_storage::private_artifact::PrivateArtifactMetadata::commitment(&self) -> radroots_storage::private_artifact::ArtifactCommitment 1320 pub const fn radroots_storage::private_artifact::PrivateArtifactMetadata::created_at_unix_ms(&self) -> u64 1321 pub fn radroots_storage::private_artifact::PrivateArtifactMetadata::envelope_context(&self) -> radroots_storage::private_artifact::PrivateArtifactEnvelopeContext 1322 pub fn radroots_storage::private_artifact::PrivateArtifactMetadata::from_durable_parts(radroots_storage::private_artifact::PrivateArtifactId, radroots_storage::private_artifact::ArtifactKind, radroots_storage::private_artifact::ArtifactSchemaId, radroots_storage::private_artifact::ArtifactCommitment, u64, radroots_storage::private_artifact::DurableSecretReference, radroots_storage::private_artifact::RetentionPolicy, radroots_storage::private_artifact::PrivateArtifactRevision, radroots_storage::private_artifact::PrivateArtifactStage, u64, u64, core::option::Option<(u64, radroots_storage::private_artifact::DeletionReason, radroots_storage::private_artifact::ArtifactCommitment)>) -> core::result::Result<Self, radroots_storage::Error> 1323 pub const fn radroots_storage::private_artifact::PrivateArtifactMetadata::kind(&self) -> &radroots_storage::private_artifact::ArtifactKind 1324 pub fn radroots_storage::private_artifact::PrivateArtifactMetadata::mark_expired(&self, radroots_storage::private_artifact::PrivateArtifactRevision, u64) -> core::result::Result<Self, radroots_storage::Error> 1325 pub fn radroots_storage::private_artifact::PrivateArtifactMetadata::new(radroots_storage::private_artifact::PrivateArtifactId, radroots_storage::private_artifact::ArtifactKind, radroots_storage::private_artifact::ArtifactSchemaId, radroots_storage::private_artifact::ArtifactCommitment, u64, radroots_storage::private_artifact::DurableSecretReference, radroots_storage::private_artifact::RetentionPolicy, u64) -> core::result::Result<Self, radroots_storage::Error> 1326 pub const fn radroots_storage::private_artifact::PrivateArtifactMetadata::protected_size_bytes(&self) -> u64 1327 pub fn radroots_storage::private_artifact::PrivateArtifactMetadata::resealed(&self, &radroots_storage::private_artifact::PrivateArtifactResealRequest) -> core::result::Result<Self, radroots_storage::Error> 1328 pub const fn radroots_storage::private_artifact::PrivateArtifactMetadata::retention(&self) -> radroots_storage::private_artifact::RetentionPolicy 1329 pub const fn radroots_storage::private_artifact::PrivateArtifactMetadata::revision(&self) -> radroots_storage::private_artifact::PrivateArtifactRevision 1330 pub const fn radroots_storage::private_artifact::PrivateArtifactMetadata::schema_id(&self) -> &radroots_storage::private_artifact::ArtifactSchemaId 1331 pub const fn radroots_storage::private_artifact::PrivateArtifactMetadata::secret_reference(&self) -> &radroots_storage::private_artifact::DurableSecretReference 1332 pub const fn radroots_storage::private_artifact::PrivateArtifactMetadata::stage(&self) -> radroots_storage::private_artifact::PrivateArtifactStage 1333 pub fn radroots_storage::private_artifact::PrivateArtifactMetadata::tombstone(&self, radroots_storage::private_artifact::PrivateArtifactRevision, u64, radroots_storage::private_artifact::DeletionReason) -> core::result::Result<Self, radroots_storage::Error> 1334 pub const fn radroots_storage::private_artifact::PrivateArtifactMetadata::tombstone_record(&self) -> core::option::Option<radroots_storage::private_artifact::ArtifactTombstone> 1335 pub const fn radroots_storage::private_artifact::PrivateArtifactMetadata::updated_at_unix_ms(&self) -> u64 1336 impl serde_core::ser::Serialize for radroots_storage::private_artifact::PrivateArtifactMetadata 1337 pub fn radroots_storage::private_artifact::PrivateArtifactMetadata::serialize<S>(&self, S) -> core::result::Result<<S as serde_core::ser::Serializer>::Ok, <S as serde_core::ser::Serializer>::Error> where S: serde_core::ser::Serializer 1338 impl<'de> serde_core::de::Deserialize<'de> for radroots_storage::private_artifact::PrivateArtifactMetadata 1339 pub fn radroots_storage::private_artifact::PrivateArtifactMetadata::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 1340 pub struct radroots_storage::private_artifact::PrivateArtifactResealId(_) 1341 impl radroots_storage::private_artifact::PrivateArtifactResealId 1342 pub const fn radroots_storage::private_artifact::PrivateArtifactResealId::as_bytes(&self) -> &[u8; 16] 1343 pub const fn radroots_storage::private_artifact::PrivateArtifactResealId::new([u8; 16]) -> core::result::Result<Self, radroots_storage::Error> 1344 impl core::fmt::Debug for radroots_storage::private_artifact::PrivateArtifactResealId 1345 pub fn radroots_storage::private_artifact::PrivateArtifactResealId::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 1346 impl serde_core::ser::Serialize for radroots_storage::private_artifact::PrivateArtifactResealId 1347 pub fn radroots_storage::private_artifact::PrivateArtifactResealId::serialize<S>(&self, S) -> core::result::Result<<S as serde_core::ser::Serializer>::Ok, <S as serde_core::ser::Serializer>::Error> where S: serde_core::ser::Serializer 1348 impl<'de> serde_core::de::Deserialize<'de> for radroots_storage::private_artifact::PrivateArtifactResealId 1349 pub fn radroots_storage::private_artifact::PrivateArtifactResealId::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 1350 pub struct radroots_storage::private_artifact::PrivateArtifactResealReceipt 1351 impl radroots_storage::private_artifact::PrivateArtifactResealReceipt 1352 pub const fn radroots_storage::private_artifact::PrivateArtifactResealReceipt::artifact_id(self) -> radroots_storage::private_artifact::PrivateArtifactId 1353 pub fn radroots_storage::private_artifact::PrivateArtifactResealReceipt::committed(&radroots_storage::private_artifact::PrivateArtifactResealRequest, radroots_storage::private_artifact::PrivateArtifactRevision) -> Self 1354 pub const fn radroots_storage::private_artifact::PrivateArtifactResealReceipt::committed_revision(self) -> radroots_storage::private_artifact::PrivateArtifactRevision 1355 pub const fn radroots_storage::private_artifact::PrivateArtifactResealReceipt::disposition(self) -> radroots_storage::private_artifact::PrivateArtifactResealDisposition 1356 pub fn radroots_storage::private_artifact::PrivateArtifactResealReceipt::replay(&self, &radroots_storage::private_artifact::PrivateArtifactResealRequest) -> core::result::Result<Self, radroots_storage::Error> 1357 pub const fn radroots_storage::private_artifact::PrivateArtifactResealReceipt::request_fingerprint(self) -> [u8; 32] 1358 pub const fn radroots_storage::private_artifact::PrivateArtifactResealReceipt::reseal_id(self) -> radroots_storage::private_artifact::PrivateArtifactResealId 1359 impl core::fmt::Debug for radroots_storage::private_artifact::PrivateArtifactResealReceipt 1360 pub fn radroots_storage::private_artifact::PrivateArtifactResealReceipt::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 1361 pub struct radroots_storage::private_artifact::PrivateArtifactResealRequest 1362 impl radroots_storage::private_artifact::PrivateArtifactResealRequest 1363 pub const fn radroots_storage::private_artifact::PrivateArtifactResealRequest::artifact_id(&self) -> radroots_storage::private_artifact::PrivateArtifactId 1364 pub const fn radroots_storage::private_artifact::PrivateArtifactResealRequest::committed_at_unix_ms(&self) -> u64 1365 pub const fn radroots_storage::private_artifact::PrivateArtifactResealRequest::expected_commitment(&self) -> radroots_storage::private_artifact::ArtifactCommitment 1366 pub const fn radroots_storage::private_artifact::PrivateArtifactResealRequest::expected_revision(&self) -> radroots_storage::private_artifact::PrivateArtifactRevision 1367 pub fn radroots_storage::private_artifact::PrivateArtifactResealRequest::fingerprint(&self) -> [u8; 32] 1368 pub fn radroots_storage::private_artifact::PrivateArtifactResealRequest::new(radroots_storage::private_artifact::PrivateArtifactResealId, radroots_storage::private_artifact::PrivateArtifactId, radroots_storage::private_artifact::PrivateArtifactRevision, radroots_storage::private_artifact::ArtifactCommitment, radroots_storage::private_artifact::ArtifactCommitment, u64, radroots_storage::private_artifact::DurableSecretReference, u64) -> core::result::Result<Self, radroots_storage::Error> 1369 pub const fn radroots_storage::private_artifact::PrivateArtifactResealRequest::next_commitment(&self) -> radroots_storage::private_artifact::ArtifactCommitment 1370 pub const fn radroots_storage::private_artifact::PrivateArtifactResealRequest::next_protected_size_bytes(&self) -> u64 1371 pub const fn radroots_storage::private_artifact::PrivateArtifactResealRequest::next_secret_reference(&self) -> &radroots_storage::private_artifact::DurableSecretReference 1372 pub const fn radroots_storage::private_artifact::PrivateArtifactResealRequest::reseal_id(&self) -> radroots_storage::private_artifact::PrivateArtifactResealId 1373 impl core::fmt::Debug for radroots_storage::private_artifact::PrivateArtifactResealRequest 1374 pub fn radroots_storage::private_artifact::PrivateArtifactResealRequest::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 1375 pub struct radroots_storage::private_artifact::PrivateArtifactRevision(_) 1376 impl radroots_storage::private_artifact::PrivateArtifactRevision 1377 pub const radroots_storage::private_artifact::PrivateArtifactRevision::INITIAL: Self 1378 pub const fn radroots_storage::private_artifact::PrivateArtifactRevision::get(self) -> u64 1379 pub const fn radroots_storage::private_artifact::PrivateArtifactRevision::new(u64) -> core::result::Result<Self, radroots_storage::Error> 1380 impl serde_core::ser::Serialize for radroots_storage::private_artifact::PrivateArtifactRevision 1381 pub fn radroots_storage::private_artifact::PrivateArtifactRevision::serialize<S>(&self, S) -> core::result::Result<<S as serde_core::ser::Serializer>::Ok, <S as serde_core::ser::Serializer>::Error> where S: serde_core::ser::Serializer 1382 impl<'de> serde_core::de::Deserialize<'de> for radroots_storage::private_artifact::PrivateArtifactRevision 1383 pub fn radroots_storage::private_artifact::PrivateArtifactRevision::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 1384 pub struct radroots_storage::private_artifact::PrivateArtifactStatus 1385 pub radroots_storage::private_artifact::PrivateArtifactStatus::active: u64 1386 pub radroots_storage::private_artifact::PrivateArtifactStatus::expired: u64 1387 pub radroots_storage::private_artifact::PrivateArtifactStatus::tombstoned: u64 1388 impl radroots_storage::private_artifact::PrivateArtifactStatus 1389 pub fn radroots_storage::private_artifact::PrivateArtifactStatus::total(self) -> core::option::Option<u64> 1390 pub struct radroots_storage::private_artifact::RetentionPolicy 1391 impl radroots_storage::private_artifact::RetentionPolicy 1392 pub const fn radroots_storage::private_artifact::RetentionPolicy::delete_not_before_unix_ms(self) -> core::option::Option<u64> 1393 pub const fn radroots_storage::private_artifact::RetentionPolicy::expires_at_unix_ms(self) -> core::option::Option<u64> 1394 pub const fn radroots_storage::private_artifact::RetentionPolicy::indefinite() -> Self 1395 pub const fn radroots_storage::private_artifact::RetentionPolicy::is_expired_at(self, u64) -> bool 1396 pub const fn radroots_storage::private_artifact::RetentionPolicy::new(core::option::Option<u64>, core::option::Option<u64>) -> core::result::Result<Self, radroots_storage::Error> 1397 pub const fn radroots_storage::private_artifact::RetentionPolicy::permits_deletion_at(self, u64) -> bool 1398 impl serde_core::ser::Serialize for radroots_storage::private_artifact::RetentionPolicy 1399 pub fn radroots_storage::private_artifact::RetentionPolicy::serialize<S>(&self, S) -> core::result::Result<<S as serde_core::ser::Serializer>::Ok, <S as serde_core::ser::Serializer>::Error> where S: serde_core::ser::Serializer 1400 impl<'de> serde_core::de::Deserialize<'de> for radroots_storage::private_artifact::RetentionPolicy 1401 pub fn radroots_storage::private_artifact::RetentionPolicy::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 1402 pub const radroots_storage::private_artifact::ARTIFACT_KIND_MAX_BYTES: usize 1403 pub const radroots_storage::private_artifact::ARTIFACT_SCHEMA_MAX_BYTES: usize 1404 pub const radroots_storage::private_artifact::EXPIRED_ARTIFACT_QUERY_LIMIT_MAX: u16 1405 pub const radroots_storage::private_artifact::PRIVATE_ARTIFACT_ENVELOPE_PURPOSE_PREFIX: &str 1406 pub const radroots_storage::private_artifact::PRIVATE_ARTIFACT_ENVELOPE_SUBJECT_TYPE: &str 1407 pub const radroots_storage::private_artifact::SECRET_PROVIDER_MAX_BYTES: usize 1408 pub const radroots_storage::private_artifact::SECRET_REFERENCE_MAX_BYTES: usize 1409 pub trait radroots_storage::private_artifact::PrivateArtifactStore: core::marker::Send + core::marker::Sync 1410 pub fn radroots_storage::private_artifact::PrivateArtifactStore::expired(&self, u64, u16) -> radroots_transport::source::BoxFuture<'_, core::result::Result<alloc::vec::Vec<radroots_storage::private_artifact::PrivateArtifactMetadata>, radroots_storage::Error>> 1411 pub fn radroots_storage::private_artifact::PrivateArtifactStore::mark_expired(&self, radroots_storage::private_artifact::PrivateArtifactId, radroots_storage::private_artifact::PrivateArtifactRevision, u64) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::private_artifact::PrivateArtifactMetadata, radroots_storage::Error>> 1412 pub fn radroots_storage::private_artifact::PrivateArtifactStore::metadata(&self, radroots_storage::private_artifact::PrivateArtifactId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::private_artifact::PrivateArtifactMetadata>, radroots_storage::Error>> 1413 pub fn radroots_storage::private_artifact::PrivateArtifactStore::put_metadata(&self, radroots_storage::private_artifact::PrivateArtifactMetadata) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::private_artifact::PrivateArtifactMetadata, radroots_storage::Error>> 1414 pub fn radroots_storage::private_artifact::PrivateArtifactStore::reseal_metadata(&self, radroots_storage::private_artifact::PrivateArtifactResealRequest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::private_artifact::PrivateArtifactResealReceipt, radroots_storage::Error>> 1415 pub fn radroots_storage::private_artifact::PrivateArtifactStore::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::private_artifact::PrivateArtifactStatus, radroots_storage::Error>> 1416 pub fn radroots_storage::private_artifact::PrivateArtifactStore::tombstone(&self, radroots_storage::private_artifact::PrivateArtifactId, radroots_storage::private_artifact::PrivateArtifactRevision, u64, radroots_storage::private_artifact::DeletionReason) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::private_artifact::PrivateArtifactMetadata, radroots_storage::Error>> 1417 impl radroots_storage::private_artifact::PrivateArtifactStore for radroots_storage::memory::MemoryStorage 1418 pub fn radroots_storage::memory::MemoryStorage::expired(&self, u64, u16) -> radroots_transport::source::BoxFuture<'_, core::result::Result<alloc::vec::Vec<radroots_storage::private_artifact::PrivateArtifactMetadata>, radroots_storage::Error>> 1419 pub fn radroots_storage::memory::MemoryStorage::mark_expired(&self, radroots_storage::private_artifact::PrivateArtifactId, radroots_storage::private_artifact::PrivateArtifactRevision, u64) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::private_artifact::PrivateArtifactMetadata, radroots_storage::Error>> 1420 pub fn radroots_storage::memory::MemoryStorage::metadata(&self, radroots_storage::private_artifact::PrivateArtifactId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::private_artifact::PrivateArtifactMetadata>, radroots_storage::Error>> 1421 pub fn radroots_storage::memory::MemoryStorage::put_metadata(&self, radroots_storage::private_artifact::PrivateArtifactMetadata) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::private_artifact::PrivateArtifactMetadata, radroots_storage::Error>> 1422 pub fn radroots_storage::memory::MemoryStorage::reseal_metadata(&self, radroots_storage::private_artifact::PrivateArtifactResealRequest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::private_artifact::PrivateArtifactResealReceipt, radroots_storage::Error>> 1423 pub fn radroots_storage::memory::MemoryStorage::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::private_artifact::PrivateArtifactStatus, radroots_storage::Error>> 1424 pub fn radroots_storage::memory::MemoryStorage::tombstone(&self, radroots_storage::private_artifact::PrivateArtifactId, radroots_storage::private_artifact::PrivateArtifactRevision, u64, radroots_storage::private_artifact::DeletionReason) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::private_artifact::PrivateArtifactMetadata, radroots_storage::Error>> 1425 pub mod radroots_storage::projection 1426 pub use radroots_storage::projection::BoxFuture 1427 pub use radroots_storage::projection::EventId 1428 pub mod radroots_storage::projection::document_query 1429 pub enum radroots_storage::projection::document_query::ProjectionDocumentGenerations 1430 pub radroots_storage::projection::document_query::ProjectionDocumentGenerations::All 1431 pub radroots_storage::projection::document_query::ProjectionDocumentGenerations::Exact(radroots_storage::projection::ProjectionGeneration) 1432 pub struct radroots_storage::projection::document_query::ProjectionDocumentCursor 1433 pub struct radroots_storage::projection::document_query::ProjectionDocumentPage 1434 impl radroots_storage::projection::document_query::ProjectionDocumentPage 1435 pub fn radroots_storage::projection::document_query::ProjectionDocumentPage::into_records(self) -> alloc::vec::Vec<radroots_storage::projection::document_query::ProjectionDocumentRecord> 1436 pub fn radroots_storage::projection::document_query::ProjectionDocumentPage::new(&radroots_storage::projection::document_query::ProjectionDocumentQuery, alloc::vec::Vec<radroots_storage::projection::document_query::ProjectionDocumentRecord>, bool) -> core::result::Result<Self, radroots_storage::Error> 1437 pub const fn radroots_storage::projection::document_query::ProjectionDocumentPage::next_cursor(&self) -> core::option::Option<&radroots_storage::projection::document_query::ProjectionDocumentCursor> 1438 pub fn radroots_storage::projection::document_query::ProjectionDocumentPage::records(&self) -> &[radroots_storage::projection::document_query::ProjectionDocumentRecord] 1439 pub struct radroots_storage::projection::document_query::ProjectionDocumentQuery 1440 impl radroots_storage::projection::document_query::ProjectionDocumentQuery 1441 pub fn radroots_storage::projection::document_query::ProjectionDocumentQuery::after(&self) -> core::option::Option<(radroots_storage::projection::ProjectionGeneration, &str)> 1442 pub const fn radroots_storage::projection::document_query::ProjectionDocumentQuery::generations(&self) -> radroots_storage::projection::document_query::ProjectionDocumentGenerations 1443 pub const fn radroots_storage::projection::document_query::ProjectionDocumentQuery::limit(&self) -> u16 1444 pub fn radroots_storage::projection::document_query::ProjectionDocumentQuery::matches(&self, radroots_storage::projection::ProjectionGeneration, &str) -> bool 1445 pub fn radroots_storage::projection::document_query::ProjectionDocumentQuery::new(radroots_storage::projection::ProjectionId, radroots_storage::projection::document_query::ProjectionDocumentGenerations, u16) -> core::result::Result<Self, radroots_storage::Error> 1446 pub fn radroots_storage::projection::document_query::ProjectionDocumentQuery::projection_id(&self) -> &radroots_storage::projection::ProjectionId 1447 pub fn radroots_storage::projection::document_query::ProjectionDocumentQuery::with_cursor(self, &radroots_storage::projection::document_query::ProjectionDocumentCursor) -> core::result::Result<Self, radroots_storage::Error> 1448 pub struct radroots_storage::projection::document_query::ProjectionDocumentRecord 1449 impl radroots_storage::projection::document_query::ProjectionDocumentRecord 1450 pub fn radroots_storage::projection::document_query::ProjectionDocumentRecord::corrupt(radroots_storage::projection::ProjectionGeneration, alloc::string::String) -> core::result::Result<Self, radroots_storage::Error> 1451 pub const fn radroots_storage::projection::document_query::ProjectionDocumentRecord::document(&self) -> core::option::Option<&radroots_storage::projection::ProjectionDocument> 1452 pub const fn radroots_storage::projection::document_query::ProjectionDocumentRecord::generation(&self) -> radroots_storage::projection::ProjectionGeneration 1453 pub fn radroots_storage::projection::document_query::ProjectionDocumentRecord::key(&self) -> &str 1454 pub fn radroots_storage::projection::document_query::ProjectionDocumentRecord::new(radroots_storage::projection::ProjectionGeneration, radroots_storage::projection::ProjectionDocument) -> core::result::Result<Self, radroots_storage::Error> 1455 impl core::fmt::Debug for radroots_storage::projection::document_query::ProjectionDocumentRecord 1456 pub fn radroots_storage::projection::document_query::ProjectionDocumentRecord::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 1457 pub const radroots_storage::projection::document_query::PROJECTION_DOCUMENT_PAGE_BYTES_MAX: usize 1458 pub const radroots_storage::projection::document_query::PROJECTION_DOCUMENT_QUERY_LIMIT_MAX: u16 1459 pub enum radroots_storage::projection::InvalidationReason 1460 pub radroots_storage::projection::InvalidationReason::EventIndexManifestChanged 1461 pub radroots_storage::projection::InvalidationReason::IntegrityFailure 1462 pub radroots_storage::projection::InvalidationReason::OperatorRequested 1463 pub radroots_storage::projection::InvalidationReason::ProjectionGenerationChanged 1464 pub radroots_storage::projection::InvalidationReason::SourceGenerationChanged 1465 pub enum radroots_storage::projection::ProjectionHealth 1466 pub radroots_storage::projection::ProjectionHealth::Failed 1467 pub radroots_storage::projection::ProjectionHealth::Invalidated 1468 pub radroots_storage::projection::ProjectionHealth::Ready 1469 pub radroots_storage::projection::ProjectionHealth::Rebuilding 1470 pub enum radroots_storage::projection::RebuildFailure 1471 pub radroots_storage::projection::RebuildFailure::IntegrityFailure 1472 pub radroots_storage::projection::RebuildFailure::PromotionRejected 1473 pub radroots_storage::projection::RebuildFailure::ReducerRejected 1474 pub radroots_storage::projection::RebuildFailure::SourceChanged 1475 pub enum radroots_storage::projection::RebuildStage 1476 pub radroots_storage::projection::RebuildStage::Completed 1477 pub radroots_storage::projection::RebuildStage::Failed 1478 pub radroots_storage::projection::RebuildStage::Requested 1479 pub radroots_storage::projection::RebuildStage::Running 1480 pub struct radroots_storage::projection::ArtifactDigest(_) 1481 impl radroots_storage::projection::ArtifactDigest 1482 pub const fn radroots_storage::projection::ArtifactDigest::as_bytes(&self) -> &[u8; 32] 1483 pub const fn radroots_storage::projection::ArtifactDigest::new([u8; 32]) -> Self 1484 pub struct radroots_storage::projection::EventIdRange 1485 impl radroots_storage::projection::EventIdRange 1486 pub const fn radroots_storage::projection::EventIdRange::first(&self) -> &radroots_event::id::EventId 1487 pub const fn radroots_storage::projection::EventIdRange::last(&self) -> &radroots_event::id::EventId 1488 pub fn radroots_storage::projection::EventIdRange::new(radroots_event::id::EventId, radroots_event::id::EventId) -> core::result::Result<Self, radroots_storage::Error> 1489 pub struct radroots_storage::projection::EventIndexCheckpoint 1490 impl radroots_storage::projection::EventIndexCheckpoint 1491 pub const fn radroots_storage::projection::EventIndexCheckpoint::generated_at_unix_ms(&self) -> u64 1492 pub const fn radroots_storage::projection::EventIndexCheckpoint::generation(&self) -> radroots_storage::projection::ProjectionGeneration 1493 pub fn radroots_storage::projection::EventIndexCheckpoint::new(radroots_storage::projection::ProjectionGeneration, u64, alloc::vec::Vec<radroots_storage::projection::EventIndexShardCheckpoint>) -> core::result::Result<Self, radroots_storage::Error> 1494 pub fn radroots_storage::projection::EventIndexCheckpoint::shard(&self, &radroots_storage::projection::EventIndexShardId) -> core::option::Option<&radroots_storage::projection::EventIndexShardCheckpoint> 1495 pub fn radroots_storage::projection::EventIndexCheckpoint::shards(&self) -> &[radroots_storage::projection::EventIndexShardCheckpoint] 1496 pub struct radroots_storage::projection::EventIndexManifest 1497 impl radroots_storage::projection::EventIndexManifest 1498 pub const fn radroots_storage::projection::EventIndexManifest::first_published_at_unix_s(&self) -> u64 1499 pub const fn radroots_storage::projection::EventIndexManifest::generation(&self) -> radroots_storage::projection::ProjectionGeneration 1500 pub const fn radroots_storage::projection::EventIndexManifest::last_published_at_unix_s(&self) -> u64 1501 pub fn radroots_storage::projection::EventIndexManifest::new(radroots_storage::projection::ProjectionGeneration, u64, u32, u64, u64, alloc::vec::Vec<radroots_storage::projection::EventIndexShard>) -> core::result::Result<Self, radroots_storage::Error> 1502 pub fn radroots_storage::projection::EventIndexManifest::shards(&self) -> &[radroots_storage::projection::EventIndexShard] 1503 pub const fn radroots_storage::projection::EventIndexManifest::target_shard_size(&self) -> u32 1504 pub const fn radroots_storage::projection::EventIndexManifest::total_events(&self) -> u64 1505 pub struct radroots_storage::projection::EventIndexShard 1506 impl radroots_storage::projection::EventIndexShard 1507 pub fn radroots_storage::projection::EventIndexShard::artifact_path(&self) -> &str 1508 pub const fn radroots_storage::projection::EventIndexShard::event_count(&self) -> u32 1509 pub const fn radroots_storage::projection::EventIndexShard::event_ids(&self) -> &radroots_storage::projection::EventIdRange 1510 pub const fn radroots_storage::projection::EventIndexShard::first_published_at_unix_s(&self) -> u64 1511 pub const fn radroots_storage::projection::EventIndexShard::last_published_at_unix_s(&self) -> u64 1512 pub fn radroots_storage::projection::EventIndexShard::new(radroots_storage::projection::EventIndexShardId, impl core::convert::Into<alloc::string::String>, u32, radroots_storage::projection::EventIdRange, u64, u64, radroots_storage::projection::ArtifactDigest) -> core::result::Result<Self, radroots_storage::Error> 1513 pub const fn radroots_storage::projection::EventIndexShard::sha256(&self) -> radroots_storage::projection::ArtifactDigest 1514 pub const fn radroots_storage::projection::EventIndexShard::shard_id(&self) -> &radroots_storage::projection::EventIndexShardId 1515 pub struct radroots_storage::projection::EventIndexShardCheckpoint 1516 impl radroots_storage::projection::EventIndexShardCheckpoint 1517 pub fn radroots_storage::projection::EventIndexShardCheckpoint::cursor(&self) -> core::option::Option<&str> 1518 pub const fn radroots_storage::projection::EventIndexShardCheckpoint::last_created_at_unix_s(&self) -> u64 1519 pub const fn radroots_storage::projection::EventIndexShardCheckpoint::last_event_id(&self) -> core::option::Option<&radroots_event::id::EventId> 1520 pub fn radroots_storage::projection::EventIndexShardCheckpoint::new(radroots_storage::projection::EventIndexShardId, u64, core::option::Option<radroots_event::id::EventId>, core::option::Option<alloc::string::String>) -> core::result::Result<Self, radroots_storage::Error> 1521 pub const fn radroots_storage::projection::EventIndexShardCheckpoint::shard_id(&self) -> &radroots_storage::projection::EventIndexShardId 1522 pub struct radroots_storage::projection::EventIndexShardId(_) 1523 impl radroots_storage::projection::EventIndexShardId 1524 pub fn radroots_storage::projection::EventIndexShardId::as_str(&self) -> &str 1525 pub fn radroots_storage::projection::EventIndexShardId::parse(impl core::convert::Into<alloc::string::String>) -> core::result::Result<Self, radroots_storage::Error> 1526 pub struct radroots_storage::projection::ProjectionCheckpoint 1527 impl radroots_storage::projection::ProjectionCheckpoint 1528 pub fn radroots_storage::projection::ProjectionCheckpoint::advances(&self, &Self) -> bool 1529 pub const fn radroots_storage::projection::ProjectionCheckpoint::generation(&self) -> radroots_storage::projection::ProjectionGeneration 1530 pub fn radroots_storage::projection::ProjectionCheckpoint::new(radroots_storage::projection::ProjectionId, radroots_storage::projection::ProjectionGeneration, core::option::Option<radroots_storage::event::EventPosition>, u64, u64) -> core::result::Result<Self, radroots_storage::Error> 1531 pub const fn radroots_storage::projection::ProjectionCheckpoint::projected_rows(&self) -> u64 1532 pub const fn radroots_storage::projection::ProjectionCheckpoint::projection_id(&self) -> &radroots_storage::projection::ProjectionId 1533 pub const fn radroots_storage::projection::ProjectionCheckpoint::source_position(&self) -> core::option::Option<radroots_storage::event::EventPosition> 1534 pub const fn radroots_storage::projection::ProjectionCheckpoint::updated_at_unix_ms(&self) -> u64 1535 pub struct radroots_storage::projection::ProjectionDocument 1536 impl radroots_storage::projection::ProjectionDocument 1537 pub fn radroots_storage::projection::ProjectionDocument::from_stored_parts(alloc::string::String, alloc::vec::Vec<u8>, [u8; 32]) -> core::result::Result<Self, radroots_storage::Error> 1538 pub fn radroots_storage::projection::ProjectionDocument::key(&self) -> &str 1539 pub fn radroots_storage::projection::ProjectionDocument::new(alloc::string::String, alloc::vec::Vec<u8>) -> core::result::Result<Self, radroots_storage::Error> 1540 pub fn radroots_storage::projection::ProjectionDocument::value(&self) -> &[u8] 1541 pub const fn radroots_storage::projection::ProjectionDocument::value_sha256(&self) -> &[u8; 32] 1542 pub struct radroots_storage::projection::ProjectionGeneration(_) 1543 impl radroots_storage::projection::ProjectionGeneration 1544 pub const fn radroots_storage::projection::ProjectionGeneration::as_bytes(&self) -> &[u8; 32] 1545 pub const fn radroots_storage::projection::ProjectionGeneration::new([u8; 32]) -> core::result::Result<Self, radroots_storage::Error> 1546 pub struct radroots_storage::projection::ProjectionId(_) 1547 impl radroots_storage::projection::ProjectionId 1548 pub fn radroots_storage::projection::ProjectionId::as_str(&self) -> &str 1549 pub fn radroots_storage::projection::ProjectionId::parse(impl core::convert::Into<alloc::string::String>) -> core::result::Result<Self, radroots_storage::Error> 1550 pub struct radroots_storage::projection::ProjectionInvalidation 1551 impl radroots_storage::projection::ProjectionInvalidation 1552 pub const fn radroots_storage::projection::ProjectionInvalidation::invalid_generation(&self) -> radroots_storage::projection::ProjectionGeneration 1553 pub const fn radroots_storage::projection::ProjectionInvalidation::invalidated_at_unix_ms(&self) -> u64 1554 pub fn radroots_storage::projection::ProjectionInvalidation::new(radroots_storage::projection::ProjectionId, radroots_storage::projection::ProjectionGeneration, radroots_storage::projection::ProjectionGeneration, radroots_storage::projection::InvalidationReason, u64) -> core::result::Result<Self, radroots_storage::Error> 1555 pub const fn radroots_storage::projection::ProjectionInvalidation::projection_id(&self) -> &radroots_storage::projection::ProjectionId 1556 pub const fn radroots_storage::projection::ProjectionInvalidation::reason(&self) -> radroots_storage::projection::InvalidationReason 1557 pub const fn radroots_storage::projection::ProjectionInvalidation::replacement_generation(&self) -> radroots_storage::projection::ProjectionGeneration 1558 pub struct radroots_storage::projection::ProjectionRevision(_) 1559 impl radroots_storage::projection::ProjectionRevision 1560 pub const radroots_storage::projection::ProjectionRevision::INITIAL: Self 1561 pub const fn radroots_storage::projection::ProjectionRevision::get(self) -> u64 1562 pub const fn radroots_storage::projection::ProjectionRevision::new(u64) -> core::result::Result<Self, radroots_storage::Error> 1563 pub struct radroots_storage::projection::ProjectionSnapshot 1564 impl radroots_storage::projection::ProjectionSnapshot 1565 pub const fn radroots_storage::projection::ProjectionSnapshot::created_at_unix_ms(&self) -> u64 1566 pub fn radroots_storage::projection::ProjectionSnapshot::from_stored_parts(radroots_storage::projection::ProjectionId, [u8; 32], radroots_storage::projection::ProjectionGeneration, u64, alloc::vec::Vec<u8>, [u8; 32]) -> core::result::Result<Self, radroots_storage::Error> 1567 pub const fn radroots_storage::projection::ProjectionSnapshot::generation(&self) -> radroots_storage::projection::ProjectionGeneration 1568 pub fn radroots_storage::projection::ProjectionSnapshot::new(radroots_storage::projection::ProjectionId, [u8; 32], radroots_storage::projection::ProjectionGeneration, u64, alloc::vec::Vec<u8>) -> core::result::Result<Self, radroots_storage::Error> 1569 pub const fn radroots_storage::projection::ProjectionSnapshot::projection_id(&self) -> &radroots_storage::projection::ProjectionId 1570 pub const fn radroots_storage::projection::ProjectionSnapshot::snapshot_id(&self) -> &[u8; 32] 1571 pub fn radroots_storage::projection::ProjectionSnapshot::value(&self) -> &[u8] 1572 pub const fn radroots_storage::projection::ProjectionSnapshot::value_sha256(&self) -> &[u8; 32] 1573 pub struct radroots_storage::projection::ProjectionStatus 1574 impl radroots_storage::projection::ProjectionStatus 1575 pub const fn radroots_storage::projection::ProjectionStatus::active_rebuild(&self) -> core::option::Option<radroots_storage::projection::RebuildTicketId> 1576 pub const fn radroots_storage::projection::ProjectionStatus::checkpoint(&self) -> core::option::Option<&radroots_storage::projection::ProjectionCheckpoint> 1577 pub const fn radroots_storage::projection::ProjectionStatus::generation(&self) -> radroots_storage::projection::ProjectionGeneration 1578 pub const fn radroots_storage::projection::ProjectionStatus::health(&self) -> radroots_storage::projection::ProjectionHealth 1579 pub fn radroots_storage::projection::ProjectionStatus::new(radroots_storage::projection::ProjectionId, radroots_storage::projection::ProjectionGeneration, radroots_storage::projection::ProjectionHealth, core::option::Option<radroots_storage::projection::ProjectionCheckpoint>, core::option::Option<radroots_storage::projection::RebuildTicketId>) -> core::result::Result<Self, radroots_storage::Error> 1580 pub const fn radroots_storage::projection::ProjectionStatus::projection_id(&self) -> &radroots_storage::projection::ProjectionId 1581 pub struct radroots_storage::projection::RawSourceDigest(_) 1582 impl radroots_storage::projection::RawSourceDigest 1583 pub const fn radroots_storage::projection::RawSourceDigest::as_bytes(&self) -> &[u8; 32] 1584 pub const fn radroots_storage::projection::RawSourceDigest::new([u8; 32]) -> Self 1585 pub struct radroots_storage::projection::RebuildTicket 1586 impl radroots_storage::projection::RebuildTicket 1587 pub const fn radroots_storage::projection::RebuildTicket::checkpoint(&self) -> core::option::Option<&radroots_storage::projection::ProjectionCheckpoint> 1588 pub const fn radroots_storage::projection::RebuildTicket::failure(&self) -> core::option::Option<radroots_storage::projection::RebuildFailure> 1589 pub fn radroots_storage::projection::RebuildTicket::from_durable_parts(radroots_storage::projection::RebuildTicketId, radroots_storage::projection::ProjectionInvalidation, radroots_storage::projection::ProjectionRevision, radroots_storage::projection::RebuildStage, radroots_storage::event::SourceGeneration, core::option::Option<radroots_storage::event::EventPosition>, radroots_storage::projection::RawSourceDigest, core::option::Option<radroots_storage::projection::ProjectionCheckpoint>, core::option::Option<radroots_storage::projection::RebuildFailure>, u64, u64) -> core::result::Result<Self, radroots_storage::Error> 1590 pub const fn radroots_storage::projection::RebuildTicket::invalidation(&self) -> &radroots_storage::projection::ProjectionInvalidation 1591 pub fn radroots_storage::projection::RebuildTicket::requested(radroots_storage::projection::RebuildTicketId, radroots_storage::projection::ProjectionInvalidation, radroots_storage::event::SourceGeneration, core::option::Option<radroots_storage::event::EventPosition>, radroots_storage::projection::RawSourceDigest) -> core::result::Result<Self, radroots_storage::Error> 1592 pub const fn radroots_storage::projection::RebuildTicket::requested_at_unix_ms(&self) -> u64 1593 pub const fn radroots_storage::projection::RebuildTicket::revision(&self) -> radroots_storage::projection::ProjectionRevision 1594 pub const fn radroots_storage::projection::RebuildTicket::source_digest(&self) -> radroots_storage::projection::RawSourceDigest 1595 pub const fn radroots_storage::projection::RebuildTicket::source_generation(&self) -> radroots_storage::event::SourceGeneration 1596 pub const fn radroots_storage::projection::RebuildTicket::source_high_water(&self) -> core::option::Option<radroots_storage::event::EventPosition> 1597 pub const fn radroots_storage::projection::RebuildTicket::stage(&self) -> radroots_storage::projection::RebuildStage 1598 pub const fn radroots_storage::projection::RebuildTicket::ticket_id(&self) -> radroots_storage::projection::RebuildTicketId 1599 pub fn radroots_storage::projection::RebuildTicket::transition(&self, radroots_storage::projection::RebuildTransition) -> core::result::Result<Self, radroots_storage::Error> 1600 pub const fn radroots_storage::projection::RebuildTicket::updated_at_unix_ms(&self) -> u64 1601 pub struct radroots_storage::projection::RebuildTicketId(_) 1602 impl radroots_storage::projection::RebuildTicketId 1603 pub const fn radroots_storage::projection::RebuildTicketId::as_bytes(&self) -> &[u8; 16] 1604 pub const fn radroots_storage::projection::RebuildTicketId::new([u8; 16]) -> core::result::Result<Self, radroots_storage::Error> 1605 pub struct radroots_storage::projection::RebuildTransition 1606 impl radroots_storage::projection::RebuildTransition 1607 pub const fn radroots_storage::projection::RebuildTransition::checkpoint(radroots_storage::projection::RebuildTicketId, radroots_storage::projection::ProjectionRevision, u64, radroots_storage::projection::ProjectionCheckpoint) -> Self 1608 pub const fn radroots_storage::projection::RebuildTransition::complete(radroots_storage::projection::RebuildTicketId, radroots_storage::projection::ProjectionRevision, u64, radroots_storage::projection::ProjectionCheckpoint) -> Self 1609 pub const fn radroots_storage::projection::RebuildTransition::fail(radroots_storage::projection::RebuildTicketId, radroots_storage::projection::ProjectionRevision, u64, radroots_storage::projection::RebuildFailure) -> Self 1610 pub const fn radroots_storage::projection::RebuildTransition::start(radroots_storage::projection::RebuildTicketId, radroots_storage::projection::ProjectionRevision, u64) -> Self 1611 pub const fn radroots_storage::projection::RebuildTransition::ticket_id(&self) -> radroots_storage::projection::RebuildTicketId 1612 pub const radroots_storage::projection::EVENT_INDEX_ARTIFACT_PATH_MAX_BYTES: usize 1613 pub const radroots_storage::projection::EVENT_INDEX_CURSOR_MAX_BYTES: usize 1614 pub const radroots_storage::projection::EVENT_INDEX_SHARDS_MAX: usize 1615 pub const radroots_storage::projection::EVENT_INDEX_SHARD_ID_MAX_BYTES: usize 1616 pub const radroots_storage::projection::PROJECTION_DOCUMENT_KEY_MAX_BYTES: usize 1617 pub const radroots_storage::projection::PROJECTION_DOCUMENT_VALUE_MAX_BYTES: usize 1618 pub const radroots_storage::projection::PROJECTION_ID_MAX_BYTES: usize 1619 pub trait radroots_storage::projection::ProjectionStore: core::marker::Send + core::marker::Sync 1620 pub fn radroots_storage::projection::ProjectionStore::checkpoint(&self, radroots_storage::projection::ProjectionCheckpoint) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::ProjectionStatus, radroots_storage::Error>> 1621 pub fn radroots_storage::projection::ProjectionStore::event_index_checkpoint(&self, radroots_storage::projection::ProjectionGeneration) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::EventIndexCheckpoint>, radroots_storage::Error>> 1622 pub fn radroots_storage::projection::ProjectionStore::event_index_manifest(&self, radroots_storage::projection::ProjectionGeneration) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::EventIndexManifest>, radroots_storage::Error>> 1623 pub fn radroots_storage::projection::ProjectionStore::invalidate(&self, radroots_storage::projection::ProjectionInvalidation) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::ProjectionStatus, radroots_storage::Error>> 1624 pub fn radroots_storage::projection::ProjectionStore::invalidation(&self, radroots_storage::projection::ProjectionId, radroots_storage::projection::ProjectionGeneration) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::ProjectionInvalidation>, radroots_storage::Error>> 1625 pub fn radroots_storage::projection::ProjectionStore::projection_document(&self, radroots_storage::projection::ProjectionId, radroots_storage::projection::ProjectionGeneration, alloc::string::String) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::ProjectionDocument>, radroots_storage::Error>> 1626 pub fn radroots_storage::projection::ProjectionStore::projection_snapshot(&self, radroots_storage::projection::ProjectionId, [u8; 32]) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::ProjectionSnapshot>, radroots_storage::Error>> 1627 pub fn radroots_storage::projection::ProjectionStore::put_event_index_checkpoint(&self, radroots_storage::projection::EventIndexCheckpoint) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::Error>> 1628 pub fn radroots_storage::projection::ProjectionStore::put_event_index_manifest(&self, radroots_storage::projection::EventIndexManifest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::Error>> 1629 pub fn radroots_storage::projection::ProjectionStore::put_projection_document(&self, radroots_storage::projection::ProjectionId, radroots_storage::projection::ProjectionGeneration, radroots_storage::projection::ProjectionDocument) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::Error>> 1630 pub fn radroots_storage::projection::ProjectionStore::put_projection_snapshot(&self, radroots_storage::projection::ProjectionSnapshot) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::Error>> 1631 pub fn radroots_storage::projection::ProjectionStore::query_projection_documents(&self, radroots_storage::projection::document_query::ProjectionDocumentQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::document_query::ProjectionDocumentPage, radroots_storage::Error>> 1632 pub fn radroots_storage::projection::ProjectionStore::rebuild(&self, radroots_storage::projection::RebuildTicketId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::RebuildTicket>, radroots_storage::Error>> 1633 pub fn radroots_storage::projection::ProjectionStore::request_rebuild(&self, radroots_storage::projection::RebuildTicket) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::RebuildTicket, radroots_storage::Error>> 1634 pub fn radroots_storage::projection::ProjectionStore::status(&self, radroots_storage::projection::ProjectionId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::ProjectionStatus>, radroots_storage::Error>> 1635 pub fn radroots_storage::projection::ProjectionStore::transition_rebuild(&self, radroots_storage::projection::RebuildTransition) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::RebuildTicket, radroots_storage::Error>> 1636 impl radroots_storage::projection::ProjectionStore for radroots_storage::memory::MemoryStorage 1637 pub fn radroots_storage::memory::MemoryStorage::checkpoint(&self, radroots_storage::projection::ProjectionCheckpoint) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::ProjectionStatus, radroots_storage::Error>> 1638 pub fn radroots_storage::memory::MemoryStorage::event_index_checkpoint(&self, radroots_storage::projection::ProjectionGeneration) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::EventIndexCheckpoint>, radroots_storage::Error>> 1639 pub fn radroots_storage::memory::MemoryStorage::event_index_manifest(&self, radroots_storage::projection::ProjectionGeneration) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::EventIndexManifest>, radroots_storage::Error>> 1640 pub fn radroots_storage::memory::MemoryStorage::invalidate(&self, radroots_storage::projection::ProjectionInvalidation) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::ProjectionStatus, radroots_storage::Error>> 1641 pub fn radroots_storage::memory::MemoryStorage::invalidation(&self, radroots_storage::projection::ProjectionId, radroots_storage::projection::ProjectionGeneration) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::ProjectionInvalidation>, radroots_storage::Error>> 1642 pub fn radroots_storage::memory::MemoryStorage::projection_document(&self, radroots_storage::projection::ProjectionId, radroots_storage::projection::ProjectionGeneration, alloc::string::String) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::ProjectionDocument>, radroots_storage::Error>> 1643 pub fn radroots_storage::memory::MemoryStorage::projection_snapshot(&self, radroots_storage::projection::ProjectionId, [u8; 32]) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::ProjectionSnapshot>, radroots_storage::Error>> 1644 pub fn radroots_storage::memory::MemoryStorage::put_event_index_checkpoint(&self, radroots_storage::projection::EventIndexCheckpoint) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::Error>> 1645 pub fn radroots_storage::memory::MemoryStorage::put_event_index_manifest(&self, radroots_storage::projection::EventIndexManifest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::Error>> 1646 pub fn radroots_storage::memory::MemoryStorage::put_projection_document(&self, radroots_storage::projection::ProjectionId, radroots_storage::projection::ProjectionGeneration, radroots_storage::projection::ProjectionDocument) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::Error>> 1647 pub fn radroots_storage::memory::MemoryStorage::put_projection_snapshot(&self, radroots_storage::projection::ProjectionSnapshot) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::Error>> 1648 pub fn radroots_storage::memory::MemoryStorage::query_projection_documents(&self, radroots_storage::projection::document_query::ProjectionDocumentQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::document_query::ProjectionDocumentPage, radroots_storage::Error>> 1649 pub fn radroots_storage::memory::MemoryStorage::rebuild(&self, radroots_storage::projection::RebuildTicketId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::RebuildTicket>, radroots_storage::Error>> 1650 pub fn radroots_storage::memory::MemoryStorage::request_rebuild(&self, radroots_storage::projection::RebuildTicket) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::RebuildTicket, radroots_storage::Error>> 1651 pub fn radroots_storage::memory::MemoryStorage::status(&self, radroots_storage::projection::ProjectionId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::ProjectionStatus>, radroots_storage::Error>> 1652 pub fn radroots_storage::memory::MemoryStorage::transition_rebuild(&self, radroots_storage::projection::RebuildTransition) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::RebuildTicket, radroots_storage::Error>> 1653 pub mod radroots_storage::status 1654 pub enum radroots_storage::status::EventStoreHealth 1655 pub radroots_storage::status::EventStoreHealth::Available 1656 pub radroots_storage::status::EventStoreHealth::Degraded 1657 pub radroots_storage::status::EventStoreHealth::Unavailable 1658 pub enum radroots_storage::status::EventStoreMode 1659 pub radroots_storage::status::EventStoreMode::ReadOnly 1660 pub radroots_storage::status::EventStoreMode::ReadWrite 1661 pub enum radroots_storage::status::IntegrityHealth 1662 pub radroots_storage::status::IntegrityHealth::Corrupt 1663 pub radroots_storage::status::IntegrityHealth::Degraded 1664 pub radroots_storage::status::IntegrityHealth::Healthy 1665 pub radroots_storage::status::IntegrityHealth::Unknown 1666 impl radroots_storage::status::IntegrityHealth 1667 pub const fn radroots_storage::status::IntegrityHealth::as_str(self) -> &'static str 1668 pub enum radroots_storage::status::ShutdownState 1669 pub radroots_storage::status::ShutdownState::Closed 1670 pub radroots_storage::status::ShutdownState::Closing 1671 pub radroots_storage::status::ShutdownState::Open 1672 impl radroots_storage::status::ShutdownState 1673 pub const fn radroots_storage::status::ShutdownState::as_str(self) -> &'static str 1674 pub enum radroots_storage::status::StorageBackend 1675 pub radroots_storage::status::StorageBackend::Memory 1676 pub radroots_storage::status::StorageBackend::Sqlite 1677 impl radroots_storage::status::StorageBackend 1678 pub const fn radroots_storage::status::StorageBackend::as_str(self) -> &'static str 1679 pub enum radroots_storage::status::StorageOpenMode 1680 pub radroots_storage::status::StorageOpenMode::Create 1681 pub radroots_storage::status::StorageOpenMode::ReadOnly 1682 pub radroots_storage::status::StorageOpenMode::ReadWriteExisting 1683 impl radroots_storage::status::StorageOpenMode 1684 pub const fn radroots_storage::status::StorageOpenMode::as_str(self) -> &'static str 1685 pub enum radroots_storage::status::WriterPolicy 1686 pub radroots_storage::status::WriterPolicy::AdvisoryProcessLock 1687 pub radroots_storage::status::WriterPolicy::NoWriter 1688 pub struct radroots_storage::status::EventStoreStatus 1689 impl radroots_storage::status::EventStoreStatus 1690 pub const fn radroots_storage::status::EventStoreStatus::generation(&self) -> radroots_storage::event::SourceGeneration 1691 pub const fn radroots_storage::status::EventStoreStatus::health(&self) -> radroots_storage::status::EventStoreHealth 1692 pub const fn radroots_storage::status::EventStoreStatus::mode(&self) -> radroots_storage::status::EventStoreMode 1693 pub const fn radroots_storage::status::EventStoreStatus::new(radroots_storage::event::SourceGeneration, radroots_storage::status::EventStoreMode, radroots_storage::status::EventStoreHealth, u64, u64, u64) -> core::result::Result<Self, radroots_storage::Error> 1694 pub const fn radroots_storage::status::EventStoreStatus::raw_events(&self) -> u64 1695 pub const fn radroots_storage::status::EventStoreStatus::verified_events(&self) -> u64 1696 pub const fn radroots_storage::status::EventStoreStatus::visible_events(&self) -> u64 1697 pub struct radroots_storage::status::IntegrityStatus 1698 impl radroots_storage::status::IntegrityStatus 1699 pub const fn radroots_storage::status::IntegrityStatus::checked_at_unix_ms(self) -> core::option::Option<u64> 1700 pub const fn radroots_storage::status::IntegrityStatus::failed_members(self) -> u32 1701 pub const fn radroots_storage::status::IntegrityStatus::health(self) -> radroots_storage::status::IntegrityHealth 1702 pub fn radroots_storage::status::IntegrityStatus::new(radroots_storage::status::IntegrityHealth, core::option::Option<u64>, u32, u32) -> core::result::Result<Self, radroots_storage::Error> 1703 pub const fn radroots_storage::status::IntegrityStatus::verified_members(self) -> u32 1704 pub struct radroots_storage::status::StorageStatus 1705 impl radroots_storage::status::StorageStatus 1706 pub const fn radroots_storage::status::StorageStatus::backend(self) -> radroots_storage::status::StorageBackend 1707 pub const fn radroots_storage::status::StorageStatus::busy_timeout_ms(self) -> u32 1708 pub const fn radroots_storage::status::StorageStatus::integrity(self) -> radroots_storage::status::IntegrityStatus 1709 pub fn radroots_storage::status::StorageStatus::new(radroots_storage::status::StorageBackend, radroots_storage::status::StorageOpenMode, radroots_storage::status::WriterPolicy, radroots_storage::status::ShutdownState, radroots_storage::status::IntegrityStatus, bool, u32) -> core::result::Result<Self, radroots_storage::Error> 1710 pub const fn radroots_storage::status::StorageStatus::open_mode(self) -> radroots_storage::status::StorageOpenMode 1711 pub const fn radroots_storage::status::StorageStatus::shutdown(self) -> radroots_storage::status::ShutdownState 1712 pub const fn radroots_storage::status::StorageStatus::wal_enabled(self) -> bool 1713 pub const fn radroots_storage::status::StorageStatus::writer_policy(self) -> radroots_storage::status::WriterPolicy 1714 pub trait radroots_storage::status::StorageStatusProvider: core::marker::Send + core::marker::Sync 1715 pub fn radroots_storage::status::StorageStatusProvider::storage_status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::StorageStatus, radroots_storage::Error>> 1716 impl radroots_storage::status::StorageStatusProvider for radroots_storage::memory::MemoryStorage 1717 pub fn radroots_storage::memory::MemoryStorage::storage_status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::StorageStatus, radroots_storage::Error>> 1718 #[non_exhaustive] pub enum radroots_storage::Error 1719 pub radroots_storage::Error::AdmissionEventMismatch 1720 pub radroots_storage::Error::AdmissionRegression 1721 pub radroots_storage::Error::AtomicCommitConflict 1722 pub radroots_storage::Error::AtomicCommitFailed 1723 pub radroots_storage::Error::AtomicWorkflowMismatch 1724 pub radroots_storage::Error::BackendUnavailable 1725 pub radroots_storage::Error::BackupManifestPlanMismatch 1726 pub radroots_storage::Error::BackupSecretPolicyViolation 1727 pub radroots_storage::Error::CorruptAuthoredDraft 1728 pub radroots_storage::Error::CorruptJournalRecord 1729 pub radroots_storage::Error::CorruptOutboxRecord 1730 pub radroots_storage::Error::CorruptPrivateArtifactMetadata 1731 pub radroots_storage::Error::CorruptProjectionDocument 1732 pub radroots_storage::Error::CorruptProjectionRecord 1733 pub radroots_storage::Error::CorruptReliabilityOperation 1734 pub radroots_storage::Error::CorruptStoredEvent 1735 pub radroots_storage::Error::CursorGenerationMismatch 1736 pub radroots_storage::Error::DeliveryAttemptOverflow 1737 pub radroots_storage::Error::DeliveryPlanClaimConflict 1738 pub radroots_storage::Error::DraftNotFound 1739 pub radroots_storage::Error::DraftRevisionConflict 1740 pub radroots_storage::Error::DuplicateBackupMember 1741 pub radroots_storage::Error::DuplicateEventIndexShard 1742 pub radroots_storage::Error::DuplicateEventQueryId 1743 pub radroots_storage::Error::EmptyEventQueryIds 1744 pub radroots_storage::Error::EventConflict 1745 pub radroots_storage::Error::EventNotFound 1746 pub radroots_storage::Error::EventPageLimitExceeded 1747 pub radroots_storage::Error::IdempotencyConflict 1748 pub radroots_storage::Error::InvalidAtomicCommitId 1749 pub radroots_storage::Error::InvalidAtomicCommitTimestamp 1750 pub radroots_storage::Error::InvalidAuthoredArtifact 1751 pub radroots_storage::Error::InvalidAuthoredDeliveryPlan 1752 pub radroots_storage::Error::InvalidAuthoredDraft 1753 pub radroots_storage::Error::InvalidAuthoredOperation 1754 pub radroots_storage::Error::InvalidAuthoredTransition 1755 pub radroots_storage::Error::InvalidBackupId 1756 pub radroots_storage::Error::InvalidBackupManifest 1757 pub radroots_storage::Error::InvalidBackupMemberLength 1758 pub radroots_storage::Error::InvalidBackupMemberPath 1759 pub radroots_storage::Error::InvalidBackupTimestamp 1760 pub radroots_storage::Error::InvalidBackupTransition 1761 pub radroots_storage::Error::InvalidBackupVersion 1762 pub radroots_storage::Error::InvalidDeliveryAttempt 1763 pub radroots_storage::Error::InvalidDeliveryEvidence 1764 pub radroots_storage::Error::InvalidEventIndexArtifactPath 1765 pub radroots_storage::Error::InvalidEventIndexCheckpoint 1766 pub radroots_storage::Error::InvalidEventIndexCursor 1767 pub radroots_storage::Error::InvalidEventIndexManifest 1768 pub radroots_storage::Error::InvalidEventIndexRange 1769 pub radroots_storage::Error::InvalidEventIndexShardCount 1770 pub radroots_storage::Error::InvalidEventIndexShardId 1771 pub radroots_storage::Error::InvalidEventIndexTimestamp 1772 pub radroots_storage::Error::InvalidEventQueryLimit 1773 pub radroots_storage::Error::InvalidEventSequence 1774 pub radroots_storage::Error::InvalidExpiredArtifactQueryLimit 1775 pub radroots_storage::Error::InvalidIdempotencyKey 1776 pub radroots_storage::Error::InvalidIntegrityStatus 1777 pub radroots_storage::Error::InvalidJournalQueryLimit 1778 pub radroots_storage::Error::InvalidJournalRevision 1779 pub radroots_storage::Error::InvalidJournalTransition 1780 pub radroots_storage::Error::InvalidOperationInstanceId 1781 pub radroots_storage::Error::InvalidOperationTimestamp 1782 pub radroots_storage::Error::InvalidOutboxClaimLimit 1783 pub radroots_storage::Error::InvalidOutboxItemId 1784 pub radroots_storage::Error::InvalidOutboxLease 1785 pub radroots_storage::Error::InvalidOutboxLeaseOwner 1786 pub radroots_storage::Error::InvalidOutboxRevision 1787 pub radroots_storage::Error::InvalidOutboxTimestamp 1788 pub radroots_storage::Error::InvalidPrivateArtifactId 1789 pub radroots_storage::Error::InvalidPrivateArtifactKind 1790 pub radroots_storage::Error::InvalidPrivateArtifactMetadata 1791 pub radroots_storage::Error::InvalidPrivateArtifactResealId 1792 pub radroots_storage::Error::InvalidPrivateArtifactResealRequest 1793 pub radroots_storage::Error::InvalidPrivateArtifactRetention 1794 pub radroots_storage::Error::InvalidPrivateArtifactRevision 1795 pub radroots_storage::Error::InvalidPrivateArtifactSchema 1796 pub radroots_storage::Error::InvalidPrivateArtifactSecretReference 1797 pub radroots_storage::Error::InvalidPrivateArtifactTimestamp 1798 pub radroots_storage::Error::InvalidProjectionDocument 1799 pub radroots_storage::Error::InvalidProjectionGeneration 1800 pub radroots_storage::Error::InvalidProjectionId 1801 pub radroots_storage::Error::InvalidProjectionInvalidation 1802 pub radroots_storage::Error::InvalidProjectionRevision 1803 pub radroots_storage::Error::InvalidProjectionSnapshot 1804 pub radroots_storage::Error::InvalidProjectionTimestamp 1805 pub radroots_storage::Error::InvalidRebuildTicketId 1806 pub radroots_storage::Error::InvalidRebuildTransition 1807 pub radroots_storage::Error::InvalidRecoveryAttempt 1808 pub radroots_storage::Error::InvalidRecoveryDeadline 1809 pub radroots_storage::Error::InvalidReliabilityRevision 1810 pub radroots_storage::Error::InvalidRestoreTimestamp 1811 pub radroots_storage::Error::InvalidRestoreTransition 1812 pub radroots_storage::Error::InvalidRetrySchedule 1813 pub radroots_storage::Error::InvalidSourceGeneration 1814 pub radroots_storage::Error::InvalidStorageStatus 1815 pub radroots_storage::Error::InvalidWorkClaim 1816 pub radroots_storage::Error::InvalidWorkFailure 1817 pub radroots_storage::Error::JournalOperationCommitted 1818 pub radroots_storage::Error::JournalRevisionConflict 1819 pub radroots_storage::Error::OperationIdentityMismatch 1820 pub radroots_storage::Error::OperationNotFound 1821 pub radroots_storage::Error::OutboxItemNotFound 1822 pub radroots_storage::Error::OutboxItemNotReady 1823 pub radroots_storage::Error::OutboxItemTerminal 1824 pub radroots_storage::Error::OutboxLeaseConflict 1825 pub radroots_storage::Error::OutboxLeaseExpired 1826 pub radroots_storage::Error::OutboxPlanConflict 1827 pub radroots_storage::Error::OutboxRevisionConflict 1828 pub radroots_storage::Error::PrivateArtifactConflict 1829 pub radroots_storage::Error::PrivateArtifactNotExpired 1830 pub radroots_storage::Error::PrivateArtifactNotFound 1831 pub radroots_storage::Error::PrivateArtifactPersistenceIndeterminate 1832 pub radroots_storage::Error::PrivateArtifactResealConflict 1833 pub radroots_storage::Error::PrivateArtifactRetentionActive 1834 pub radroots_storage::Error::PrivateArtifactRevisionConflict 1835 pub radroots_storage::Error::PrivateArtifactTombstoned 1836 pub radroots_storage::Error::ProjectionCheckpointMismatch 1837 pub radroots_storage::Error::ProjectionCheckpointRegression 1838 pub radroots_storage::Error::ProjectionRevisionConflict 1839 pub radroots_storage::Error::RebuildTicketTerminal 1840 pub radroots_storage::Error::ReliabilityOperationTerminal 1841 pub radroots_storage::Error::ReliabilityRevisionConflict 1842 pub radroots_storage::Error::RestoreMemberVerificationFailed 1843 pub radroots_storage::Error::SourceGenerationChanged 1844 pub radroots_storage::Error::SpaceInsufficient 1845 pub radroots_storage::Error::TooManyEventQueryIds 1846 impl core::error::Error for radroots_storage::Error 1847 impl core::fmt::Display for radroots_storage::Error 1848 pub fn radroots_storage::Error::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 1849 pub struct radroots_storage::StorageStatus 1850 impl radroots_storage::status::StorageStatus 1851 pub const fn radroots_storage::status::StorageStatus::backend(self) -> radroots_storage::status::StorageBackend 1852 pub const fn radroots_storage::status::StorageStatus::busy_timeout_ms(self) -> u32 1853 pub const fn radroots_storage::status::StorageStatus::integrity(self) -> radroots_storage::status::IntegrityStatus 1854 pub fn radroots_storage::status::StorageStatus::new(radroots_storage::status::StorageBackend, radroots_storage::status::StorageOpenMode, radroots_storage::status::WriterPolicy, radroots_storage::status::ShutdownState, radroots_storage::status::IntegrityStatus, bool, u32) -> core::result::Result<Self, radroots_storage::Error> 1855 pub const fn radroots_storage::status::StorageStatus::open_mode(self) -> radroots_storage::status::StorageOpenMode 1856 pub const fn radroots_storage::status::StorageStatus::shutdown(self) -> radroots_storage::status::ShutdownState 1857 pub const fn radroots_storage::status::StorageStatus::wal_enabled(self) -> bool 1858 pub const fn radroots_storage::status::StorageStatus::writer_policy(self) -> radroots_storage::status::WriterPolicy 1859 pub trait radroots_storage::BackupSource: core::marker::Send + core::marker::Sync 1860 pub fn radroots_storage::BackupSource::begin_backup(&self, radroots_storage::backup::BackupPlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::BackupOperation, radroots_storage::Error>> 1861 pub fn radroots_storage::BackupSource::begin_restore(&self, radroots_storage::backup::RestorePlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::RestoreOperation, radroots_storage::Error>> 1862 pub fn radroots_storage::BackupSource::capture_backup(&self, radroots_storage::backup::BackupPlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::BackupManifest, radroots_storage::backup::BackupCapabilityError>> 1863 pub fn radroots_storage::BackupSource::close(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::StorageStatus, radroots_storage::Error>> 1864 pub fn radroots_storage::BackupSource::finalize_backup(&self, radroots_storage::backup::BackupPlan, radroots_storage::backup::BackupManifest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::backup::BackupCapabilityError>> 1865 pub fn radroots_storage::BackupSource::finalize_restore(&self, radroots_storage::backup::RestorePlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::backup::RestoreCapabilityError>> 1866 pub fn radroots_storage::BackupSource::integrity(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::IntegrityStatus, radroots_storage::Error>> 1867 pub fn radroots_storage::BackupSource::settle_backup_writes(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::backup::BackupCapabilityError>> 1868 pub fn radroots_storage::BackupSource::stage_restore(&self, radroots_storage::backup::RestorePlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<alloc::vec::Vec<radroots_storage::backup::RestoreMemberStatus>, radroots_storage::backup::RestoreCapabilityError>> 1869 pub fn radroots_storage::BackupSource::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::StorageStatus, radroots_storage::Error>> 1870 pub fn radroots_storage::BackupSource::transition_backup(&self, radroots_storage::backup::BackupId, radroots_storage::backup::ReliabilityRevision, radroots_storage::backup::BackupTransition, u64) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::BackupOperation, radroots_storage::Error>> 1871 pub fn radroots_storage::BackupSource::transition_restore(&self, radroots_storage::backup::BackupId, radroots_storage::backup::ReliabilityRevision, radroots_storage::backup::RestoreTransition, u64) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::RestoreOperation, radroots_storage::Error>> 1872 pub fn radroots_storage::BackupSource::verify_backup(&self, radroots_storage::backup::BackupPlan, radroots_storage::backup::BackupManifest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::backup::BackupCapabilityError>> 1873 impl radroots_storage::backup::StorageReliability for radroots_storage::memory::MemoryStorage 1874 pub fn radroots_storage::memory::MemoryStorage::begin_backup(&self, radroots_storage::backup::BackupPlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::BackupOperation, radroots_storage::Error>> 1875 pub fn radroots_storage::memory::MemoryStorage::begin_restore(&self, radroots_storage::backup::RestorePlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::RestoreOperation, radroots_storage::Error>> 1876 pub fn radroots_storage::memory::MemoryStorage::capture_backup(&self, radroots_storage::backup::BackupPlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::BackupManifest, radroots_storage::backup::BackupCapabilityError>> 1877 pub fn radroots_storage::memory::MemoryStorage::close(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::StorageStatus, radroots_storage::Error>> 1878 pub fn radroots_storage::memory::MemoryStorage::finalize_backup(&self, radroots_storage::backup::BackupPlan, radroots_storage::backup::BackupManifest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::backup::BackupCapabilityError>> 1879 pub fn radroots_storage::memory::MemoryStorage::finalize_restore(&self, radroots_storage::backup::RestorePlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::backup::RestoreCapabilityError>> 1880 pub fn radroots_storage::memory::MemoryStorage::integrity(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::IntegrityStatus, radroots_storage::Error>> 1881 pub fn radroots_storage::memory::MemoryStorage::settle_backup_writes(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::backup::BackupCapabilityError>> 1882 pub fn radroots_storage::memory::MemoryStorage::stage_restore(&self, radroots_storage::backup::RestorePlan) -> radroots_transport::source::BoxFuture<'_, core::result::Result<alloc::vec::Vec<radroots_storage::backup::RestoreMemberStatus>, radroots_storage::backup::RestoreCapabilityError>> 1883 pub fn radroots_storage::memory::MemoryStorage::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::StorageStatus, radroots_storage::Error>> 1884 pub fn radroots_storage::memory::MemoryStorage::transition_backup(&self, radroots_storage::backup::BackupId, radroots_storage::backup::ReliabilityRevision, radroots_storage::backup::BackupTransition, u64) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::BackupOperation, radroots_storage::Error>> 1885 pub fn radroots_storage::memory::MemoryStorage::transition_restore(&self, radroots_storage::backup::BackupId, radroots_storage::backup::ReliabilityRevision, radroots_storage::backup::RestoreTransition, u64) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::backup::RestoreOperation, radroots_storage::Error>> 1886 pub fn radroots_storage::memory::MemoryStorage::verify_backup(&self, radroots_storage::backup::BackupPlan, radroots_storage::backup::BackupManifest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::backup::BackupCapabilityError>> 1887 pub trait radroots_storage::EventStore: core::marker::Send + core::marker::Sync 1888 pub fn radroots_storage::EventStore::admit(&self, radroots_storage::event::EventAdmission) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::AdmissionReceipt, radroots_storage::Error>> 1889 pub fn radroots_storage::EventStore::query_provenance(&self, radroots_event::id::EventId, radroots_storage::event::EventQueryBounds) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::EventPage<radroots_storage::event::StoredEventProvenance>, radroots_storage::Error>> 1890 pub fn radroots_storage::EventStore::query_raw(&self, radroots_storage::event::EventQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::EventPage<radroots_storage::event::StoredRawEvent>, radroots_storage::Error>> 1891 pub fn radroots_storage::EventStore::query_verified(&self, radroots_storage::event::EventQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::EventPage<radroots_storage::event::StoredVerifiedEvent>, radroots_storage::Error>> 1892 pub fn radroots_storage::EventStore::query_visible(&self, radroots_storage::event::EventQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::EventPage<radroots_storage::event::StoredVisibleEvent>, radroots_storage::Error>> 1893 pub fn radroots_storage::EventStore::rebuild_visibility(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::VisibilitySnapshot, radroots_storage::Error>> 1894 pub fn radroots_storage::EventStore::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::EventStoreStatus, radroots_storage::Error>> 1895 impl radroots_storage::event::EventStore for radroots_storage::memory::MemoryStorage 1896 pub fn radroots_storage::memory::MemoryStorage::admit(&self, radroots_storage::event::EventAdmission) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::AdmissionReceipt, radroots_storage::Error>> 1897 pub fn radroots_storage::memory::MemoryStorage::query_provenance(&self, radroots_event::id::EventId, radroots_storage::event::EventQueryBounds) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::EventPage<radroots_storage::event::StoredEventProvenance>, radroots_storage::Error>> 1898 pub fn radroots_storage::memory::MemoryStorage::query_raw(&self, radroots_storage::event::EventQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::EventPage<radroots_storage::event::StoredRawEvent>, radroots_storage::Error>> 1899 pub fn radroots_storage::memory::MemoryStorage::query_verified(&self, radroots_storage::event::EventQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::EventPage<radroots_storage::event::StoredVerifiedEvent>, radroots_storage::Error>> 1900 pub fn radroots_storage::memory::MemoryStorage::query_visible(&self, radroots_storage::event::EventQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::EventPage<radroots_storage::event::StoredVisibleEvent>, radroots_storage::Error>> 1901 pub fn radroots_storage::memory::MemoryStorage::rebuild_visibility(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::event::VisibilitySnapshot, radroots_storage::Error>> 1902 pub fn radroots_storage::memory::MemoryStorage::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::status::EventStoreStatus, radroots_storage::Error>> 1903 pub trait radroots_storage::Journal: core::marker::Send + core::marker::Sync 1904 pub fn radroots_storage::Journal::by_idempotency_key(&self, radroots_protocol::runtime::v1::OperationId, radroots_storage::journal::IdempotencyKey) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::journal::OperationRecord>, radroots_storage::Error>> 1905 pub fn radroots_storage::Journal::operation(&self, radroots_storage::journal::OperationInstanceId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::journal::OperationRecord>, radroots_storage::Error>> 1906 pub fn radroots_storage::Journal::prepare(&self, radroots_storage::journal::PrepareOperation) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::journal::PrepareReceipt, radroots_storage::Error>> 1907 pub fn radroots_storage::Journal::recoverable(&self, u16) -> radroots_transport::source::BoxFuture<'_, core::result::Result<alloc::vec::Vec<radroots_storage::journal::OperationRecord>, radroots_storage::Error>> 1908 pub fn radroots_storage::Journal::transition(&self, radroots_storage::journal::JournalTransition) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::journal::OperationRecord, radroots_storage::Error>> 1909 impl radroots_storage::journal::Journal for radroots_storage::memory::MemoryStorage 1910 pub fn radroots_storage::memory::MemoryStorage::by_idempotency_key(&self, radroots_protocol::runtime::v1::OperationId, radroots_storage::journal::IdempotencyKey) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::journal::OperationRecord>, radroots_storage::Error>> 1911 pub fn radroots_storage::memory::MemoryStorage::operation(&self, radroots_storage::journal::OperationInstanceId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::journal::OperationRecord>, radroots_storage::Error>> 1912 pub fn radroots_storage::memory::MemoryStorage::prepare(&self, radroots_storage::journal::PrepareOperation) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::journal::PrepareReceipt, radroots_storage::Error>> 1913 pub fn radroots_storage::memory::MemoryStorage::recoverable(&self, u16) -> radroots_transport::source::BoxFuture<'_, core::result::Result<alloc::vec::Vec<radroots_storage::journal::OperationRecord>, radroots_storage::Error>> 1914 pub fn radroots_storage::memory::MemoryStorage::transition(&self, radroots_storage::journal::JournalTransition) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::journal::OperationRecord, radroots_storage::Error>> 1915 pub trait radroots_storage::Outbox: core::marker::Send + core::marker::Sync 1916 pub fn radroots_storage::Outbox::claim(&self, radroots_storage::outbox::ClaimOutboxItems) -> radroots_transport::source::BoxFuture<'_, core::result::Result<alloc::vec::Vec<radroots_storage::outbox::ClaimedOutboxItem>, radroots_storage::Error>> 1917 pub fn radroots_storage::Outbox::enqueue(&self, radroots_storage::outbox::EnqueueOutboxItem) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::outbox::EnqueueReceipt, radroots_storage::Error>> 1918 pub fn radroots_storage::Outbox::item(&self, radroots_storage::outbox::OutboxItemId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::outbox::OutboxRecord>, radroots_storage::Error>> 1919 pub fn radroots_storage::Outbox::record_attempt(&self, radroots_storage::outbox::DeliveryAttemptEvidence) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::outbox::OutboxRecord, radroots_storage::Error>> 1920 pub fn radroots_storage::Outbox::release(&self, radroots_storage::outbox::OutboxItemId, radroots_storage::outbox::LeaseId, radroots_storage::outbox::OutboxRevision, u64, core::option::Option<u64>) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::outbox::OutboxRecord, radroots_storage::Error>> 1921 pub fn radroots_storage::Outbox::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::outbox::OutboxStatus, radroots_storage::Error>> 1922 impl radroots_storage::outbox::Outbox for radroots_storage::memory::MemoryStorage 1923 pub fn radroots_storage::memory::MemoryStorage::claim(&self, radroots_storage::outbox::ClaimOutboxItems) -> radroots_transport::source::BoxFuture<'_, core::result::Result<alloc::vec::Vec<radroots_storage::outbox::ClaimedOutboxItem>, radroots_storage::Error>> 1924 pub fn radroots_storage::memory::MemoryStorage::enqueue(&self, radroots_storage::outbox::EnqueueOutboxItem) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::outbox::EnqueueReceipt, radroots_storage::Error>> 1925 pub fn radroots_storage::memory::MemoryStorage::item(&self, radroots_storage::outbox::OutboxItemId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::outbox::OutboxRecord>, radroots_storage::Error>> 1926 pub fn radroots_storage::memory::MemoryStorage::record_attempt(&self, radroots_storage::outbox::DeliveryAttemptEvidence) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::outbox::OutboxRecord, radroots_storage::Error>> 1927 pub fn radroots_storage::memory::MemoryStorage::release(&self, radroots_storage::outbox::OutboxItemId, radroots_storage::outbox::LeaseId, radroots_storage::outbox::OutboxRevision, u64, core::option::Option<u64>) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::outbox::OutboxRecord, radroots_storage::Error>> 1928 pub fn radroots_storage::memory::MemoryStorage::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::outbox::OutboxStatus, radroots_storage::Error>> 1929 pub trait radroots_storage::ProjectionStore: core::marker::Send + core::marker::Sync 1930 pub fn radroots_storage::ProjectionStore::checkpoint(&self, radroots_storage::projection::ProjectionCheckpoint) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::ProjectionStatus, radroots_storage::Error>> 1931 pub fn radroots_storage::ProjectionStore::event_index_checkpoint(&self, radroots_storage::projection::ProjectionGeneration) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::EventIndexCheckpoint>, radroots_storage::Error>> 1932 pub fn radroots_storage::ProjectionStore::event_index_manifest(&self, radroots_storage::projection::ProjectionGeneration) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::EventIndexManifest>, radroots_storage::Error>> 1933 pub fn radroots_storage::ProjectionStore::invalidate(&self, radroots_storage::projection::ProjectionInvalidation) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::ProjectionStatus, radroots_storage::Error>> 1934 pub fn radroots_storage::ProjectionStore::invalidation(&self, radroots_storage::projection::ProjectionId, radroots_storage::projection::ProjectionGeneration) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::ProjectionInvalidation>, radroots_storage::Error>> 1935 pub fn radroots_storage::ProjectionStore::projection_document(&self, radroots_storage::projection::ProjectionId, radroots_storage::projection::ProjectionGeneration, alloc::string::String) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::ProjectionDocument>, radroots_storage::Error>> 1936 pub fn radroots_storage::ProjectionStore::projection_snapshot(&self, radroots_storage::projection::ProjectionId, [u8; 32]) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::ProjectionSnapshot>, radroots_storage::Error>> 1937 pub fn radroots_storage::ProjectionStore::put_event_index_checkpoint(&self, radroots_storage::projection::EventIndexCheckpoint) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::Error>> 1938 pub fn radroots_storage::ProjectionStore::put_event_index_manifest(&self, radroots_storage::projection::EventIndexManifest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::Error>> 1939 pub fn radroots_storage::ProjectionStore::put_projection_document(&self, radroots_storage::projection::ProjectionId, radroots_storage::projection::ProjectionGeneration, radroots_storage::projection::ProjectionDocument) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::Error>> 1940 pub fn radroots_storage::ProjectionStore::put_projection_snapshot(&self, radroots_storage::projection::ProjectionSnapshot) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::Error>> 1941 pub fn radroots_storage::ProjectionStore::query_projection_documents(&self, radroots_storage::projection::document_query::ProjectionDocumentQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::document_query::ProjectionDocumentPage, radroots_storage::Error>> 1942 pub fn radroots_storage::ProjectionStore::rebuild(&self, radroots_storage::projection::RebuildTicketId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::RebuildTicket>, radroots_storage::Error>> 1943 pub fn radroots_storage::ProjectionStore::request_rebuild(&self, radroots_storage::projection::RebuildTicket) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::RebuildTicket, radroots_storage::Error>> 1944 pub fn radroots_storage::ProjectionStore::status(&self, radroots_storage::projection::ProjectionId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::ProjectionStatus>, radroots_storage::Error>> 1945 pub fn radroots_storage::ProjectionStore::transition_rebuild(&self, radroots_storage::projection::RebuildTransition) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::RebuildTicket, radroots_storage::Error>> 1946 impl radroots_storage::projection::ProjectionStore for radroots_storage::memory::MemoryStorage 1947 pub fn radroots_storage::memory::MemoryStorage::checkpoint(&self, radroots_storage::projection::ProjectionCheckpoint) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::ProjectionStatus, radroots_storage::Error>> 1948 pub fn radroots_storage::memory::MemoryStorage::event_index_checkpoint(&self, radroots_storage::projection::ProjectionGeneration) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::EventIndexCheckpoint>, radroots_storage::Error>> 1949 pub fn radroots_storage::memory::MemoryStorage::event_index_manifest(&self, radroots_storage::projection::ProjectionGeneration) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::EventIndexManifest>, radroots_storage::Error>> 1950 pub fn radroots_storage::memory::MemoryStorage::invalidate(&self, radroots_storage::projection::ProjectionInvalidation) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::ProjectionStatus, radroots_storage::Error>> 1951 pub fn radroots_storage::memory::MemoryStorage::invalidation(&self, radroots_storage::projection::ProjectionId, radroots_storage::projection::ProjectionGeneration) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::ProjectionInvalidation>, radroots_storage::Error>> 1952 pub fn radroots_storage::memory::MemoryStorage::projection_document(&self, radroots_storage::projection::ProjectionId, radroots_storage::projection::ProjectionGeneration, alloc::string::String) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::ProjectionDocument>, radroots_storage::Error>> 1953 pub fn radroots_storage::memory::MemoryStorage::projection_snapshot(&self, radroots_storage::projection::ProjectionId, [u8; 32]) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::ProjectionSnapshot>, radroots_storage::Error>> 1954 pub fn radroots_storage::memory::MemoryStorage::put_event_index_checkpoint(&self, radroots_storage::projection::EventIndexCheckpoint) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::Error>> 1955 pub fn radroots_storage::memory::MemoryStorage::put_event_index_manifest(&self, radroots_storage::projection::EventIndexManifest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::Error>> 1956 pub fn radroots_storage::memory::MemoryStorage::put_projection_document(&self, radroots_storage::projection::ProjectionId, radroots_storage::projection::ProjectionGeneration, radroots_storage::projection::ProjectionDocument) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::Error>> 1957 pub fn radroots_storage::memory::MemoryStorage::put_projection_snapshot(&self, radroots_storage::projection::ProjectionSnapshot) -> radroots_transport::source::BoxFuture<'_, core::result::Result<(), radroots_storage::Error>> 1958 pub fn radroots_storage::memory::MemoryStorage::query_projection_documents(&self, radroots_storage::projection::document_query::ProjectionDocumentQuery) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::document_query::ProjectionDocumentPage, radroots_storage::Error>> 1959 pub fn radroots_storage::memory::MemoryStorage::rebuild(&self, radroots_storage::projection::RebuildTicketId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::RebuildTicket>, radroots_storage::Error>> 1960 pub fn radroots_storage::memory::MemoryStorage::request_rebuild(&self, radroots_storage::projection::RebuildTicket) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::RebuildTicket, radroots_storage::Error>> 1961 pub fn radroots_storage::memory::MemoryStorage::status(&self, radroots_storage::projection::ProjectionId) -> radroots_transport::source::BoxFuture<'_, core::result::Result<core::option::Option<radroots_storage::projection::ProjectionStatus>, radroots_storage::Error>> 1962 pub fn radroots_storage::memory::MemoryStorage::transition_rebuild(&self, radroots_storage::projection::RebuildTransition) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_storage::projection::RebuildTicket, radroots_storage::Error>> 1963 pub trait radroots_storage::Storage: radroots_storage::event::EventStore + radroots_storage::journal::Journal + radroots_storage::outbox::Outbox + radroots_storage::projection::ProjectionStore + radroots_storage::private_artifact::PrivateArtifactStore + radroots_storage::backup::StorageReliability + radroots_storage::atomic::AtomicStorage + radroots_storage::authored_atomic::AuthoredAtomicStorage + radroots_storage::authored_draft::AuthoredDraftStore 1964 impl<T> radroots_storage::Storage for T where T: radroots_storage::event::EventStore + radroots_storage::journal::Journal + radroots_storage::outbox::Outbox + radroots_storage::projection::ProjectionStore + radroots_storage::private_artifact::PrivateArtifactStore + radroots_storage::backup::StorageReliability + radroots_storage::atomic::AtomicStorage + radroots_storage::authored_atomic::AuthoredAtomicStorage + radroots_storage::authored_draft::AuthoredDraftStore