Struct tinychain::chain::ChainBlock

pub struct ChainBlock { /* fields omitted */ }

A single filesystem block belonging to a Chain.

Implementations

impl ChainBlock

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,
    contents: BTreeMap<TxnId, Vec<Mutation>>
) -> Self

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

pub fn append(&mut self, txn_id: TxnId, mutation: Mutation)

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

Append a DELETE op to the contents of this ChainBlock.

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

Append a PUT op to the contents of this ChainBlock.

pub fn clear_until(&mut self, txn_id: &TxnId)

Delete all mutations listed in this ChainBlock prior to the given TxnId.

pub fn mutations(&self) -> &BTreeMap<TxnId, Vec<Mutation>>

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 max_size() -> u64

#[must_use]

fn hash<'en, 'async_trait>(
    &'en self
) -> Pin<Box<dyn Future<Output = Result<Bytes, TCError>> + 'async_trait + Send, Global>> where
    'en: 'async_trait,
    Self: ToStream<'en> + 'async_trait, 

#[must_use]

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

#[must_use]

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

#[must_use]

fn into_size<'en, 'async_trait>(
    self
) -> Pin<Box<dyn Future<Output = Result<u64, TCError>> + 'async_trait + Send, Global>> where
    'en: 'async_trait,
    Self: Clone + IntoStream<'en> + 'en + 'async_trait, 

#[must_use]

fn size<'en, 'async_trait>(
    &'en self
) -> Pin<Box<dyn Future<Output = Result<u64, TCError>> + 'async_trait + Send, Global>> where
    'en: 'async_trait,
    Self: ToStream<'en> + 'async_trait, 

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 Display 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: 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<'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 StructuralEq for ChainBlock

impl StructuralPartialEq for ChainBlock