kowalski-core 1.2.0

Kowalski Core Module: A Rust-based agent for interacting with Ollama models
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

//! Multi-agent federation: ACL messages, in-process broker, registry.
//!
//! Start with [`MpscBroker`] + [`AgentRegistry`] in one process; Postgres `LISTEN`/`NOTIFY`
//! can mirror the same [`AclEnvelope`] JSON later.

mod acl;
mod broker;
mod orchestrator;
mod persist;
#[cfg(feature = "postgres")]
mod pg_broker;
mod registry;

pub use acl::{
    ABSOLUTE_MAX_DELEGATION_DEPTH, AclEnvelope, AclMessage, DEFAULT_MAX_DELEGATION_DEPTH,
    check_delegate_depth,
};
pub use broker::{MessageBroker, MpscBroker};
pub use orchestrator::{DelegationOutcome, FederationOrchestrator};
#[cfg(feature = "postgres")]
pub use persist::{AgentStateSnapshot, load_agent_states};
pub use persist::{
    delete_federation_agent, load_registry_into, mark_stale_agents_inactive,
    set_agent_current_task, touch_agent_heartbeat, upsert_agent_state_for_record,
    upsert_registry_record,
};
#[cfg(feature = "postgres")]
pub use pg_broker::{
    PgBroker, bridge_postgres_notify_to_mpsc, bridge_postgres_notify_to_mpsc_pool, pg_pool_connect,
};
pub use registry::{AgentRecord, AgentRegistry};