pub enum BufferedWrite {
SaveMessage {
conversation_id: ConversationId,
role: String,
content: String,
tier: MemoryTier,
},
UpsertPersonaFact {
category: String,
content: String,
confidence: f64,
source_conversation_id: Option<i64>,
supersedes_id: Option<i64>,
},
StoreEmbedding {
collection: String,
point_id: String,
vector: Vec<f32>,
payload: Value,
},
}Expand description
A single buffered write operation waiting to be flushed to the store.
Variants§
SaveMessage
Save a message to the messages table.
UpsertPersonaFact
Upsert a persona fact.
Fields
StoreEmbedding
Store an embedding in the vector backend (dispatched after SQLite commit).
Auto Trait Implementations§
impl Freeze for BufferedWrite
impl RefUnwindSafe for BufferedWrite
impl Send for BufferedWrite
impl Sync for BufferedWrite
impl Unpin for BufferedWrite
impl UnsafeUnpin for BufferedWrite
impl UnwindSafe for BufferedWrite
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
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§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 moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request