Enum tc_btree::BTree

pub enum BTree<F, D, T> {
    File(BTreeFile<F, D, T>),
    Slice(BTreeSlice<F, D, T>),
}

A stateful, transaction-aware, ordered collection of Keys with O(log n) inserts and slicing

Variants

File(BTreeFile<F, D, T>)

Slice(BTreeSlice<F, D, T>)

Trait Implementations

impl<F: File<Node>, D: Dir, T: Transaction<D>> BTreeInstance for BTree<F, D, T> where
    Self: 'static, 

type Slice = Self

fn collator(&self) -> &ValueCollator

Return a reference to this BTree’s collator.

fn schema(&self) -> &RowSchema

Return a reference to this BTree’s schema.

fn slice(self, range: Range, reverse: bool) -> TCResult<Self>

Return a slice of this BTree’s with the given range.

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

Return true if this BTree has no Keys.

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

Delete all the Keys in this BTree.

fn insert<'life0, 'async_trait>(
    &'life0 self,
    txn_id: TxnId,
    key: Key
) -> Pin<Box<dyn Future<Output = TCResult<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Insert the given Key into this BTree.

fn keys<'a, 'async_trait>(
    self,
    txn_id: TxnId
) -> Pin<Box<dyn Future<Output = TCResult<TCTryStream<'a, Key>>> + Send + 'async_trait>> where
    Self: 'a,
    'a: 'async_trait,
    Self: 'async_trait, 

Return a Stream of this BTree’s Keys.

#[must_use]

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

Return the number of Keys in this BTree.

#[must_use]

fn try_insert_from<'life0, 'async_trait, S: Stream<Item = TCResult<Key>> + Send + Unpin>(
    &'life0 self,
    txn_id: TxnId,
    keys: S
) -> Pin<Box<dyn Future<Output = TCResult<()>> + Send + 'async_trait>> where
    S: 'async_trait,
    'life0: 'async_trait,
    Self: Sync + 'async_trait, 

Insert all the keys from the given Stream into this BTree.

impl<F: Clone, D: Clone, T: Clone> Clone for BTree<F, D, T>

fn clone(&self) -> BTree<F, D, T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<F, D, T> Display for BTree<F, D, T>

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

Formats the value using the given formatter.

impl<F, D, T> From<BTreeFile<F, D, T>> for BTree<F, D, T>

fn from(btree: BTreeFile<F, D, T>) -> Self

Performs the conversion.

impl<F, D, T> From<BTreeSlice<F, D, T>> for BTree<F, D, T>

fn from(btree: BTreeSlice<F, D, T>) -> Self

Performs the conversion.

impl<F: File<Node>, D: Dir, T: Transaction<D>> FromStream for BTree<F, D, T> where
    Self: Send + Sync + 'static, 

type Context = (T, F)

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

Parse this value using the given Decoder.

impl<'en, F: File<Node>, D: Dir, T: Transaction<D>> Hash<'en, D> for BTree<F, D, T>

type Item = Key

type Txn = T

fn hashable<'async_trait>(
    &'en self,
    txn: &'en T
) -> Pin<Box<dyn Future<Output = TCResult<TCTryStream<'en, Self::Item>>> + Send + 'async_trait>> where
    'en: 'async_trait,
    Self: 'async_trait, 

#[must_use]

fn hash_hex<'async_trait>(
    &'en self,
    txn: &'en Self::Txn
) -> Pin<Box<dyn Future<Output = Result<String, TCError>> + 'async_trait + Send, Global>> where
    'en: 'async_trait,
    Self: Sync + 'async_trait, 

#[must_use]

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

impl<F: Send + Sync, D: Send + Sync, T: Send + Sync> Instance for BTree<F, D, T>

type Class = BTreeType

The Class type of this instance

fn class(&self) -> BTreeType

Returns the [Class] of this instance.

impl<'en, F: File<Node>, D: Dir, T: Transaction<D>> IntoView<'en, D> for BTree<F, D, T> where
    Self: 'static, 

type Txn = T

type View = BTreeView<'en>

fn into_view<'async_trait>(
    self,
    txn: T
) -> Pin<Box<dyn Future<Output = TCResult<BTreeView<'en>>> + Send + 'async_trait>> where
    Self: 'async_trait,