Struct Engine 

pub struct Engine { /* private fields */ }

The envoy coordination engine — wraps sqlitegraph’s graph database and pub/sub Publisher for agent-oriented coordination.

Uses sqlitegraph 2.2.0’s indexed kind-based lookups (find_entity_by_kind_and_name, find_entities_by_kind) for O(1) entity resolution without in-memory caches.

Implementations

impl Engine

pub fn open(path: &str) -> Result<Self>

Open (or create) an envoy database backed by sqlitegraph.

pub fn open_in_memory() -> Result<Self>

Open an in-memory engine for testing.

pub fn publisher(&self) -> &Publisher

Access the underlying sqlitegraph Publisher for real-time event listeners.

pub fn graph(&self) -> &SqliteGraph

Access the underlying sqlitegraph for direct graph operations.

pub fn create_channel(&self, name: &str, description: &str) -> Result<Channel>

pub fn get_channel(&self, name: &str) -> Result<Channel>

pub fn get_channel_by_id(&self, id: i64) -> Result<Channel>

pub fn list_channels(&self) -> Result<Vec<Channel>>

pub fn publish( &self, channel_name: &str, sender: &str, payload: EventPayload, ) -> Result<Event>

pub fn replay( &self, channel_name: &str, since_sequence: i64, limit: Option<i64>, ) -> Result<Vec<Event>>

pub fn catch_up(&self, agent_id: &str, channel_name: &str) -> Result<Vec<Event>>

pub fn subscribe( &self, agent_id: &str, channel_name: &str, ) -> Result<Subscription>

pub fn unsubscribe(&self, agent_id: &str, channel_name: &str) -> Result<()>

pub fn get_subscription( &self, agent_id: &str, channel_name: &str, ) -> Result<Subscription>

pub fn list_subscriptions(&self, agent_id: &str) -> Result<Vec<Subscription>>

pub fn status(&self) -> Result<EngineStats>