pub struct CognitionServiceImpl {
pub state: Arc<AppState>,
}Expand description
gRPC service implementation for cognitive memory operations.
Fields§
§state: Arc<AppState>Trait Implementations§
Source§impl CognitionService for CognitionServiceImpl
impl CognitionService for CognitionServiceImpl
Source§type StreamCognitionStream = Pin<Box<dyn Stream<Item = Result<CognitionAlert, Status>> + Send>>
type StreamCognitionStream = Pin<Box<dyn Stream<Item = Result<CognitionAlert, Status>> + Send>>
Server streaming response type for the StreamCognition method.
Source§fn stream_cognition<'life0, 'async_trait>(
&'life0 self,
request: Request<Streaming<CognitionRequest>>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamCognitionStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn stream_cognition<'life0, 'async_trait>(
&'life0 self,
request: Request<Streaming<CognitionRequest>>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamCognitionStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Bidirectional streaming RPC. The client sends a stream of cognition
requests (tokens, known facts, control signals) and receives a stream
of alerts (contradictions, reinforcements, corrections, forgotten).
Auto Trait Implementations§
impl !RefUnwindSafe for CognitionServiceImpl
impl !UnwindSafe for CognitionServiceImpl
impl Freeze for CognitionServiceImpl
impl Send for CognitionServiceImpl
impl Sync for CognitionServiceImpl
impl Unpin for CognitionServiceImpl
impl UnsafeUnpin for CognitionServiceImpl
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<T> ErasedDestructor for Twhere
T: 'static,
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