reth_nippy_jar

Struct NippyJarChecker

Source
pub struct NippyJarChecker<H: NippyJarHeader = ()> { /* private fields */ }
Expand description

Performs consistency checks or heals on the NippyJar file

  • Is the offsets file size expected?
  • Is the data file size expected?

This is based on the assumption that NippyJar configuration is always the last one to be updated when something is written, as by the NippyJarWriter::commit() function shows.

For checks (read-only) use check_consistency method.

For heals (read-write) use ensure_consistency method.

Implementations§

Source§

impl<H: NippyJarHeader> NippyJarChecker<H>

Source

pub const fn new(jar: NippyJar<H>) -> Self

Creates a new instance of NippyJarChecker with the provided NippyJar.

This method initializes the checker without any associated file handles for the data or offsets files. The NippyJar passed in contains all necessary configurations for handling data.

Source

pub fn check_consistency(&mut self) -> Result<(), NippyJarError>

It will throw an error if the NippyJar is in a inconsistent state.

Source

pub fn ensure_consistency(&mut self) -> Result<(), NippyJarError>

It will attempt to heal if the NippyJar is in a inconsistent state.

ATTENTION: disk commit should be handled externally by consuming Self

Trait Implementations§

Source§

impl<H: Debug + NippyJarHeader> Debug for NippyJarChecker<H>

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<H> Freeze for NippyJarChecker<H>
where H: Freeze,

§

impl<H> RefUnwindSafe for NippyJarChecker<H>
where H: RefUnwindSafe,

§

impl<H> Send for NippyJarChecker<H>

§

impl<H> Sync for NippyJarChecker<H>

§

impl<H> Unpin for NippyJarChecker<H>
where H: Unpin,

§

impl<H> UnwindSafe for NippyJarChecker<H>
where H: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T> Instrument for T

§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<T> WithSubscriber for T

§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more

Layout§

Note: Unable to compute type layout, possibly due to this type having generic parameters. Layout can only be computed for concrete, fully-instantiated types.