EventStore

EventStore 允许您处理 Chekov 事件源各个方面的操作。

追加事件

通过在 event_store crate 根级别公开的流畅API来追加事件

use event_store::prelude::*;
#

let stream_uuid = Uuid::new_v4().to_string();
let my_event = MyEvent { account_id: Uuid::new_v4() };

event_store::append()
  .event(&my_event)?
  .to(&stream_uuid)?
  .execute(event_store)
  .await;

从流中读取

可以使用在 event_store crate 根级别公开的流畅API读取 Stream

use event_store::prelude::*;
#

let stream_uuid = Uuid::new_v4().to_string();

event_store::read()
  .stream(&stream_uuid)?
  .from(ReadVersion::Origin)
  .limit(10)
  .execute(event_store)
  .await;