pub struct AdminIntentLog { /* private fields */ }Implementations§
Source§impl AdminIntentLog
impl AdminIntentLog
Sourcepub fn open(path: impl AsRef<Path>) -> Result<Self, IntentLogError>
pub fn open(path: impl AsRef<Path>) -> Result<Self, IntentLogError>
Open (or create) the intent log at path.
Sourcepub fn begin(
&self,
op: IntentOp,
actor: &str,
args: IntentArgs,
) -> Result<IntentHandle<'_>, IntentLogError>
pub fn begin( &self, op: IntentOp, actor: &str, args: IntentArgs, ) -> Result<IntentHandle<'_>, IntentLogError>
Begin a new intent. Writes the opening record and fsyncs.
Sourcepub fn list_unfinished(&self) -> Vec<UnfinishedIntent>
pub fn list_unfinished(&self) -> Vec<UnfinishedIntent>
Return metadata about every intent that has not yet reached a terminal phase (completed or aborted).
Sourcepub fn scan_and_report(&self)
pub fn scan_and_report(&self)
Scan the log and emit crate::telemetry::operator_event::OperatorEvent::DanglingAdminIntent
for every unfinished intent. Corrupted lines are skipped with a
tracing::warn! breadcrumb — they do not abort the scan.
Auto Trait Implementations§
impl !Freeze for AdminIntentLog
impl RefUnwindSafe for AdminIntentLog
impl Send for AdminIntentLog
impl Sync for AdminIntentLog
impl Unpin for AdminIntentLog
impl UnsafeUnpin for AdminIntentLog
impl UnwindSafe for AdminIntentLog
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
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request