pub struct GraphQueue { /* private fields */ }Expand description
Bounded MPSC queue feeding the entity-graph worker task.
Implementations§
Source§impl GraphQueue
impl GraphQueue
Sourcepub fn start(
capacity: usize,
backlog: Arc<AtomicUsize>,
system: Arc<ConversationMemorySystem>,
) -> Self
pub fn start( capacity: usize, backlog: Arc<AtomicUsize>, system: Arc<ConversationMemorySystem>, ) -> Self
Spawn the graph worker on the current Tokio runtime and return the sending handle.
system lets the worker reach the canonical
ConversationMemorySystem::apply_entity_graph_update_now helper
— extracting that body into a public method is how the worker
avoids reimplementing the load → mutate → CAS → persist flow.
Sourcepub fn submit(&self, item: GraphWorkItem) -> Result<(), PipelineError>
pub fn submit(&self, item: GraphWorkItem) -> Result<(), PipelineError>
Non-blocking submit; returns PipelineError::Backpressure if the queue is full.
Auto Trait Implementations§
impl Freeze for GraphQueue
impl RefUnwindSafe for GraphQueue
impl Send for GraphQueue
impl Sync for GraphQueue
impl Unpin for GraphQueue
impl UnsafeUnpin for GraphQueue
impl UnwindSafe for GraphQueue
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::RequestSource§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