Struct KnowledgeServiceImpl 

pub struct KnowledgeServiceImpl { /* private fields */ }

gRPC service implementation for the knowledge base.

Implementations

impl KnowledgeServiceImpl

pub fn new(kb: KnowledgeBase) -> Self

Create a new service instance.

pub fn from_shared(kb: Arc<RwLock<KnowledgeBase>>) -> Self

Create from shared knowledge base.

Trait Implementations

impl KnowledgeService for KnowledgeServiceImpl

type SearchStreamStream = ReceiverStream<Result<SearchResult, Status>>

Server streaming response type for the SearchStream method.

fn add_entry<'life0, 'async_trait>( &'life0 self, request: Request<AddEntryRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<AddEntryResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Add a new knowledge entry

fn add_entries<'life0, 'async_trait>( &'life0 self, request: Request<AddEntriesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<AddEntriesResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Add multiple entries in batch

fn get_entry<'life0, 'async_trait>( &'life0 self, request: Request<GetEntryRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetEntryResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get an entry by ID

fn update_entry<'life0, 'async_trait>( &'life0 self, request: Request<UpdateEntryRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateEntryResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Update an existing entry

fn delete_entry<'life0, 'async_trait>( &'life0 self, request: Request<DeleteEntryRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteEntryResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete an entry

fn search<'life0, 'async_trait>( &'life0 self, request: Request<SearchRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SearchResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Search for similar entries

fn search_stream<'life0, 'async_trait>( &'life0 self, request: Request<SearchRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::SearchStreamStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stream search results

fn record_feedback<'life0, 'async_trait>( &'life0 self, request: Request<FeedbackRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<FeedbackResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Record user feedback on a result

fn get_related<'life0, 'async_trait>( &'life0 self, request: Request<GetRelatedRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetRelatedResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get related entries

fn link_entries<'life0, 'async_trait>( &'life0 self, request: Request<LinkEntriesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<LinkEntriesResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Link two entries as related

fn get_stats<'life0, 'async_trait>( &'life0 self, _request: Request<GetStatsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetStatsResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get knowledge base statistics

fn health<'life0, 'async_trait>( &'life0 self, _request: Request<HealthRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<HealthResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Health check