radroots_sync.txt (35439B)
1 pub mod radroots_sync 2 pub mod radroots_sync::ingest 3 pub enum radroots_sync::ingest::AdmissionDecision 4 pub radroots_sync::ingest::AdmissionDecision::Reject 5 pub radroots_sync::ingest::AdmissionDecision::Verified 6 pub radroots_sync::ingest::AdmissionDecision::Visible 7 pub enum radroots_sync::ingest::ContractFailureDecision 8 pub radroots_sync::ingest::ContractFailureDecision::Reject 9 pub radroots_sync::ingest::ContractFailureDecision::Verified 10 pub struct radroots_sync::ingest::IngestBatchReceipt 11 impl radroots_sync::ingest::IngestBatchReceipt 12 pub fn radroots_sync::ingest::IngestBatchReceipt::accepted(&self) -> usize 13 pub fn radroots_sync::ingest::IngestBatchReceipt::outcomes(&self) -> &[core::result::Result<radroots_sync::ingest::IngestReceipt, radroots_sync::policy::Error>] 14 pub fn radroots_sync::ingest::IngestBatchReceipt::rejected(&self) -> usize 15 pub struct radroots_sync::ingest::IngestReceipt 16 impl radroots_sync::ingest::IngestReceipt 17 pub const fn radroots_sync::ingest::IngestReceipt::admission(&self) -> &radroots_storage::event::AdmissionReceipt 18 pub const fn radroots_sync::ingest::IngestReceipt::commit_disposition(&self) -> radroots_storage::atomic::AtomicCommitDisposition 19 pub const fn radroots_sync::ingest::IngestReceipt::committed_at_unix_ms(&self) -> u64 20 pub const fn radroots_sync::ingest::IngestReceipt::sync_id(&self) -> radroots_sync::policy::SyncId 21 pub struct radroots_sync::ingest::RegistryPolicy 22 impl radroots_sync::ingest::RegistryPolicy 23 pub const fn radroots_sync::ingest::RegistryPolicy::verified() -> Self 24 pub const fn radroots_sync::ingest::RegistryPolicy::visible() -> Self 25 impl radroots_sync::ingest::AdmissionPolicy for radroots_sync::ingest::RegistryPolicy 26 pub fn radroots_sync::ingest::RegistryPolicy::contract_failure(&self, &radroots_event::verification::SignatureVerifiedEvent) -> radroots_sync::ingest::ContractFailureDecision 27 pub fn radroots_sync::ingest::RegistryPolicy::decide(&self, &radroots_event::verification::ContractValidatedEvent) -> radroots_sync::ingest::AdmissionDecision 28 pub fn radroots_sync::ingest::RegistryPolicy::policy_id(&self) -> &'static str 29 pub fn radroots_sync::ingest::RegistryPolicy::select_contract(&self, &radroots_event::verification::SignatureVerifiedEvent) -> core::option::Option<&'static str> 30 pub trait radroots_sync::ingest::AdmissionPolicy: core::marker::Send + core::marker::Sync 31 pub fn radroots_sync::ingest::AdmissionPolicy::contract_failure(&self, &radroots_event::verification::SignatureVerifiedEvent) -> radroots_sync::ingest::ContractFailureDecision 32 pub fn radroots_sync::ingest::AdmissionPolicy::decide(&self, &radroots_event::verification::ContractValidatedEvent) -> radroots_sync::ingest::AdmissionDecision 33 pub fn radroots_sync::ingest::AdmissionPolicy::policy_id(&self) -> &'static str 34 pub fn radroots_sync::ingest::AdmissionPolicy::select_contract(&self, &radroots_event::verification::SignatureVerifiedEvent) -> core::option::Option<&'static str> 35 impl radroots_sync::ingest::AdmissionPolicy for radroots_sync::ingest::RegistryPolicy 36 pub fn radroots_sync::ingest::RegistryPolicy::contract_failure(&self, &radroots_event::verification::SignatureVerifiedEvent) -> radroots_sync::ingest::ContractFailureDecision 37 pub fn radroots_sync::ingest::RegistryPolicy::decide(&self, &radroots_event::verification::ContractValidatedEvent) -> radroots_sync::ingest::AdmissionDecision 38 pub fn radroots_sync::ingest::RegistryPolicy::policy_id(&self) -> &'static str 39 pub fn radroots_sync::ingest::RegistryPolicy::select_contract(&self, &radroots_event::verification::SignatureVerifiedEvent) -> core::option::Option<&'static str> 40 pub mod radroots_sync::policy 41 #[non_exhaustive] pub enum radroots_sync::policy::Error 42 pub radroots_sync::policy::Error::AdmissionFailed 43 pub radroots_sync::policy::Error::ClockUnavailable 44 pub radroots_sync::policy::Error::DeadlineOverflow 45 pub radroots_sync::policy::Error::DeliveryDeferred 46 pub radroots_sync::policy::Error::InvalidDeadlinePolicy 47 pub radroots_sync::policy::Error::InvalidDeliveryRequest 48 pub radroots_sync::policy::Error::InvalidIngestReceipt 49 pub radroots_sync::policy::Error::InvalidProjectionRequest 50 pub radroots_sync::policy::Error::InvalidPullRequest 51 pub radroots_sync::policy::Error::InvalidPushRequest 52 pub radroots_sync::policy::Error::InvalidReducerOutput 53 pub radroots_sync::policy::Error::InvalidSignerOutput 54 pub radroots_sync::policy::Error::InvalidSourcePage 55 pub radroots_sync::policy::Error::InvalidStatusRequest 56 pub radroots_sync::policy::Error::InvalidSyncId 57 pub radroots_sync::policy::Error::MissingSigner 58 pub radroots_sync::policy::Error::MissingSink 59 pub radroots_sync::policy::Error::MissingSource 60 pub radroots_sync::policy::Error::MissingTransportCapability 61 pub radroots_sync::policy::Error::PolicyRejected 62 pub radroots_sync::policy::Error::ReducerFailed 63 pub radroots_sync::policy::Error::SignerCapabilityUnavailable 64 pub radroots_sync::policy::Error::SignerDeadlineExceeded 65 pub radroots_sync::policy::Error::SignerFailed 66 pub radroots_sync::policy::Error::SignerWithoutSink 67 pub radroots_sync::policy::Error::SigningCancelled 68 pub radroots_sync::policy::Error::SigningIndeterminate 69 pub radroots_sync::policy::Error::StorageConflict 70 pub radroots_sync::policy::Error::StorageFailed 71 pub radroots_sync::policy::Error::StorageSpaceInsufficient 72 pub radroots_sync::policy::Error::VerificationFailed 73 pub radroots_sync::policy::Error::WorkClaimConflict 74 impl core::error::Error for radroots_sync::policy::Error 75 impl core::fmt::Display for radroots_sync::policy::Error 76 pub fn radroots_sync::policy::Error::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 77 #[non_exhaustive] pub enum radroots_sync::policy::OperationKind 78 pub radroots_sync::policy::OperationKind::Deliver 79 pub radroots_sync::policy::OperationKind::Ingest 80 pub radroots_sync::policy::OperationKind::Projection 81 pub radroots_sync::policy::OperationKind::Pull 82 pub radroots_sync::policy::OperationKind::Sign 83 pub struct radroots_sync::policy::DeadlinePolicy 84 impl radroots_sync::policy::DeadlinePolicy 85 pub fn radroots_sync::policy::DeadlinePolicy::deadline_unix_ms(self, radroots_sync::policy::OperationKind, u64) -> core::result::Result<u64, radroots_sync::policy::Error> 86 pub const fn radroots_sync::policy::DeadlinePolicy::new(u64, u64, u64) -> core::result::Result<Self, radroots_sync::policy::Error> 87 pub const fn radroots_sync::policy::DeadlinePolicy::timeout_ms(self, radroots_sync::policy::OperationKind) -> u64 88 impl<'de> serde_core::de::Deserialize<'de> for radroots_sync::policy::DeadlinePolicy 89 pub fn radroots_sync::policy::DeadlinePolicy::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 90 pub struct radroots_sync::policy::EngineBuilder 91 impl radroots_sync::policy::EngineBuilder 92 pub fn radroots_sync::policy::EngineBuilder::build(self) -> core::result::Result<radroots_sync::Engine, radroots_sync::policy::Error> 93 pub fn radroots_sync::policy::EngineBuilder::signer(self, alloc::sync::Arc<dyn radroots_signing::signer::Signer>) -> Self 94 pub fn radroots_sync::policy::EngineBuilder::sink(self, alloc::sync::Arc<dyn radroots_transport::sink::EventSink>) -> Self 95 pub fn radroots_sync::policy::EngineBuilder::source(self, alloc::sync::Arc<dyn radroots_transport::source::EventSource>) -> Self 96 pub struct radroots_sync::policy::SyncId(_) 97 impl radroots_sync::policy::SyncId 98 pub const fn radroots_sync::policy::SyncId::as_bytes(&self) -> &[u8; 16] 99 pub const fn radroots_sync::policy::SyncId::new([u8; 16]) -> core::result::Result<Self, radroots_sync::policy::Error> 100 impl<'de> serde_core::de::Deserialize<'de> for radroots_sync::policy::SyncId 101 pub fn radroots_sync::policy::SyncId::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 102 pub trait radroots_sync::policy::Clock: core::marker::Send + core::marker::Sync 103 pub fn radroots_sync::policy::Clock::now_unix_ms(&self) -> core::result::Result<u64, radroots_sync::policy::Error> 104 pub trait radroots_sync::policy::IdSource: core::marker::Send + core::marker::Sync 105 pub fn radroots_sync::policy::IdSource::next_id(&self, radroots_sync::policy::OperationKind) -> core::result::Result<radroots_sync::policy::SyncId, radroots_sync::policy::Error> 106 pub trait radroots_sync::policy::SyncStorage: radroots_storage::event::EventStore + radroots_storage::journal::Journal + radroots_storage::outbox::Outbox + radroots_storage::projection::ProjectionStore + radroots_storage::atomic::AtomicStorage + radroots_storage::authored_atomic::AuthoredAtomicStorage + radroots_storage::status::StorageStatusProvider 107 impl<T> radroots_sync::policy::SyncStorage for T where T: radroots_storage::event::EventStore + radroots_storage::journal::Journal + radroots_storage::outbox::Outbox + radroots_storage::projection::ProjectionStore + radroots_storage::atomic::AtomicStorage + radroots_storage::authored_atomic::AuthoredAtomicStorage + radroots_storage::status::StorageStatusProvider 108 pub mod radroots_sync::projection 109 pub enum radroots_sync::projection::RefreshKind 110 pub radroots_sync::projection::RefreshKind::Incremental 111 pub radroots_sync::projection::RefreshKind::Rebuild 112 pub enum radroots_sync::projection::RefreshState 113 pub radroots_sync::projection::RefreshState::Complete 114 pub radroots_sync::projection::RefreshState::Failed 115 pub radroots_sync::projection::RefreshState::Partial 116 pub struct radroots_sync::projection::ReducerError 117 pub struct radroots_sync::projection::RefreshReceipt 118 impl radroots_sync::projection::RefreshReceipt 119 pub const fn radroots_sync::projection::RefreshReceipt::batches(&self) -> u16 120 pub const fn radroots_sync::projection::RefreshReceipt::checkpoint(&self) -> core::option::Option<&radroots_storage::projection::ProjectionCheckpoint> 121 pub const fn radroots_sync::projection::RefreshReceipt::events_reduced(&self) -> usize 122 pub const fn radroots_sync::projection::RefreshReceipt::kind(&self) -> radroots_sync::projection::RefreshKind 123 pub const fn radroots_sync::projection::RefreshReceipt::rebuild_ticket(&self) -> core::option::Option<radroots_storage::projection::RebuildTicketId> 124 pub const fn radroots_sync::projection::RefreshReceipt::state(&self) -> radroots_sync::projection::RefreshState 125 pub struct radroots_sync::projection::RefreshRequest 126 impl radroots_sync::projection::RefreshRequest 127 pub const fn radroots_sync::projection::RefreshRequest::batch_limit(&self) -> u16 128 pub const fn radroots_sync::projection::RefreshRequest::generation(&self) -> radroots_storage::projection::ProjectionGeneration 129 pub const fn radroots_sync::projection::RefreshRequest::max_batches(&self) -> u16 130 pub fn radroots_sync::projection::RefreshRequest::new(radroots_storage::projection::ProjectionId, radroots_storage::projection::ProjectionGeneration, u16, u16) -> core::result::Result<Self, radroots_sync::policy::Error> 131 pub const fn radroots_sync::projection::RefreshRequest::projection_id(&self) -> &radroots_storage::projection::ProjectionId 132 pub const radroots_sync::projection::PROJECTION_RAW_SOURCE_MAX_EVENTS: u64 133 pub const radroots_sync::projection::PROJECTION_REFRESH_MAX_BATCHES: u16 134 pub trait radroots_sync::projection::Reducer: core::marker::Send + core::marker::Sync 135 pub fn radroots_sync::projection::Reducer::abort_rebuild(&self, radroots_storage::projection::RebuildTicketId, radroots_storage::projection::RebuildFailure) -> core::result::Result<(), radroots_sync::projection::ReducerError> 136 pub fn radroots_sync::projection::Reducer::begin_rebuild(&self, radroots_storage::projection::RebuildTicketId, radroots_storage::event::SourceGeneration, radroots_storage::projection::RawSourceDigest) -> core::result::Result<(), radroots_sync::projection::ReducerError> 137 pub fn radroots_sync::projection::Reducer::generation(&self) -> radroots_storage::projection::ProjectionGeneration 138 pub fn radroots_sync::projection::Reducer::projection_id(&self) -> &radroots_storage::projection::ProjectionId 139 pub fn radroots_sync::projection::Reducer::reduce(&self, &[radroots_storage::event::StoredVisibleEvent], u64, core::option::Option<radroots_storage::projection::RebuildTicketId>) -> core::result::Result<u64, radroots_sync::projection::ReducerError> 140 pub mod radroots_sync::pull 141 pub enum radroots_sync::pull::PullTermination 142 pub radroots_sync::pull::PullTermination::Cancelled 143 pub radroots_sync::pull::PullTermination::Complete 144 pub radroots_sync::pull::PullTermination::Deadline 145 pub radroots_sync::pull::PullTermination::PageLimit 146 pub radroots_sync::pull::PullTermination::SourceFailed 147 pub struct radroots_sync::pull::PullReceipt 148 impl radroots_sync::pull::PullReceipt 149 pub const fn radroots_sync::pull::PullReceipt::deadline_unix_ms(&self) -> u64 150 pub const fn radroots_sync::pull::PullReceipt::events_observed(&self) -> usize 151 pub fn radroots_sync::pull::PullReceipt::ingest_outcomes(&self) -> &[core::result::Result<radroots_sync::ingest::IngestReceipt, radroots_sync::policy::Error>] 152 pub const fn radroots_sync::pull::PullReceipt::pages_fetched(&self) -> u16 153 pub const fn radroots_sync::pull::PullReceipt::resume_from(&self) -> core::option::Option<&radroots_transport::source::FetchCursor> 154 pub const fn radroots_sync::pull::PullReceipt::sync_id(&self) -> radroots_sync::policy::SyncId 155 pub fn radroots_sync::pull::PullReceipt::target_outcomes(&self) -> &[radroots_transport::outcome::FetchTargetOutcome] 156 pub fn radroots_sync::pull::PullReceipt::target_summaries(&self) -> core::option::Option<&[radroots_sync::pull::PullTargetSummary]> 157 pub const fn radroots_sync::pull::PullReceipt::termination(&self) -> radroots_sync::pull::PullTermination 158 impl<'de> serde_core::de::Deserialize<'de> for radroots_sync::pull::PullReceipt 159 pub fn radroots_sync::pull::PullReceipt::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 160 pub struct radroots_sync::pull::PullRequest 161 impl radroots_sync::pull::PullRequest 162 pub const fn radroots_sync::pull::PullRequest::cursor(&self) -> core::option::Option<&radroots_transport::source::FetchCursor> 163 pub const fn radroots_sync::pull::PullRequest::max_pages(&self) -> u16 164 pub fn radroots_sync::pull::PullRequest::new(radroots_transport::target::TargetSet, u16, u16) -> core::result::Result<Self, radroots_sync::policy::Error> 165 pub const fn radroots_sync::pull::PullRequest::page_limit(&self) -> u16 166 pub const fn radroots_sync::pull::PullRequest::selector(&self) -> &radroots_transport::source::FetchSelector 167 pub const fn radroots_sync::pull::PullRequest::targets(&self) -> &radroots_transport::target::TargetSet 168 pub fn radroots_sync::pull::PullRequest::with_cursor(self, radroots_transport::source::FetchCursor) -> Self 169 pub fn radroots_sync::pull::PullRequest::with_selector(self, radroots_transport::source::FetchSelector) -> Self 170 impl<'de> serde_core::de::Deserialize<'de> for radroots_sync::pull::PullRequest 171 pub fn radroots_sync::pull::PullRequest::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 172 pub struct radroots_sync::pull::PullTargetSummary 173 impl radroots_sync::pull::PullTargetSummary 174 pub const fn radroots_sync::pull::PullTargetSummary::all_pages_complete(&self) -> bool 175 pub const fn radroots_sync::pull::PullTargetSummary::incomplete_pages(&self) -> u16 176 pub const fn radroots_sync::pull::PullTargetSummary::last_incomplete(&self) -> core::option::Option<radroots_transport::outcome::FetchTargetState> 177 pub const fn radroots_sync::pull::PullTargetSummary::missing_outcome_pages(&self) -> u16 178 pub const fn radroots_sync::pull::PullTargetSummary::pages_observed(&self) -> u16 179 pub const fn radroots_sync::pull::PullTargetSummary::target(&self) -> &radroots_transport::target::TargetFingerprint 180 impl<'de> serde_core::de::Deserialize<'de> for radroots_sync::pull::PullTargetSummary 181 pub fn radroots_sync::pull::PullTargetSummary::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 182 pub const radroots_sync::pull::PULL_MAX_PAGES: u16 183 pub mod radroots_sync::push 184 pub struct radroots_sync::push::AdmissionRunReceipt 185 impl radroots_sync::push::AdmissionRunReceipt 186 pub const fn radroots_sync::push::AdmissionRunReceipt::artifact(&self) -> &radroots_storage::authored::AuthoredArtifact 187 pub const fn radroots_sync::push::AdmissionRunReceipt::is_replay(&self) -> bool 188 pub struct radroots_sync::push::DeliveryExecutionReceipt 189 impl radroots_sync::push::DeliveryExecutionReceipt 190 pub const fn radroots_sync::push::DeliveryExecutionReceipt::is_replay(&self) -> bool 191 pub const fn radroots_sync::push::DeliveryExecutionReceipt::plan(&self) -> &radroots_storage::authored_delivery::AuthoredDeliveryPlan 192 pub struct radroots_sync::push::PushCancellationReceipt 193 impl radroots_sync::push::PushCancellationReceipt 194 pub const fn radroots_sync::push::PushCancellationReceipt::changed(&self) -> bool 195 pub const fn radroots_sync::push::PushCancellationReceipt::status(&self) -> &radroots_sync::push::PushStatus 196 pub struct radroots_sync::push::PushPreparation 197 impl radroots_sync::push::PushPreparation 198 pub const fn radroots_sync::push::PushPreparation::artifact(&self) -> &radroots_storage::authored::AuthoredArtifact 199 pub const fn radroots_sync::push::PushPreparation::delivery_plan(&self) -> &radroots_storage::authored_delivery::AuthoredDeliveryPlan 200 pub const fn radroots_sync::push::PushPreparation::is_replay(&self) -> bool 201 pub const fn radroots_sync::push::PushPreparation::operation(&self) -> &radroots_storage::authored::AuthoredOperation 202 pub struct radroots_sync::push::PushRequest 203 impl radroots_sync::push::PushRequest 204 pub const fn radroots_sync::push::PushRequest::actor(&self) -> &radroots_signing::actor::Actor 205 pub fn radroots_sync::push::PushRequest::authored_preparation(&self, u64) -> core::result::Result<radroots_storage::authored_atomic::PrepareAuthoredOperation, radroots_sync::policy::Error> 206 pub const fn radroots_sync::push::PushRequest::cancellation(&self) -> radroots_signing::request::CancellationPolicy 207 pub const fn radroots_sync::push::PushRequest::delivery_deadline_unix_ms(&self) -> u64 208 pub const fn radroots_sync::push::PushRequest::idempotency_key(&self) -> &radroots_storage::journal::IdempotencyKey 209 pub fn radroots_sync::push::PushRequest::new(radroots_sync::policy::SyncId, radroots_storage::journal::IdempotencyKey, radroots_signing::actor::Actor, radroots_event_codec::authoring::AuthoredEventPlan, radroots_transport::target::TargetSet, radroots_transport::policy::SatisfactionPolicy, u64, radroots_signing::request::CancellationPolicy) -> core::result::Result<Self, radroots_sync::policy::Error> 210 pub const fn radroots_sync::push::PushRequest::operation_id(&self) -> radroots_sync::policy::SyncId 211 pub const fn radroots_sync::push::PushRequest::plan(&self) -> &radroots_event_codec::authoring::AuthoredEventPlan 212 pub const fn radroots_sync::push::PushRequest::satisfaction(&self) -> &radroots_transport::policy::SatisfactionPolicy 213 pub const fn radroots_sync::push::PushRequest::targets(&self) -> &radroots_transport::target::TargetSet 214 impl core::fmt::Debug for radroots_sync::push::PushRequest 215 pub fn radroots_sync::push::PushRequest::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 216 pub struct radroots_sync::push::PushStatus 217 impl radroots_sync::push::PushStatus 218 pub const fn radroots_sync::push::PushStatus::artifact(&self) -> &radroots_storage::authored::AuthoredArtifact 219 pub const fn radroots_sync::push::PushStatus::delivery_history(&self) -> &radroots_storage::authored_delivery::history::AuthoredDeliveryHistory 220 pub const fn radroots_sync::push::PushStatus::delivery_plan(&self) -> &radroots_storage::authored_delivery::AuthoredDeliveryPlan 221 pub const fn radroots_sync::push::PushStatus::operation(&self) -> &radroots_storage::authored::AuthoredOperation 222 pub const fn radroots_sync::push::PushStatus::settlement(&self) -> radroots_storage::authored::OperationSettlement 223 pub struct radroots_sync::push::SigningRunReceipt 224 impl radroots_sync::push::SigningRunReceipt 225 pub const fn radroots_sync::push::SigningRunReceipt::artifact(&self) -> &radroots_storage::authored::AuthoredArtifact 226 pub const fn radroots_sync::push::SigningRunReceipt::is_replay(&self) -> bool 227 pub mod radroots_sync::status 228 pub struct radroots_sync::status::CapabilityReport<T> 229 impl<T> radroots_sync::status::CapabilityReport<T> 230 pub const fn radroots_sync::status::CapabilityReport<T>::state(&self) -> radroots_protocol::runtime::v1::SyncCapabilityState 231 pub const fn radroots_sync::status::CapabilityReport<T>::status(&self) -> core::option::Option<&T> 232 pub struct radroots_sync::status::ProjectionReport 233 impl radroots_sync::status::ProjectionReport 234 pub const fn radroots_sync::status::ProjectionReport::projection_id(&self) -> &radroots_storage::projection::ProjectionId 235 pub const fn radroots_sync::status::ProjectionReport::status(&self) -> core::option::Option<&radroots_storage::projection::ProjectionStatus> 236 pub struct radroots_sync::status::SyncStatus 237 impl radroots_sync::status::SyncStatus 238 pub const fn radroots_sync::status::SyncStatus::events(&self) -> &radroots_storage::status::EventStoreStatus 239 pub const fn radroots_sync::status::SyncStatus::health(&self) -> radroots_protocol::runtime::v1::SyncHealth 240 pub const fn radroots_sync::status::SyncStatus::outbox(&self) -> radroots_storage::outbox::OutboxStatus 241 pub fn radroots_sync::status::SyncStatus::projections(&self) -> &[radroots_sync::status::ProjectionReport] 242 pub const fn radroots_sync::status::SyncStatus::signer(&self) -> &radroots_sync::status::CapabilityReport<radroots_signing::status::SignerStatus> 243 pub const fn radroots_sync::status::SyncStatus::sink(&self) -> &radroots_sync::status::CapabilityReport<radroots_transport::status::SinkStatus> 244 pub const fn radroots_sync::status::SyncStatus::source(&self) -> &radroots_sync::status::CapabilityReport<radroots_transport::status::SourceStatus> 245 pub const fn radroots_sync::status::SyncStatus::storage(&self) -> radroots_storage::status::StorageStatus 246 pub fn radroots_sync::status::SyncStatus::to_protocol(&self) -> radroots_protocol::runtime::v1::SyncStatusReceipt 247 #[non_exhaustive] pub enum radroots_sync::Error 248 pub radroots_sync::Error::AdmissionFailed 249 pub radroots_sync::Error::ClockUnavailable 250 pub radroots_sync::Error::DeadlineOverflow 251 pub radroots_sync::Error::DeliveryDeferred 252 pub radroots_sync::Error::InvalidDeadlinePolicy 253 pub radroots_sync::Error::InvalidDeliveryRequest 254 pub radroots_sync::Error::InvalidIngestReceipt 255 pub radroots_sync::Error::InvalidProjectionRequest 256 pub radroots_sync::Error::InvalidPullRequest 257 pub radroots_sync::Error::InvalidPushRequest 258 pub radroots_sync::Error::InvalidReducerOutput 259 pub radroots_sync::Error::InvalidSignerOutput 260 pub radroots_sync::Error::InvalidSourcePage 261 pub radroots_sync::Error::InvalidStatusRequest 262 pub radroots_sync::Error::InvalidSyncId 263 pub radroots_sync::Error::MissingSigner 264 pub radroots_sync::Error::MissingSink 265 pub radroots_sync::Error::MissingSource 266 pub radroots_sync::Error::MissingTransportCapability 267 pub radroots_sync::Error::PolicyRejected 268 pub radroots_sync::Error::ReducerFailed 269 pub radroots_sync::Error::SignerCapabilityUnavailable 270 pub radroots_sync::Error::SignerDeadlineExceeded 271 pub radroots_sync::Error::SignerFailed 272 pub radroots_sync::Error::SignerWithoutSink 273 pub radroots_sync::Error::SigningCancelled 274 pub radroots_sync::Error::SigningIndeterminate 275 pub radroots_sync::Error::StorageConflict 276 pub radroots_sync::Error::StorageFailed 277 pub radroots_sync::Error::StorageSpaceInsufficient 278 pub radroots_sync::Error::VerificationFailed 279 pub radroots_sync::Error::WorkClaimConflict 280 impl core::error::Error for radroots_sync::policy::Error 281 impl core::fmt::Display for radroots_sync::policy::Error 282 pub fn radroots_sync::policy::Error::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 283 pub struct radroots_sync::AdmissionRunReceipt 284 impl radroots_sync::push::AdmissionRunReceipt 285 pub const fn radroots_sync::push::AdmissionRunReceipt::artifact(&self) -> &radroots_storage::authored::AuthoredArtifact 286 pub const fn radroots_sync::push::AdmissionRunReceipt::is_replay(&self) -> bool 287 pub struct radroots_sync::DeliveryExecutionReceipt 288 impl radroots_sync::push::DeliveryExecutionReceipt 289 pub const fn radroots_sync::push::DeliveryExecutionReceipt::is_replay(&self) -> bool 290 pub const fn radroots_sync::push::DeliveryExecutionReceipt::plan(&self) -> &radroots_storage::authored_delivery::AuthoredDeliveryPlan 291 pub struct radroots_sync::Engine 292 impl radroots_sync::Engine 293 pub async fn radroots_sync::Engine::admit_signed(&self, radroots_sync::policy::SyncId) -> core::result::Result<radroots_sync::push::AdmissionRunReceipt, radroots_sync::policy::Error> 294 pub async fn radroots_sync::Engine::cancel_push(&self, radroots_sync::policy::SyncId) -> core::result::Result<radroots_sync::push::PushCancellationReceipt, radroots_sync::policy::Error> 295 pub async fn radroots_sync::Engine::prepare_push(&self, radroots_sync::push::PushRequest) -> core::result::Result<radroots_sync::push::PushPreparation, radroots_sync::policy::Error> 296 pub async fn radroots_sync::Engine::push_status(&self, radroots_sync::policy::SyncId) -> core::result::Result<core::option::Option<radroots_sync::push::PushStatus>, radroots_sync::policy::Error> 297 pub async fn radroots_sync::Engine::sign_prepared(&self, radroots_sync::push::PushRequest) -> core::result::Result<radroots_sync::push::SigningRunReceipt, radroots_sync::policy::Error> 298 impl radroots_sync::Engine 299 pub fn radroots_sync::Engine::builder(alloc::sync::Arc<dyn radroots_sync::policy::SyncStorage>, alloc::sync::Arc<dyn radroots_sync::policy::Clock>, alloc::sync::Arc<dyn radroots_sync::policy::IdSource>, radroots_sync::policy::DeadlinePolicy) -> radroots_sync::policy::EngineBuilder 300 pub fn radroots_sync::Engine::clock(&self) -> &dyn radroots_sync::policy::Clock 301 pub const fn radroots_sync::Engine::deadlines(&self) -> radroots_sync::policy::DeadlinePolicy 302 pub fn radroots_sync::Engine::ids(&self) -> &dyn radroots_sync::policy::IdSource 303 pub fn radroots_sync::Engine::signer(&self) -> core::option::Option<&dyn radroots_signing::signer::Signer> 304 pub fn radroots_sync::Engine::sink(&self) -> core::option::Option<&dyn radroots_transport::sink::EventSink> 305 pub fn radroots_sync::Engine::source(&self) -> core::option::Option<&dyn radroots_transport::source::EventSource> 306 pub fn radroots_sync::Engine::storage(&self) -> &dyn radroots_sync::policy::SyncStorage 307 impl radroots_sync::Engine 308 pub async fn radroots_sync::Engine::deliver_push(&self, radroots_sync::policy::SyncId) -> core::result::Result<radroots_sync::push::DeliveryExecutionReceipt, radroots_sync::policy::Error> 309 pub async fn radroots_sync::Engine::deliver_push_selected(&self, radroots_sync::policy::SyncId, radroots_transport::target::TargetSet) -> core::result::Result<radroots_sync::push::DeliveryExecutionReceipt, radroots_sync::policy::Error> 310 impl radroots_sync::Engine 311 pub async fn radroots_sync::Engine::ingest(&self, radroots_transport::source::ObservedEvent, &dyn radroots_sync::ingest::AdmissionPolicy) -> core::result::Result<radroots_sync::ingest::IngestReceipt, radroots_sync::policy::Error> 312 pub async fn radroots_sync::Engine::ingest_batch(&self, alloc::vec::Vec<radroots_transport::source::ObservedEvent>, &dyn radroots_sync::ingest::AdmissionPolicy) -> radroots_sync::ingest::IngestBatchReceipt 313 impl radroots_sync::Engine 314 pub async fn radroots_sync::Engine::pull(&self, radroots_sync::pull::PullRequest, &dyn radroots_sync::ingest::AdmissionPolicy) -> core::result::Result<radroots_sync::pull::PullReceipt, radroots_sync::policy::Error> 315 impl radroots_sync::Engine 316 pub async fn radroots_sync::Engine::refresh_projection(&self, radroots_sync::projection::RefreshRequest, &dyn radroots_sync::projection::Reducer) -> core::result::Result<radroots_sync::projection::RefreshReceipt, radroots_sync::policy::Error> 317 impl radroots_sync::Engine 318 pub fn radroots_sync::Engine::retry_decision(&self, &radroots_storage::authored_delivery::AuthoredDeliveryPlan, u64) -> core::result::Result<radroots_protocol::runtime::v1::SyncRetryDecision, radroots_sync::policy::Error> 319 pub async fn radroots_sync::Engine::status(&self, &[radroots_storage::projection::ProjectionId]) -> core::result::Result<radroots_sync::status::SyncStatus, radroots_sync::policy::Error> 320 impl core::fmt::Debug for radroots_sync::Engine 321 pub fn radroots_sync::Engine::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 322 pub struct radroots_sync::PullReceipt 323 impl radroots_sync::pull::PullReceipt 324 pub const fn radroots_sync::pull::PullReceipt::deadline_unix_ms(&self) -> u64 325 pub const fn radroots_sync::pull::PullReceipt::events_observed(&self) -> usize 326 pub fn radroots_sync::pull::PullReceipt::ingest_outcomes(&self) -> &[core::result::Result<radroots_sync::ingest::IngestReceipt, radroots_sync::policy::Error>] 327 pub const fn radroots_sync::pull::PullReceipt::pages_fetched(&self) -> u16 328 pub const fn radroots_sync::pull::PullReceipt::resume_from(&self) -> core::option::Option<&radroots_transport::source::FetchCursor> 329 pub const fn radroots_sync::pull::PullReceipt::sync_id(&self) -> radroots_sync::policy::SyncId 330 pub fn radroots_sync::pull::PullReceipt::target_outcomes(&self) -> &[radroots_transport::outcome::FetchTargetOutcome] 331 pub fn radroots_sync::pull::PullReceipt::target_summaries(&self) -> core::option::Option<&[radroots_sync::pull::PullTargetSummary]> 332 pub const fn radroots_sync::pull::PullReceipt::termination(&self) -> radroots_sync::pull::PullTermination 333 impl<'de> serde_core::de::Deserialize<'de> for radroots_sync::pull::PullReceipt 334 pub fn radroots_sync::pull::PullReceipt::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 335 pub struct radroots_sync::PullRequest 336 impl radroots_sync::pull::PullRequest 337 pub const fn radroots_sync::pull::PullRequest::cursor(&self) -> core::option::Option<&radroots_transport::source::FetchCursor> 338 pub const fn radroots_sync::pull::PullRequest::max_pages(&self) -> u16 339 pub fn radroots_sync::pull::PullRequest::new(radroots_transport::target::TargetSet, u16, u16) -> core::result::Result<Self, radroots_sync::policy::Error> 340 pub const fn radroots_sync::pull::PullRequest::page_limit(&self) -> u16 341 pub const fn radroots_sync::pull::PullRequest::selector(&self) -> &radroots_transport::source::FetchSelector 342 pub const fn radroots_sync::pull::PullRequest::targets(&self) -> &radroots_transport::target::TargetSet 343 pub fn radroots_sync::pull::PullRequest::with_cursor(self, radroots_transport::source::FetchCursor) -> Self 344 pub fn radroots_sync::pull::PullRequest::with_selector(self, radroots_transport::source::FetchSelector) -> Self 345 impl<'de> serde_core::de::Deserialize<'de> for radroots_sync::pull::PullRequest 346 pub fn radroots_sync::pull::PullRequest::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 347 pub struct radroots_sync::PushCancellationReceipt 348 impl radroots_sync::push::PushCancellationReceipt 349 pub const fn radroots_sync::push::PushCancellationReceipt::changed(&self) -> bool 350 pub const fn radroots_sync::push::PushCancellationReceipt::status(&self) -> &radroots_sync::push::PushStatus 351 pub struct radroots_sync::PushPreparation 352 impl radroots_sync::push::PushPreparation 353 pub const fn radroots_sync::push::PushPreparation::artifact(&self) -> &radroots_storage::authored::AuthoredArtifact 354 pub const fn radroots_sync::push::PushPreparation::delivery_plan(&self) -> &radroots_storage::authored_delivery::AuthoredDeliveryPlan 355 pub const fn radroots_sync::push::PushPreparation::is_replay(&self) -> bool 356 pub const fn radroots_sync::push::PushPreparation::operation(&self) -> &radroots_storage::authored::AuthoredOperation 357 pub struct radroots_sync::PushRequest 358 impl radroots_sync::push::PushRequest 359 pub const fn radroots_sync::push::PushRequest::actor(&self) -> &radroots_signing::actor::Actor 360 pub fn radroots_sync::push::PushRequest::authored_preparation(&self, u64) -> core::result::Result<radroots_storage::authored_atomic::PrepareAuthoredOperation, radroots_sync::policy::Error> 361 pub const fn radroots_sync::push::PushRequest::cancellation(&self) -> radroots_signing::request::CancellationPolicy 362 pub const fn radroots_sync::push::PushRequest::delivery_deadline_unix_ms(&self) -> u64 363 pub const fn radroots_sync::push::PushRequest::idempotency_key(&self) -> &radroots_storage::journal::IdempotencyKey 364 pub fn radroots_sync::push::PushRequest::new(radroots_sync::policy::SyncId, radroots_storage::journal::IdempotencyKey, radroots_signing::actor::Actor, radroots_event_codec::authoring::AuthoredEventPlan, radroots_transport::target::TargetSet, radroots_transport::policy::SatisfactionPolicy, u64, radroots_signing::request::CancellationPolicy) -> core::result::Result<Self, radroots_sync::policy::Error> 365 pub const fn radroots_sync::push::PushRequest::operation_id(&self) -> radroots_sync::policy::SyncId 366 pub const fn radroots_sync::push::PushRequest::plan(&self) -> &radroots_event_codec::authoring::AuthoredEventPlan 367 pub const fn radroots_sync::push::PushRequest::satisfaction(&self) -> &radroots_transport::policy::SatisfactionPolicy 368 pub const fn radroots_sync::push::PushRequest::targets(&self) -> &radroots_transport::target::TargetSet 369 impl core::fmt::Debug for radroots_sync::push::PushRequest 370 pub fn radroots_sync::push::PushRequest::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 371 pub struct radroots_sync::PushStatus 372 impl radroots_sync::push::PushStatus 373 pub const fn radroots_sync::push::PushStatus::artifact(&self) -> &radroots_storage::authored::AuthoredArtifact 374 pub const fn radroots_sync::push::PushStatus::delivery_history(&self) -> &radroots_storage::authored_delivery::history::AuthoredDeliveryHistory 375 pub const fn radroots_sync::push::PushStatus::delivery_plan(&self) -> &radroots_storage::authored_delivery::AuthoredDeliveryPlan 376 pub const fn radroots_sync::push::PushStatus::operation(&self) -> &radroots_storage::authored::AuthoredOperation 377 pub const fn radroots_sync::push::PushStatus::settlement(&self) -> radroots_storage::authored::OperationSettlement 378 pub struct radroots_sync::SigningRunReceipt 379 impl radroots_sync::push::SigningRunReceipt 380 pub const fn radroots_sync::push::SigningRunReceipt::artifact(&self) -> &radroots_storage::authored::AuthoredArtifact 381 pub const fn radroots_sync::push::SigningRunReceipt::is_replay(&self) -> bool 382 pub struct radroots_sync::SyncStatus 383 impl radroots_sync::status::SyncStatus 384 pub const fn radroots_sync::status::SyncStatus::events(&self) -> &radroots_storage::status::EventStoreStatus 385 pub const fn radroots_sync::status::SyncStatus::health(&self) -> radroots_protocol::runtime::v1::SyncHealth 386 pub const fn radroots_sync::status::SyncStatus::outbox(&self) -> radroots_storage::outbox::OutboxStatus 387 pub fn radroots_sync::status::SyncStatus::projections(&self) -> &[radroots_sync::status::ProjectionReport] 388 pub const fn radroots_sync::status::SyncStatus::signer(&self) -> &radroots_sync::status::CapabilityReport<radroots_signing::status::SignerStatus> 389 pub const fn radroots_sync::status::SyncStatus::sink(&self) -> &radroots_sync::status::CapabilityReport<radroots_transport::status::SinkStatus> 390 pub const fn radroots_sync::status::SyncStatus::source(&self) -> &radroots_sync::status::CapabilityReport<radroots_transport::status::SourceStatus> 391 pub const fn radroots_sync::status::SyncStatus::storage(&self) -> radroots_storage::status::StorageStatus 392 pub fn radroots_sync::status::SyncStatus::to_protocol(&self) -> radroots_protocol::runtime::v1::SyncStatusReceipt