pub struct PgDatasetMaintenance { /* private fields */ }Expand description
Configured maintenance authority exposes only known-attempt reconciliation. The underlying administrator connection never escapes this adapter boundary.
Implementations§
Source§impl PgDatasetMaintenance
impl PgDatasetMaintenance
pub fn governance(&self) -> GovernanceMaintenance
Source§impl PgDatasetMaintenance
impl PgDatasetMaintenance
pub fn recoverable_attempts( &self, executor: Arc<dyn DatasetExecutorLease>, ) -> Result<Vec<RecoverableDatasetAttempt>, CoreError>
pub fn claim( &self, executor: Arc<dyn DatasetExecutorLease>, attempt_id: Uuid, ) -> Result<PgDatasetRecovery<'static>, CoreError>
pub fn has_unresolved_attempts(&self) -> Result<bool, CoreError>
Source§impl PgDatasetMaintenance
Operation recovery is restricted to stopped private attempts under the same
Dataset executor exclusion used by Lake cleanup. It can only fail unfinished
records; committed completion/result evidence is never rewritten.
impl PgDatasetMaintenance
Operation recovery is restricted to stopped private attempts under the same Dataset executor exclusion used by Lake cleanup. It can only fail unfinished records; committed completion/result evidence is never rewritten.
pub fn verify_operation_recovery(&self) -> Result<(), CoreError>
pub fn reconcile_operations( &self, executor: Arc<dyn DatasetExecutorLease>, interrupt: impl Fn(&mut StoredOperation), ) -> Result<(), CoreError>
Sourcepub fn prune_expired_operations(&self) -> Result<u64, CoreError>
pub fn prune_expired_operations(&self) -> Result<u64, CoreError>
A bounded lifecycle pass. The only cascade is into expired key bindings; Dataset ownership, private attempts, governed Assets and provenance are independent tables and remain available to trusted reconciliation.
Auto Trait Implementations§
impl Freeze for PgDatasetMaintenance
impl RefUnwindSafe for PgDatasetMaintenance
impl Send for PgDatasetMaintenance
impl Sync for PgDatasetMaintenance
impl Unpin for PgDatasetMaintenance
impl UnsafeUnpin for PgDatasetMaintenance
impl UnwindSafe for PgDatasetMaintenance
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more