pub struct ReadModelSchemaRegistry { /* private fields */ }Expand description
Registry of table-mapped read-model schemas an adapter should manage.
Implementations§
Source§impl ReadModelSchemaRegistry
impl ReadModelSchemaRegistry
pub fn new() -> Self
pub fn register<M>(&mut self) -> Result<&mut Self, ReadModelError>where
M: RelationalReadModel,
pub fn register_schema( &mut self, schema: ReadModelSchema, ) -> Result<&mut Self, ReadModelError>
pub fn len(&self) -> usize
pub fn is_empty(&self) -> bool
pub fn schemas(&self) -> impl Iterator<Item = &ReadModelSchema>
pub fn table_names(&self) -> impl Iterator<Item = &str>
pub fn schema_for_table(&self, table_name: &str) -> Option<&ReadModelSchema>
pub fn schema_for_model(&self, model_name: &str) -> Option<&ReadModelSchema>
pub fn validate(&self) -> Result<(), ReadModelError>
Trait Implementations§
Source§impl Clone for ReadModelSchemaRegistry
impl Clone for ReadModelSchemaRegistry
Source§fn clone(&self) -> ReadModelSchemaRegistry
fn clone(&self) -> ReadModelSchemaRegistry
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for ReadModelSchemaRegistry
impl Debug for ReadModelSchemaRegistry
Source§impl Default for ReadModelSchemaRegistry
impl Default for ReadModelSchemaRegistry
Source§fn default() -> ReadModelSchemaRegistry
fn default() -> ReadModelSchemaRegistry
Returns the “default value” for a type. Read more
impl Eq for ReadModelSchemaRegistry
Source§impl PartialEq for ReadModelSchemaRegistry
impl PartialEq for ReadModelSchemaRegistry
Source§fn eq(&self, other: &ReadModelSchemaRegistry) -> bool
fn eq(&self, other: &ReadModelSchemaRegistry) -> bool
Tests for
self and other values to be equal, and is used by ==.impl StructuralPartialEq for ReadModelSchemaRegistry
Source§impl TableSchemaRegistryExt for TableSchemaRegistry
impl TableSchemaRegistryExt for TableSchemaRegistry
fn register_table<M>(&mut self) -> Result<&mut Self, TableStoreError>where
M: TableModel,
Auto Trait Implementations§
impl Freeze for ReadModelSchemaRegistry
impl RefUnwindSafe for ReadModelSchemaRegistry
impl Send for ReadModelSchemaRegistry
impl Sync for ReadModelSchemaRegistry
impl Unpin for ReadModelSchemaRegistry
impl UnsafeUnpin for ReadModelSchemaRegistry
impl UnwindSafe for ReadModelSchemaRegistry
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, InMemoryLockManager>
fn queued(self) -> QueuedRepository<Self, InMemoryLockManager>
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: LockManager>(
self,
lock_manager: L,
) -> QueuedRepository<Self, L>
fn queued_with<L: LockManager>( self, lock_manager: L, ) -> QueuedRepository<Self, L>
Wrap with a custom async lock manager.