Struct CollectionTree 

pub struct CollectionTree<Item: Record> { /* private fields */ }

Implementations

impl<Item> CollectionTree<Item>

where Item: Record<Value = InlineArray> + Debug,

pub fn upsert( &self, id: impl Borrow<Item::SelfId> + Debug, item: &Item, ) -> DbResult<Option<Item>>

Insert or update value by id. Return old value if exist

pub fn upsert_fn<F, Ret>( &self, id: impl Borrow<Item::SelfId> + Debug, f: F, ) -> DbResult<(Option<Item>, Ret)>

where F: Fn(Option<Item>) -> (Option<Item>, Ret), Item: Clone, Ret: Debug,

Update, create or delete value by id with Fn. Can call closure multiple times.

Return new value and closure result

pub fn update_fn<F>( &self, id: impl Borrow<Item::SelfId> + Debug, f: F, ) -> DbResult<Item>

where F: FnOnce(Item) -> DbResult<Item>, Item: Clone,

Update item with closure if exist, return new value. Tried only once.

pub fn updater(&self, id: Item::SelfId) -> DbResult<Updater<Item>>

where Item: Clone,

pub fn apply_updater(&self, updater: Updater<Item>) -> DbResult<Entry<Item>>

Tried only once.

pub fn change_status( &self, old_id: &Item::SelfId, new_id: &Item::SelfId, ) -> DbResult<()>

👎Deprecated

change status in item key with closure, if key not exist, does nothing. not use for change id!

pub fn remove( &self, id: impl Borrow<Item::SelfId> + Debug, ) -> DbResult<Option<Item>>

permanently remove item. Return old value or None if not exist

pub fn remove_item( &self, id: impl Borrow<Item::SelfId> + Debug, ) -> DbResult<Option<Item>>

👎Deprecated

pub fn soft_remove( &self, id: impl Borrow<Item::SelfId> + Debug, ) -> DbResult<Option<Item>>

Remove item to other (‘removed’) tree. Return old value or None if not exist

impl<Item> CollectionTree<Item>

where Item: Record<Value = InlineArray> + Debug,

pub fn get( &self, id: impl Borrow<Item::SelfId> + Debug, ) -> DbResult<Option<Item>>

get value by id

pub fn get_item( &self, id: impl Borrow<Item::SelfId> + Debug, ) -> DbResult<Option<Item>>

👎Deprecated

pub fn get_or_err( &self, id: impl Borrow<Item::SelfId> + Debug, ) -> DbResult<Item>

get value by id or return not found

pub fn contains(&self, id: impl Borrow<Item::SelfId> + Debug) -> DbResult<bool>

check exist by id

pub fn contains_item( &self, id: impl Borrow<Item::SelfId> + Debug, ) -> DbResult<bool>

👎Deprecated

pub fn iter(&self) -> IterCollection<Entry<Item>>

get iterator for collection

pub fn scan_prefix<P>(&self, prefix: P) -> IterCollection<Entry<Item>>

where P: AsRef<[u8]> + Debug,

get iterator by prefix for collection

pub fn range_iter<K, R>(&self, range: R) -> IterCollection<Entry<Item>>

where K: AsRef<[u8]>, R: RangeBounds<K> + Debug,

get iterator by range for collection

pub fn try_range_iter<K, R>( &self, range: R, ) -> impl DoubleEndedIterator<Item = DbResult<Entry<Item>>> + use<K, R, Item>

where K: AsRef<[u8]>, R: RangeBounds<K> + Debug,

get iterator by range for collection if item error, return Error

pub fn try_range_iter_with_raw<K, R>( &self, range: R, ) -> impl DoubleEndedIterator<Item = DbResult<ItemWithRaw<Item>>> + use<K, R, Item>

where K: AsRef<[u8]>, R: RangeBounds<K> + Debug,

get iterator by range for collection if item error, return Error

pub fn iter_keys<P>( &self, prefix: P, ) -> impl DoubleEndedIterator<Item = Item::SelfId> + use<P, Item>

where P: AsRef<[u8]> + Debug,

iter without deserialize value

pub fn par_iter( &self, seq: Option<u64>, ) -> DbResult<MaybeParIter<impl IndexedParallelIterator<Item = (Iter, Self)> + '_, Iter>>

Split collection into groups for parallel processing

used rayon for parallelism

pub fn cast_slice<K: AsRef<[u8]>>( &self, id: K, ) -> DbResult<Option<BytesAsValSlice<InlineArray, Item>>>

impl<Item> CollectionTree<Item>

where Item: Record<Value = InlineArray> + Debug,

pub fn open(db: Database) -> Self

pub fn open_tree(db: Database) -> Self

👎Deprecated

pub fn with_name(db: Database, name: &str) -> Self

pub fn builder(db: Database) -> CollectionBuilder<Item>

pub fn raw(&self) -> &RawTree

pub fn close(self)

Methods from Deref<Target = RawTree>

pub fn checksum(&self) -> u32

pub fn is_empty(&self) -> bool

pub fn count(&self) -> u64

pub fn subscribe(&self) -> Receiver<ChangeEvent>

pub fn hashpoints(&self) -> CheckSumVec

pub fn scan_group( &self, group: u32, ) -> impl DoubleEndedIterator<Item = KeyValue> + use<>

pub fn recalcucate_hash(&self) -> u64

pub fn close(&self)

save seq number, type hash, version to db, flush tree

pub fn get(&self, id: &[u8]) -> DbResult<Option<Vec<u8>>>

return slice with [key + value] bytes

pub fn range( &self, range: (Bound<&[u8]>, Bound<&[u8]>), ) -> Box<dyn DoubleEndedIterator<Item = KeyValue>>

pub fn next_id(&self) -> DbResult<u64>

pub fn apply_event(&self, event: ChangeEvent) -> DbResult<()>

pub fn apply_batch( &self, iter: impl Iterator<Item = (ByteValue, Option<ByteValue>)>, ) -> DbResult<()>

Trait Implementations

impl<Item: Record> Clone for CollectionTree<Item>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Item: Record> Debug for CollectionTree<Item>

where Arc<EventHandlers<Item>>: Debug,

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

Formats the value using the given formatter.

impl<Item: Record> Deref for CollectionTree<Item>

type Target = RawTree

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<Item: Record> From<CollectionTree<Item>> for RawTree

fn from(value: CollectionTree<Item>) -> Self

Converts to this type from the input type.