Struct TxRwImpl

pub struct TxRwImpl<'tx> { /* private fields */ }

Read/Write Transaction

Trait Implementations

impl<'tx> Drop for TxRwImpl<'tx>

fn drop(&mut self)

Executes the destructor for this type.

impl<'tx: 'a, 'a> IntoIterator for &'a TxRwImpl<'tx>

type Item = (&'a [u8], BucketImpl<'tx, 'a>)

The type of the elements being iterated over.

type IntoIter = BucketIter<'tx, 'a>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.

impl<'tx: 'a, 'a> IntoIterator for &'a mut TxRwImpl<'tx>

type Item = (&'a [u8], BucketRwImpl<'tx, 'a>)

The type of the elements being iterated over.

type IntoIter = BucketIterMut<'tx, 'a>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.

impl<'tx> TxApi<'tx> for TxRwImpl<'tx>

fn id(&self) -> TxId

Returns the transaction id.

fn size(&self) -> u64

Returns current database size in bytes as seen by this transaction.

fn writable(&self) -> bool

Returns whether the transaction can perform write operations.

fn cursor<'a>(&'a self) -> CursorImpl<'tx, 'a>

Creates a cursor associated with the root bucket. All items in the cursor will return None value because all root bucket keys point to buckets.

fn stats(&self) -> Arc<TxStats>

Retrieves a copy of the current transaction statistics.

fn bucket<'a, T: AsRef<[u8]>>(&'a self, name: T) -> Option<BucketImpl<'tx, 'a>>

Retrieves a bucket by name. Returns None if the bucket does not exist.

fn bucket_path<'a, T: AsRef<[u8]>>( &'a self, names: &[T], ) -> Option<BucketImpl<'tx, 'a>>

fn for_each<'a, F: FnMut(&'a [u8], BucketImpl<'tx, 'a>) -> Result<()>>( &self, f: F, ) -> Result<()>

where 'tx: 'a,

👎Deprecated since 1.3.9: please use iter_* methods instead

Executes a function for each key/value pair in a bucket. Because ForEach uses a Cursor, the iteration over keys is in lexicographical order.

fn page(&self, id: PgId) -> Option<PageInfo>

Returns page information for a given page number.

fn iter_buckets<'a>(&'a self) -> BucketIter<'tx, 'a>

impl<'tx> TxRwApi<'tx> for TxRwImpl<'tx>

fn rollback(self) -> Result<()>

Closes the transaction and ignores all previous updates.

fn commit(self) -> Result<()>

commit writes all changes to disk and updates the meta page. Returns an error if a disk write error occurs

impl<'tx> TxRwRefApi<'tx> for TxRwImpl<'tx>

fn bucket_mut<'a, T: AsRef<[u8]>>( &'a mut self, name: T, ) -> Option<BucketRwImpl<'tx, 'a>>

Retrieves a mutable bucket by name.

fn bucket_mut_path<'a, T: AsRef<[u8]>>( &'a mut self, names: &[T], ) -> Option<BucketRwImpl<'tx, 'a>>

fn create_bucket<'a, T: AsRef<[u8]>>( &'a mut self, name: T, ) -> Result<BucketRwImpl<'tx, 'a>>

Creates a new bucket.

fn create_bucket_if_not_exists<'a, T: AsRef<[u8]>>( &'a mut self, name: T, ) -> Result<BucketRwImpl<'tx, 'a>>

Creates a new bucket if it doesn’t already exist.

fn create_bucket_path<'a, T: AsRef<[u8]>>( &'a mut self, names: &[T], ) -> Result<BucketRwImpl<'tx, 'a>>

fn delete_bucket<T: AsRef<[u8]>>(&mut self, name: T) -> Result<()>

DeleteBucket deletes a bucket. Returns an error if the bucket cannot be found or if the key represents a non-bucket value.

fn on_commit<F: FnOnce() + 'tx>(&mut self, f: F)

OnCommit adds a handler function to be executed after the transaction successfully commits.

fn iter_mut_buckets<'a>(&'a mut self) -> BucketIterMut<'tx, 'a>