Struct DistributedReasoner 

pub struct DistributedReasoner { /* private fields */ }

Distributed reasoning engine with caching support

Implementations

impl DistributedReasoner

pub fn new() -> Result<Self>

Create a new distributed reasoner

pub fn with_cache(cache: Arc<CacheManager>) -> Result<Self>

Create with a cache manager

pub async fn query( &self, goal: &Predicate, kb: &KnowledgeBase, ) -> Result<Vec<Substitution>>

Query locally with optional caching

pub async fn prove( &self, goal: &Predicate, kb: &KnowledgeBase, ) -> Result<Option<Proof>>

Prove a goal with goal decomposition tracking

pub async fn prove_with_decomposition( &mut self, goal: &Predicate, kb: &KnowledgeBase, ) -> Result<(Option<Proof>, Vec<GoalDecomposition>)>

Prove with goal decomposition tracking

pub fn get_unsolved_goals(&self) -> Vec<&Predicate>

Get unsolved goals that could be forwarded to peers

pub fn cache_stats(&self) -> Option<CombinedCacheStats>

Get cache statistics (if cache is available)

Trait Implementations

impl Default for DistributedReasoner

fn default() -> Self

Returns the “default value” for a type.