pub struct StorageMutationAuthority<W: WalWriter, P: MutationProjection> { /* private fields */ }Expand description
Storage-owned implementation of the mutation authority lane.
Implementations§
Source§impl<W: WalWriter, P: MutationProjection> StorageMutationAuthority<W, P>
impl<W: WalWriter, P: MutationProjection> StorageMutationAuthority<W, P>
Sourcepub fn new(wal_writer: W, projection: P) -> Self
pub fn new(wal_writer: W, projection: P) -> Self
Creates a new storage authority with an owned WAL writer and projection.
Sourcepub fn projection(&self) -> &P
pub fn projection(&self) -> &P
Returns the projection used by this authority.
Sourcepub fn projection_mut(&mut self) -> &mut P
pub fn projection_mut(&mut self) -> &mut P
Returns the mutable projection used by this authority.
Sourcepub fn into_parts(self) -> (W, P)
pub fn into_parts(self) -> (W, P)
Decomposes the authority into its owned parts.
Trait Implementations§
Source§impl<W: Debug + WalWriter, P: Debug + MutationProjection> Debug for StorageMutationAuthority<W, P>
impl<W: Debug + WalWriter, P: Debug + MutationProjection> Debug for StorageMutationAuthority<W, P>
Source§impl<W: WalWriter, P: MutationProjection> MutationAuthority for StorageMutationAuthority<W, P>
impl<W: WalWriter, P: MutationProjection> MutationAuthority for StorageMutationAuthority<W, P>
Source§type Error = MutationAuthorityError<<P as MutationProjection>::Error>
type Error = MutationAuthorityError<<P as MutationProjection>::Error>
Typed implementation error.
Source§fn submit_command(
&mut self,
command: MutationCommand,
durability: DurabilityPolicy,
) -> Result<MutationOutcome, Self::Error>
fn submit_command( &mut self, command: MutationCommand, durability: DurabilityPolicy, ) -> Result<MutationOutcome, Self::Error>
Submit a semantic mutation command through the authority lane.
Auto Trait Implementations§
impl<W, P> Freeze for StorageMutationAuthority<W, P>
impl<W, P> RefUnwindSafe for StorageMutationAuthority<W, P>where
W: RefUnwindSafe,
P: RefUnwindSafe,
impl<W, P> Send for StorageMutationAuthority<W, P>
impl<W, P> Sync for StorageMutationAuthority<W, P>
impl<W, P> Unpin for StorageMutationAuthority<W, P>
impl<W, P> UnsafeUnpin for StorageMutationAuthority<W, P>where
W: UnsafeUnpin,
P: UnsafeUnpin,
impl<W, P> UnwindSafe for StorageMutationAuthority<W, P>where
W: UnwindSafe,
P: UnwindSafe,
Blanket Implementations§
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