Struct SqliteEventStore 

pub struct SqliteEventStore { /* private fields */ }

EventStore 的 SQLite 具体实现。

Implementations

impl SqliteEventStore

pub fn open( db_path: impl Into<PathBuf>, commit_mode: CommitMode, ) -> Result<Arc<Self>>

打开（或创建）数据库并初始化表结构与 PRAGMA。

Examples found in repository

examples/01_runtime_with_persistence.rs (lines 18-21)

async fn main() -> ForgeResult<()> {
    // 1) 构造事件存储（SQLite WAL）
    let store = SqliteEventStore::open(
        "./data/persistence_demo.sqlite",
        CommitMode::AsyncDurable { group_window_ms: 8 },
    )?;

    // 2) 配置持久化选项（定期快照）
    let persist_opts = PersistOptions {
        commit_mode: CommitMode::AsyncDurable { group_window_ms: 8 },
        snapshot_every_n_events: 1000,
        snapshot_every_bytes: 8 * 1024 * 1024,
        snapshot_every_ms: 5 * 60 * 1000,
        compression: true,
    };

    // 3) 注入持久化订阅者（由事件驱动持久化与快照）
    let subscriber = Arc::new(SnapshotSubscriber::new(
        store.clone(),
        persist_opts.clone(),
        "default_doc",
    ));

    let options =
        EditorOptionsBuilder::new().add_event_handler(subscriber).build();

    // 4) 从 XML schema 加载运行时（注意路径相对于工作目录，必要时调整为 "../../schema/main.xml"）
    let xml_path = "schema/main.xml";
    let mut editor =
        ForgeAsyncRuntime::from_xml_schema_path(xml_path, Some(options), None)
            .await?;

    // 5) 构造一个新增节点事务（dwgc）并分发
    let doc = editor.doc();
    let mut tr = editor.get_tr();
    let schema = &tr.schema;
    // 依赖 main.xml 中定义的 <node name="dwgc" ...>
    let factory = schema.factory();
    let dw_node = factory.create_tree("dwgc", None, None, vec![], None)?;
    tr.add_node(doc.root_id().clone(), vec![dw_node])?;
    editor.dispatch(tr).await?;
    // 睡眠五秒，等待持久化与快照
    tokio::time::sleep(std::time::Duration::from_secs(5)).await;
    let state = editor.get_state();
    println!("事务已分发并持久化，当前版本: {}", state.version);

    // 如需导出/导入演示，请运行：
    // cargo run -p moduforge-persistence --example export_doc
    // cargo run -p moduforge-persistence --example export_zip
    Ok(())
}

Trait Implementations

impl EventStore for SqliteEventStore

fn append<'life0, 'async_trait>( &'life0 self, ev: PersistedEvent, ) -> Pin<Box<dyn Future<Output = Result<i64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

以独立事务追加一条事件记录。

fn append_batch<'life0, 'async_trait>( &'life0 self, evs: Vec<PersistedEvent>, ) -> Pin<Box<dyn Future<Output = Result<i64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

在单事务内批量追加多条事件以提升吞吐。

fn load_since<'life0, 'life1, 'async_trait>( &'life0 self, doc_id: &'life1 str, from_lsn: i64, limit: u32, ) -> Pin<Box<dyn Future<Output = Result<Vec<PersistedEvent>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

读取指定文档在 from_lsn 之后的有序事件流。

fn latest_snapshot<'life0, 'life1, 'async_trait>( &'life0 self, doc_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Snapshot>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

返回该文档的最新快照（若存在）。

fn write_snapshot<'life0, 'async_trait>( &'life0 self, snap: Snapshot, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

原子写入/替换快照。

fn compact<'life0, 'life1, 'async_trait>( &'life0 self, doc_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

最佳努力的历史压缩：删除最新快照之前的事件。