Struct LogSinkCardSubscriber 

pub struct LogSinkCardSubscriber { /* private fields */ }

Fan-out CardEvents into per-session LogSink ring buffers.

Process-wide singleton accessed via log_sink_subscriber. Each Session registers its own LogSink on start-up via register_log_sink and unregisters on Drop of the returned LogSinkRegistration guard.

Concurrency

Send + Sync. Internal state is Mutex<Vec<(u64, LogSink)>> + AtomicU64. on_event uses the same snapshot-clone-then-iterate pattern as CardEventBus::publish: sinks are cloned under the lock then iterated with the lock released, so registrations/unregistrations from other threads never deadlock a fan-out in flight. The mutex uses the crate-wide unwrap_or_else(|p| p.into_inner()) policy so a poisoned lock never propagates a panic.

Implementations

impl LogSinkCardSubscriber

pub const URI: &'static str = "log-sink://alc.card"

Fixed subscriber URI used by CardEventBus to key SubscriberStats and to guard against duplicate registration.

Trait Implementations

impl CardSubscriber for LogSinkCardSubscriber

fn on_event(&self, ev: &CardEvent) -> Result<(), String>

Always returns Ok(()).

Snapshots the sink list under sinks.lock(), releases the lock, then pushes a LogEntry { source: "alc.card", level: "info", message: <fmt> } into every snapshotted LogSink. Individual LogSink::push failures (poisoned per-sink mutex) are silently dropped, matching the ring-buffer best-effort policy in algocline_core::recent_log.

Concurrency

Cancel-safe (no .await). Safe to call from any thread. Does not hold self.sinks across the fan-out loop, so re-entrant registration from within a LogSink::push implementation (currently impossible) would still not deadlock.

fn describe(&self) -> String

Returns the fixed subscriber URI "log-sink://alc.card".

Used by CardEventBus to key SubscriberStats and by log_sink_subscriber initializer to guard against duplicate registration on the bus.

fn has_card(&self, _card_id: &str) -> Result<bool, String>

Best-effort check for whether card_id already exists in this subscriber. Used by alc_card_sink_backfill to skip cards that are already mirrored (drift-safe: we never overwrite).

impl Debug for LogSinkCardSubscriber

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

Formats the value using the given formatter.