Struct linera_views::batch::UnorderedBatch

pub struct UnorderedBatch {
    pub key_prefix_deletions: Vec<Vec<u8>>,
    pub simple_unordered_batch: SimpleUnorderedBatch,
}

An unordered batch of deletions and insertions, together with a set of key-prefixes to delete. Key-prefix deletions must happen before the insertions and the deletions.

Fields

key_prefix_deletions: Vec<Vec<u8>>

The key-prefix deletions.

simple_unordered_batch: SimpleUnorderedBatch

The batch of deletions and insertions.

Implementations

impl UnorderedBatch

pub async fn expand_delete_prefixes<DB: DeletePrefixExpander>( self, db: &DB, ) -> Result<SimpleUnorderedBatch, DB::Error>

From an UnorderedBatch, creates a SimpleUnorderedBatch that does not contain the key_prefix_deletions. This requires accessing the database to eliminate them.

pub async fn expand_colliding_prefix_deletions<DB: DeletePrefixExpander>( &mut self, db: &DB, ) -> Result<(), DB::Error>

Modifies an UnorderedBatch so that the key-prefix deletions do not conflict with subsequent insertions. This may require accessing the database to compute lists of deleted keys.

pub fn len(&self) -> usize

The total number of entries of the batch.

pub fn is_empty(&self) -> bool

Tests whether the batch is empty or not

Trait Implementations

impl BatchValueWriter<UnorderedBatch> for UnorderedBatchIter

fn is_empty(&self) -> bool

Returns true if there are no more values to write.

fn write_next_value( &mut self, batch: &mut UnorderedBatch, batch_size: &mut usize, ) -> Result<bool, Error>

Writes the next value (if any) to the batch and updates the batch size accordingly.

fn next_batch_size( &mut self, batch: &UnorderedBatch, batch_size: usize, ) -> Result<Option<usize>, Error>

Computes the batch size that we would obtain if we wrote the next value (if any) without consuming the value.

impl Default for UnorderedBatch

fn default() -> UnorderedBatch

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for UnorderedBatch

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for UnorderedBatch

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl SimplifiedBatch for UnorderedBatch

type Iter = UnorderedBatchIter

The iterator type used to process values from the batch.

fn into_iter(self) -> Self::Iter

Returns an owning iterator over the values in the batch.

fn len(&self) -> usize

Returns the total number of entries in the batch.

fn num_bytes(&self) -> usize

Returns the total number of bytes in the batch.

fn overhead_size(&self) -> usize

Returns the overhead size of the batch.

fn add_delete(&mut self, key: Vec<u8>)

Adds the deletion of key to the batch.

fn add_insert(&mut self, key: Vec<u8>, value: Vec<u8>)

Adds the insertion of a key-value pair to the batch.

fn from_batch<'async_trait, S>( store: S, batch: Batch, ) -> Pin<Box<dyn Future<Output = Result<Self, S::Error>> + Send + 'async_trait>>

where S: 'async_trait + DeletePrefixExpander + Send + Sync, Self: 'async_trait,

Creates a simplified batch from a standard one.

fn is_empty(&self) -> bool

Returns true if the batch is empty.