Struct ContextBus 

pub struct ContextBus { /* private fields */ }

Implementations

impl ContextBus

pub fn new() -> Self

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

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

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 read( &self, workspace_id: &str, channel_id: &str, since: i64, limit: usize, ) -> Vec<ContextEventV1>

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, max_depth: usize) -> Vec<ContextEventV1>

Trace the causal lineage of an event by following parent_id chains.

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) -> ContextBus

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.