Struct CollectionWriter 

pub struct CollectionWriter<S: Store, T> { /* private fields */ }

Implementations

impl<S: Store, T> CollectionWriter<S, T>

pub fn new(store: Arc<S>, definition: CollectionDefinition<T>) -> Self

pub fn with_options( store: Arc<S>, definition: CollectionDefinition<T>, options: CollectionOptions, ) -> Self

pub fn with_state( store: Arc<S>, definition: CollectionDefinition<T>, state: CollectionState, ) -> Self

pub fn with_state_and_options( store: Arc<S>, definition: CollectionDefinition<T>, state: CollectionState, options: CollectionOptions, ) -> Self

pub async fn from_root( store: Arc<S>, definition: CollectionDefinition<T>, root: Option<&Cid>, options: CollectionOptions, ) -> Result<Self, CollectionError>

pub fn snapshot(&self) -> CollectionState

pub fn state(&self) -> &CollectionState

pub async fn write_root(&self) -> Result<Option<Cid>, CollectionError>

impl<S: Store, T: Clone> CollectionWriter<S, T>

pub fn normalize(&self, item: &T) -> Result<T, CollectionError>

pub async fn put( &mut self, item: &T, cid: &Cid, previous: Option<&T>, ) -> Result<CollectionState, CollectionError>

pub async fn replace( &mut self, item: &T, cid: &Cid, previous: &T, ) -> Result<CollectionState, CollectionError>

pub async fn put_with_context( &mut self, item: &T, cid: &Cid, previous: Option<&T>, context: Option<&CollectionWriteContext>, previous_context: Option<&CollectionWriteContext>, ) -> Result<CollectionState, CollectionError>

pub async fn replace_with_context( &mut self, item: &T, cid: &Cid, previous: &T, context: Option<&CollectionWriteContext>, previous_context: Option<&CollectionWriteContext>, ) -> Result<CollectionState, CollectionError>

pub async fn delete( &mut self, item: &T, ) -> Result<CollectionState, CollectionError>

pub async fn delete_with_context( &mut self, item: &T, context: Option<&CollectionWriteContext>, ) -> Result<CollectionState, CollectionError>

pub async fn rebuild<I>( &mut self, entries: I, ) -> Result<CollectionState, CollectionError>

where I: IntoIterator<Item = (T, Cid)>,

pub async fn reindex<I>( &mut self, entries: I, ) -> Result<CollectionState, CollectionError>

where I: IntoIterator<Item = (T, Cid)>,

pub async fn rebuild_with_context<I>( &mut self, entries: I, ) -> Result<CollectionState, CollectionError>

where I: IntoIterator<Item = (T, Cid, Option<CollectionWriteContext>)>,

pub async fn reindex_with_context<I>( &mut self, entries: I, ) -> Result<CollectionState, CollectionError>

where I: IntoIterator<Item = (T, Cid, Option<CollectionWriteContext>)>,