Struct StorageEngine 

pub struct StorageEngine { /* private fields */ }

ストレージエンジンのメインエントリポイント

Example

use kawa_storage::{StorageEngine, StorageConfig};
 
#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let config = StorageConfig::default();
    let storage = StorageEngine::new(config).await?;
     
    // @todo イベント書き込み・読み取りのサンプル実装
    Ok(())
}

Implementations

impl StorageEngine

pub async fn new(config: StorageConfig) -> StorageResult<Self>

新しいストレージエンジンを作成

Arguments

• config - ストレージ設定

Returns

• Result<Self> - ストレージエンジンインスタンス

@todo

• データディレクトリの自動作成
• 既存データの復旧処理
• メトリクス収集の初期化

pub async fn append_event( &self, topic: &Topic, partition: Partition, event_data: EventData, ) -> StorageResult<(EventId, Offset)>

イベントを永続化

Arguments

• topic - トピック名
• partition - パーティション番号
• event_data - イベントデータ

Returns

• Result<(EventId, Offset)> - イベントIDとオフセット

@todo

• バッチ書き込みのサポート
• 圧縮機能の実装
• レプリケーション対応

pub async fn read_events( &self, topic: &Topic, partition: Partition, start_offset: Offset, max_events: usize, ) -> StorageResult<Vec<Event>>

指定したオフセット範囲のイベントを読み取り

Arguments

• topic - トピック名
• partition - パーティション番号
• start_offset - 開始オフセット
• max_events - 最大イベント数

Returns

• Result<Vec<Event>> - イベントリスト

@todo

• ストリーミング読み取り
• インデックスベース高速検索
• 非同期イテレータの実装

pub async fn get_latest_offset( &self, topic: &Topic, partition: Partition, ) -> StorageResult<Option<Offset>>

最新のオフセットを取得

Arguments

• topic - トピック名
• partition - パーティション番号

Returns

• Result<Option<Offset>> - 最新オフセット（データがない場合はNone）

pub async fn append_events_batch( &self, events: Vec<(Topic, Partition, EventData)>, ) -> StorageResult<Vec<(EventId, Offset)>>

バッチでイベントを永続化（高性能版）

Arguments

• events - イベントのバッチ

Returns

• Result<Vec<(EventId, Offset)>> - イベントIDとオフセットのリスト

Performance

1M+ events/secを達成するための最適化バッチ処理

pub fn memory_pool_stats(&self) -> PoolStats

メモリプール統計を取得

pub async fn shutdown(&self) -> StorageResult<()>

ストレージエンジンを優雅にシャットダウン

@todo

• 未書き込みデータのフラッシュ
• メトリクスの最終出力
• リソースクリーンアップ

Trait Implementations

impl Debug for StorageEngine

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

Formats the value using the given formatter.