Struct SqliteSink 

pub struct SqliteSink { /* private fields */ }

Zero-config default sink. Always available, no setup required, so “storage on by default” is actually true out of the box.

Implementations

impl SqliteSink

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

Trait Implementations

impl SignalSink for SqliteSink

fn record(&self, signal: &Signal) -> Result<(), SignalError>

Stores a signal that is about to be delivered.

fn complete( &self, signal: &Signal, result: &DeliveryResult, ) -> Result<(), SignalError>

Stores the delivery outcome, including result.deliveries. Must also work when record failed or never ran for this signal, so the outcome is never lost.

fn provider_outcome( &self, signal: &Signal, outcome: &ProviderOutcome, ) -> Result<(), SignalError>

Stores one provider’s outcome while delivery is still running: pending before its first attempt, then delivered or failed. A fan-out cut short by a timeout or an exit then still shows which providers already have the signal. Sinks that only keep the overall outcome can leave this as is.