Struct MySemanticEngine 

pub struct MySemanticEngine {
    pub storage_path: String,
    pub stores: Arc<DashMap<String, Arc<SynapseStore>>>,
    pub auth: Arc<NamespaceAuth>,
    pub audit: Arc<InferenceAudit>,
    pub scenario_manager: Arc<ScenarioManager>,
}

Fields

storage_path: String

stores: Arc<DashMap<String, Arc<SynapseStore>>>

auth: Arc<NamespaceAuth>

audit: Arc<InferenceAudit>

scenario_manager: Arc<ScenarioManager>

Implementations

impl MySemanticEngine

pub fn new(storage_path: &str) -> Self

pub async fn install_scenario( &self, name: &str, namespace: &str, ) -> Result<String, String>

pub async fn shutdown(&self)

pub fn get_store(&self, namespace: &str) -> Result<Arc<SynapseStore>, Status>

Trait Implementations

impl Clone for MySemanticEngine

fn clone(&self) -> MySemanticEngine

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl SemanticEngine for MySemanticEngine

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

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

Ingests a batch of triples

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

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

Ingests a file (CSV, Markdown)

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

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

Queries the graph (Basic traversal for now)

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,

Vector Search (Placeholder for hybrid query)

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

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

Resolves a string URI to a Node ID

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

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

Get all stored triples (for graph visualization)

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

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

Executes a SPARQL query

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

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

Deletes all data associated with a namespace

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

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

Hybrid search combining vector similarity and graph traversal

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

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

Applies automated reasoning to a namespace