Struct ContextBus 

pub struct ContextBus { /* private fields */ }

Implementations

impl ContextBus

pub fn new() -> Self

pub fn open_at(path: PathBuf) -> Self

Open a ContextBus backed by the given SQLite path. Useful for tests that need an isolated database to avoid contention on Windows CI.

pub fn try_open_at(path: PathBuf) -> Result<Self, ObservationPersistenceError>

Open without panicking or silently substituting a different data directory.

pub fn subscribe( &self, workspace_id: &str, channel_id: &str, ) -> Option<Receiver<ContextEventV1>>

pub fn subscribe_filtered( &self, workspace_id: &str, channel_id: &str, filter: TopicFilter, ) -> Option<FilteredSubscription>

Subscribe with a filter — only events matching the filter are delivered. Returns (Receiver, TopicFilter) for use in filtered receive loops.

pub fn append( &self, workspace_id: &str, channel_id: &str, kind: &ContextEventKindV1, actor: Option<&str>, payload: Value, ) -> Option<ContextEventV1>

pub fn append_ocla_observation( &self, producer_instance: &str, record: &OclaBusRecord, ) -> Result<i64, ObservationPersistenceError>

Persist an OCLA record in the ContextBus-owned private observation table. The table is deliberately outside context_events, so normal replay, search, lineage, and subscriptions cannot expose local observations.

pub fn append_legacy_observation( &self, producer_instance: &str, event: &LeanCtxEvent, ) -> Result<i64, ObservationPersistenceError>

Persist a legacy event as a compatibility observation without appending to the immutable historical JSONL journal.

pub fn read_local_observations( &self, limit: usize, ) -> Result<Vec<LocalObservationV1>, ObservationPersistenceError>

Read private observations for regression and compatibility readers.

pub fn read_legacy_observations( &self, limit: usize, ) -> Result<Vec<LeanCtxEvent>, ObservationPersistenceError>

pub fn append_with_parent( &self, workspace_id: &str, channel_id: &str, kind: &ContextEventKindV1, actor: Option<&str>, payload: Value, parent_id: Option<i64>, ) -> Option<ContextEventV1>

pub fn append_directed( &self, workspace_id: &str, channel_id: &str, kind: &ContextEventKindV1, actor: Option<&str>, payload: Value, target_agents: Vec<String>, ) -> Option<ContextEventV1>

Append an event directed at specific agents only. Only subscribers whose TopicFilter.agent_id matches a target will see it.

pub fn read( &self, workspace_id: &str, channel_id: &str, since: i64, limit: usize, ) -> Vec<ContextEventV1>

pub fn append_delivery_once( &self, workspace_id: &str, channel_id: &str, kind: &ContextEventKindV1, actor: Option<&str>, payload: Value, delivery_id: &str, target_agents: Option<Vec<String>>, ) -> Result<bool, String>

Atomically append at most one event for an authenticated delivery ID.

target_agents scopes the event like Self::append_directed: when set, only subscribers and readers identifying as one of the targets see it, live and on replay.

pub fn recent_by_kind( &self, workspace_id: &str, channel_id: &str, kind: &str, limit: usize, ) -> Vec<ContextEventV1>

Query recent events of a specific kind (for conflict detection).

pub fn search( &self, workspace_id: &str, channel_id: Option<&str>, query: &str, limit: usize, ) -> Vec<ContextEventV1>

Full-text search over event payloads via FTS5.

pub fn lineage( &self, event_id: i64, workspace_id: &str, max_depth: usize, ) -> Vec<ContextEventV1>

Trace the causal lineage of an event by following parent_id chains. Only returns events belonging to the given workspace (tenant isolation).

pub fn latest_id(&self, workspace_id: &str, channel_id: &str) -> i64

Returns the highest event id for a workspace/channel pair, or 0 if none.

Trait Implementations

impl Clone for ContextBus

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ContextBus

fn default() -> Self

Returns the “default value” for a type.