Struct DistributedGoalResolver 

pub struct DistributedGoalResolver { /* private fields */ }

Distributed goal resolver

Implementations

impl DistributedGoalResolver

pub fn new(local_kb: Arc<KnowledgeBase>) -> Self

Create a new distributed goal resolver

pub fn with_provider(self, provider: Arc<dyn RemoteKnowledgeProvider>) -> Self

Set the remote knowledge provider

pub fn with_max_depth(self, max_depth: usize) -> Self

Set maximum depth

pub fn with_timeout(self, timeout_ms: u64) -> Self

Set timeout in milliseconds

pub async fn resolve( &mut self, goal: &Predicate, substitution: &Substitution, ) -> Result<Vec<Substitution>, RemoteReasoningError>

Resolve a goal using both local and remote knowledge

pub async fn prefetch_facts( &mut self, predicate_name: &str, ) -> Result<usize, RemoteReasoningError>

Prefetch facts for a predicate from remote peers

pub fn get_cached_facts(&self, predicate_name: &str) -> Option<&[Predicate]>

Get cached remote facts

pub fn clear_cache(&mut self)

Clear the remote fact cache