Struct tinychain::chain::ChainBlock

pub struct ChainBlock { /* fields omitted */ }

A single filesystem block belonging to a super::Chain.

Implementations

impl ChainBlock

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

Return a new, empty block.

pub fn append(
    &mut self,
    txn_id: TxnId,
    path: TCPathBuf,
    key: Value,
    value: Scalar
)

Append an op to the contents of this ChainBlock.

pub fn mutations(&self) -> &BTreeMap<TxnId, Vec<(TCPathBuf, Value, Scalar)>>

The mutations listed in this ChainBlock.

pub fn last_hash(&self) -> &Bytes

The hash of the previous block in the chain.

Trait Implementations

impl BlockData for ChainBlock

fn ext() -> &'static str

fn hash<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = TCResult<Bytes>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn load<'async_trait, S: AsyncReadExt + Send + Unpin>(
    source: S
) -> Pin<Box<dyn Future<Output = TCResult<Self>> + Send + 'async_trait>> where
    S: 'async_trait,
    Self: 'async_trait, 

fn persist<'life0, 'life1, 'async_trait, W: AsyncWrite + Send + Unpin>(
    &'life0 self,
    sink: &'life1 mut W
) -> Pin<Box<dyn Future<Output = TCResult<u64>> + Send + 'async_trait>> where
    W: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

fn size<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = TCResult<u64>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

impl Clone for ChainBlock

fn clone(&self) -> ChainBlock

Returns a copy of the value.

pub 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 Display for ChainBlock

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

Formats the value using the given formatter.

impl Eq for ChainBlock

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: Decoder>(
    context: (),
    decoder: &'life0 mut D
) -> Pin<Box<dyn Future<Output = Result<Self, D::Error>> + Send + 'async_trait>> where
    D: 'async_trait,
    'life0: 'async_trait,
    Self: 'async_trait, 

Parse this value using the given Decoder.

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 Mutate for ChainBlock

type Pending = Self

The type of this state when pending a transaction commit.

fn diverge(&self, _txn_id: &TxnId) -> Self::Pending

Create a new transaction-specific version of this state.

fn converge<'life0, 'async_trait>(
    &'life0 mut self,
    new_value: Self::Pending
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Canonicalize a transaction-specific version.

impl PartialEq<ChainBlock> for ChainBlock

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=.

impl StructuralEq for ChainBlock

impl StructuralPartialEq for ChainBlock

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.