イベントソーシング

目次

• 概要
• 使用する場合
• クイックスタート
• 参考ガイド
• ベストプラクティス

概要

現在の状態ではなく、状態変化をイベントのシーケンスとして保存し、時間的クエリ、監査証跡、イベントリプレイを実現します。

使用する場合

• 監査証跡の要件
• 時間的クエリ（任意のポイントにおける状態）
• イベント駆動マイクロサービス
• CQRS実装
• 金融システム
• 複雑なドメインモデル
• デバッグと分析
• コンプライアンスと規制

クイックスタート

最小限の動作例：

interface DomainEvent {
  id: string;
  aggregateId: string;
  aggregateType: string;
  eventType: string;
  data: any;
  metadata: {
    userId?: string;
    timestamp: number;
    version: number;
  };
}

interface Aggregate {
  id: string;
  version: number;
}

class EventStore {
  private events: DomainEvent[] = [];

  async appendEvents(
    aggregateId: string,
    expectedVersion: number,
    events: Omit<DomainEvent, "id" | "metadata">[],
// ... (完全な実装については参考ガイドを参照してください)

参考ガイド

references/ ディレクトリ内の詳細な実装：

ベストプラクティス

✅ すべきこと

• イベントを不変で保存する
• イベントにバージョンを付ける
• オプティミスティック同時実行制御を使用する
• パフォーマンスのためのスナップショットを作成する
• クエリにはプロジェクションを使用する
• イベントを小さく焦点を絞ったものにする
• メタデータ（タイムスタンプ、ユーザーなど）を含める
• イベントのバージョン管理とマイグレーションを処理する

❌ してはいけないこと

• 過去のイベントを変更する
• 現在の状態のみを保存する
• 同時実行チェックをスキップする
• 読み取りのためにイベントストアをクエリする
• イベントを大きくしすぎる
• イベントスキーマの進化を忘れる