pub struct Keyless<E: Storage + Clock + Metrics, V: Codec, H: CHasher> { /* private fields */ }
Expand description
A keyless ADB for variable length data.
Implementations§
Source§impl<E: Storage + Clock + Metrics, V: Codec, H: CHasher> Keyless<E, V, H>
impl<E: Storage + Clock + Metrics, V: Codec, H: CHasher> Keyless<E, V, H>
Sourcepub async fn init(context: E, cfg: Config<V::Cfg>) -> Result<Self, Error>
pub async fn init(context: E, cfg: Config<V::Cfg>) -> Result<Self, Error>
Returns a Keyless adb initialized from cfg
. Any uncommitted operations will be discarded
and the state of the db will be as of the last committed operation.
Sourcepub async fn get(&self, loc: u64) -> Result<Option<V>, Error>
pub async fn get(&self, loc: u64) -> Result<Option<V>, Error>
Get the value at location loc
in the database.
Sourcepub fn op_count(&self) -> u64
pub fn op_count(&self) -> u64
Get the number of operations (appends + commits) that have been applied to the db since inception.
Sourcepub fn last_commit_loc(&self) -> Option<u64>
pub fn last_commit_loc(&self) -> Option<u64>
Returns the location of the last commit, if any.
Sourcepub async fn oldest_retained_loc(&self) -> Result<Option<u64>, Error>
pub async fn oldest_retained_loc(&self) -> Result<Option<u64>, Error>
Return the oldest location that remains retrievable.
Sourcepub async fn prune(&mut self, loc: u64) -> Result<(), Error>
pub async fn prune(&mut self, loc: u64) -> Result<(), Error>
Prunes the db of up to all operations that have location less than loc
. The actual number
pruned may be fewer than requested due to blob boundaries in the underlying journals.
§Panics
Panics if loc
is beyond the last commit point.
Sourcepub async fn append(&mut self, value: V) -> Result<u64, Error>
pub async fn append(&mut self, value: V) -> Result<u64, Error>
Append a value to the db, returning its location which can be used to retrieve it.
Sourcepub async fn commit(&mut self, metadata: Option<V>) -> Result<u64, Error>
pub async fn commit(&mut self, metadata: Option<V>) -> Result<u64, Error>
Commit any pending operations to the database, ensuring their durability upon return from
this function. Caller can associate an arbitrary metadata
value with the commit.
Failures after commit (but before sync
or close
) may still require reprocessing to
recover the database on restart.
Sourcepub async fn sync(&mut self) -> Result<(), Error>
pub async fn sync(&mut self) -> Result<(), Error>
Sync all database state to disk. While this isn’t necessary to ensure durability of committed operations, periodic invocation may reduce memory usage and the time required to recover the database on restart.
Sourcepub async fn get_metadata(&self) -> Result<Option<(u64, Option<V>)>, Error>
pub async fn get_metadata(&self) -> Result<Option<(u64, Option<V>)>, Error>
Get the location and metadata associated with the last commit, or None if no commit has been made.
Sourcepub async fn proof(
&self,
start_loc: u64,
max_ops: NonZeroU64,
) -> Result<(Proof<H::Digest>, Vec<Operation<V>>), Error>
pub async fn proof( &self, start_loc: u64, max_ops: NonZeroU64, ) -> Result<(Proof<H::Digest>, Vec<Operation<V>>), Error>
Generate and return:
- a proof of all operations applied to the db in the range starting at (and including)
location
start_loc
, and ending at the first of either:- the last operation performed, or
- the operation
max_ops
from the start.
- the operations corresponding to the leaves in this range.
§Warning
Panics if there are uncommitted operations.
Sourcepub async fn historical_proof(
&self,
size: u64,
start_loc: u64,
max_ops: NonZeroU64,
) -> Result<(Proof<H::Digest>, Vec<Operation<V>>), Error>
pub async fn historical_proof( &self, size: u64, start_loc: u64, max_ops: NonZeroU64, ) -> Result<(Proof<H::Digest>, Vec<Operation<V>>), Error>
Analogous to proof, but with respect to the state of the MMR when it had size
elements.
Auto Trait Implementations§
impl<E, V, H> Freeze for Keyless<E, V, H>
impl<E, V, H> !RefUnwindSafe for Keyless<E, V, H>
impl<E, V, H> Send for Keyless<E, V, H>where
V: Send,
impl<E, V, H> Sync for Keyless<E, V, H>where
V: Sync,
impl<E, V, H> Unpin for Keyless<E, V, H>
impl<E, V, H> !UnwindSafe for Keyless<E, V, H>
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
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
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>
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>
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 more