pub struct MemoryCommitter { /* private fields */ }Expand description
Turns proposals into durable memory.
Implementations§
Source§impl MemoryCommitter
impl MemoryCommitter
Sourcepub fn new(repository: Arc<dyn MemoryRepository>) -> Self
pub fn new(repository: Arc<dyn MemoryRepository>) -> Self
A committer writing to repository.
Sourcepub fn with_events(self, events: SessionEventWriter) -> Self
pub fn with_events(self, events: SessionEventWriter) -> Self
Emit audit events alongside every commit.
Sourcepub async fn reconcile(
&self,
owner: &UserId,
output: ConsolidationOutput,
idempotency_key: &str,
) -> Result<ReconciliationReport, MemoryError>
pub async fn reconcile( &self, owner: &UserId, output: ConsolidationOutput, idempotency_key: &str, ) -> Result<ReconciliationReport, MemoryError>
Resolve and commit a session’s consolidation output.
Sourcepub async fn commit_one(
&self,
owner: &UserId,
resolved: ResolvedMutation,
) -> Result<CommitReceipt, MemoryError>
pub async fn commit_one( &self, owner: &UserId, resolved: ResolvedMutation, ) -> Result<CommitReceipt, MemoryError>
Commit a single resolved mutation, for explicit in-session commands.
Auto Trait Implementations§
impl Freeze for MemoryCommitter
impl !RefUnwindSafe for MemoryCommitter
impl Send for MemoryCommitter
impl Sync for MemoryCommitter
impl Unpin for MemoryCommitter
impl !UnwindSafe for MemoryCommitter
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
§impl<S> FromSample<S> for S
impl<S> FromSample<S> for S
fn from_sample_(s: S) -> S
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].