Struct SnapshotSubscriber 

pub struct SnapshotSubscriber<E: EventStore + 'static> { /* private fields */ }

Implementations

impl<E: EventStore + 'static> SnapshotSubscriber<E>

pub fn new( store: Arc<E>, options: PersistOptions, default_doc_id: impl Into<String>, ) -> Self

Examples found in repository

examples/01_runtime_with_persistence.rs (lines 34-38)

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

    // 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<E: EventStore + 'static> Clone for SnapshotSubscriber<E>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<E: EventStore + 'static> Debug for SnapshotSubscriber<E>

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

Formats the value using the given formatter.

impl<E: EventStore + 'static> EventHandler<Event> for SnapshotSubscriber<E>

fn handle<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 Event, ) -> Pin<Box<dyn Future<Output = ForgeResult<()>> + Send + 'async_trait>>

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