Struct StorageSink 

pub struct StorageSink {
    pub store: Store,
    /* private fields */
}

EventSink that persists each event into the SQLite store as execution + execution_step rows. Designed for fan-out via MultiSink alongside the Tauri-emitting sink.

Fields

store: Store

Implementations

impl StorageSink

pub fn new(store: Store) -> Self

pub fn with_flow_name(store: Store, flow_name: String) -> Self

Like StorageSink::new, but tags every persisted execution with the flow’s display name so list views (history, per-template last-run) can show which flow ran.

pub fn with_flow_name_and_trigger( store: Store, flow_name: String, trigger: String, ) -> Self

Like StorageSink::with_flow_name, but also records how the run was triggered (manual / scheduled).

Trait Implementations

impl EventSink for StorageSink

fn emit(&self, event: ExecutionEvent)