Struct KnowledgeBridge 

pub struct KnowledgeBridge {
    pub project_hash: String,
    pub shared_facts: Vec<BridgeEntry>,
    pub updated_at: DateTime<Utc>,
}

Fields

project_hash: String

shared_facts: Vec<BridgeEntry>

updated_at: DateTime<Utc>

Implementations

impl KnowledgeBridge

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

pub fn path(project_hash: &str) -> Result<PathBuf, String>

pub fn load(project_hash: &str) -> Option<Self>

pub fn load_or_create(project_hash: &str) -> Self

pub fn save(&mut self) -> Result<(), String>

pub fn mutate_locked<T>( project_hash: &str, mutate: impl FnOnce(&mut Self) -> T, ) -> Result<T, String>

One read-modify-write of a project’s bridge under its cross-process lock: loaded inside the lock, saved before it is released. Parallel publishers therefore never drop each other’s entries.

pub fn publish(&mut self, agent_id: &str, facts: &[KnowledgeFact]) -> u32

Publish eligible facts from an agent’s knowledge store. Only publishes facts with sufficient confidence, a publishable archetype, and that haven’t already been published by this agent.

pub fn pull(&self, requesting_agent: &str) -> Vec<BridgeEntry>

Pull facts from the bridge that were published by other agents.

pub fn entry_to_fact(entry: &BridgeEntry) -> KnowledgeFact

Convert a BridgeEntry into a KnowledgeFact for import. Applies a 10% trust penalty to imported confidence.

pub fn cleanup(&mut self, max_age_days: i64, min_confidence: f32) -> usize

Remove entries older than max_age_days or below min_confidence.

pub fn entries_for_agent(&self, agent_id: &str) -> Vec<&BridgeEntry>

pub fn summary(&self) -> String

Trait Implementations

impl Clone for KnowledgeBridge

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KnowledgeBridge

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for KnowledgeBridge

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for KnowledgeBridge

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.