Struct CrossShellActivityFanout 

pub struct CrossShellActivityFanout { /* private fields */ }

Read-only fanout projection for CrossShellActivity. Stores cross-shell notifications keyed by the target shell — never touches the source shell’s rows, preserving shell isolation (E-act-2 RA tier).

Implementations

impl CrossShellActivityFanout

pub fn new() -> Self

Construct a fresh fanout, pre-wired to observe CrossShellActivity.

pub fn notifications_for(&self, shell: &ShellId) -> &[CrossShellActivity]

Borrow the notification queue for a shell (read-only).

Trait Implementations

impl Debug for CrossShellActivityFanout

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

Formats the value using the given formatter.

impl Default for CrossShellActivityFanout

fn default() -> Self

Returns the “default value” for a type.

impl Projection for CrossShellActivityFanout

fn observes(&self) -> &[TypeCode]

TypeCodes this projection observes — the router filters incoming events against this slice.

fn on_event( &mut self, event: &EventRecord, _ctx: &ProjectionContext<'_>, ) -> Result<(), ProjectionError>

Apply an event. Called only after router-side dedup + gap checks have succeeded. Implementations must:

fn last_applied(&self) -> Option<(u64, Tick)>

Last (sequence, tick) applied — None if the projection is fresh.

fn on_state_change( &mut self, _new_state: ObserverState, ) -> Result<(), ProjectionError>

React to a worker-state transition (Passive ↔ Active ↔ Draining). Default is no-op.