pub struct RowValues { /* private fields */ }Expand description
Column-value map for one relational read-model row.
Implementations§
Source§impl RowValues
impl RowValues
pub fn new() -> Self
pub fn insert( &mut self, column: impl Into<String>, value: RowValue, ) -> Option<RowValue>
pub fn insert_serde<T: Serialize + ?Sized>( &mut self, column: impl Into<String>, value: &T, ) -> Result<Option<RowValue>, ReadModelError>
pub fn get(&self, column: &str) -> Option<&RowValue>
pub fn contains_key(&self, column: &str) -> bool
pub fn len(&self) -> usize
pub fn is_empty(&self) -> bool
pub fn get_serde<T: DeserializeOwned>( &self, column: &str, ) -> Result<T, ReadModelError>
pub fn iter(&self) -> impl Iterator<Item = (&str, &RowValue)>
Trait Implementations§
Source§impl IntoIterator for RowValues
impl IntoIterator for RowValues
impl StructuralPartialEq for RowValues
Auto Trait Implementations§
impl Freeze for RowValues
impl RefUnwindSafe for RowValues
impl Send for RowValues
impl Sync for RowValues
impl Unpin for RowValues
impl UnsafeUnpin for RowValues
impl UnwindSafe for RowValues
Blanket Implementations§
Source§impl<T> AggregateBuilder for T
impl<T> AggregateBuilder for T
fn aggregate<A: Aggregate>(self) -> AggregateRepository<Self, A>
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Queueable for T
impl<T> Queueable for T
Source§fn queued(self) -> QueuedRepository<Self, InMemoryAsyncLockManager>
fn queued(self) -> QueuedRepository<Self, InMemoryAsyncLockManager>
Wrap with the default async lock manager. Pair with
.aggregate::<T>() for per-aggregate serialization over the async
repository surface.Source§fn queued_with<L: AsyncLockManager>(
self,
lock_manager: L,
) -> QueuedRepository<Self, L>
fn queued_with<L: AsyncLockManager>( self, lock_manager: L, ) -> QueuedRepository<Self, L>
Wrap with a custom async lock manager.