Struct ChainBlock

pub struct ChainBlock {
    pub mutations: BTreeMap<TxnId, Vec<MutationRecord>>,
    /* private fields */
}

A single filesystem block belonging to a Chain.

Fields

mutations: BTreeMap<TxnId, Vec<MutationRecord>>

Implementations

impl ChainBlock

pub fn hash<'a, M, R>(last_hash: &'a [u8], mutations: M) -> Output<Sha256>

where M: IntoIterator<Item = (&'a TxnId, &'a R)> + 'a, &'a R: IntoIterator<Item = &'a MutationRecord> + 'a,

Compute the hash of a ChainBlock with the given contents

pub fn pending_hash<'a, M, R, P>( last_hash: &'a [u8], mutations: M, txn_id: &TxnId, pending: P, ) -> Output<Sha256>

where M: IntoIterator<Item = (&'a TxnId, &'a R)> + 'a, &'a R: IntoIterator<Item = &'a MutationRecord> + 'a, P: IntoIterator<Item = &'a MutationRecord> + 'a,

Compute the hash of a ChainBlock with the given contents and pending contents

pub fn new<H: Into<Bytes>>(hash: H) -> Self

Return a new, empty block.

pub fn with_txn<H: Into<Bytes>>(hash: H, txn_id: TxnId) -> Self

Return a new, empty block with an empty mutation list for the given TxnId.

pub fn with_mutations( hash: Bytes, mutations: BTreeMap<TxnId, Vec<MutationRecord>>, ) -> Self

Return a new, empty block with an the given mutation list for the given TxnId.

pub fn append_delete(&mut self, txn_id: TxnId, key: Value)

Append a DELETE op to this ChainBlock

pub fn append_put(&mut self, txn_id: TxnId, key: Value, value: Scalar)

Append a PUT op to the this ChainBlock

pub fn current_hash(&self) -> Output<Sha256>

The current hash of this block

pub fn last_hash(&self) -> &Bytes

The hash of the previous block in the chain

pub async fn size(&self) -> TCResult<usize>

The current size of this block

Trait Implementations

impl Clone for ChainBlock

fn clone(&self) -> ChainBlock

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ChainBlock

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

Formats the value using the given formatter.

impl FromStream for ChainBlock

type Context = ()

The decoding context of this type, useful in situations where the stream to be decoded may be too large to hold in main memory.

fn from_stream<'life0, 'async_trait, D>( context: (), decoder: &'life0 mut D, ) -> Pin<Box<dyn Future<Output = Result<Self, D::Error>> + Send + 'async_trait>>

where D: 'async_trait + Decoder, Self: 'async_trait, 'life0: 'async_trait,

Parse this value using the given Decoder.

impl GetSize for ChainBlock

fn get_size(&self) -> usize

Determines the total size of the object.

fn get_stack_size() -> usize

Determines how may bytes this object occupies inside the stack.

fn get_heap_size(&self) -> usize

Determines how many bytes this object occupies inside the heap.

impl<'en> IntoStream<'en> for ChainBlock

fn into_stream<E: Encoder<'en>>(self, encoder: E) -> Result<E::Ok, E::Error>

Take ownership of this value and serialize it into the given encoder.

impl PartialEq for ChainBlock

fn eq(&self, other: &ChainBlock) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<'en> ToStream<'en> for ChainBlock

fn to_stream<E: Encoder<'en>>(&'en self, encoder: E) -> Result<E::Ok, E::Error>

Serialize this value into the given encoder.

impl Eq for ChainBlock

impl StructuralPartialEq for ChainBlock