Struct RecordStream 

pub struct RecordStream<'a> { /* private fields */ }

Record のストリームを操作するためのヘルパー

Implementations

impl<'a> RecordStream<'a>

pub fn new(records: &'a [Record]) -> Self

pub fn actions(&self) -> impl Iterator<Item = &ActionRecord>

Action Records のみ抽出

pub fn llm_calls(&self) -> impl Iterator<Item = &LlmCallRecord>

Llm Records のみ抽出

pub fn dependency_graphs(&self) -> impl Iterator<Item = &DependencyGraphRecord>

DependencyGraph Records のみ抽出

pub fn by_worker(&self, worker_id: usize) -> impl Iterator<Item = &Record>

Worker ID でフィルタ

pub fn group_by_worker(&self) -> HashMap<usize, Vec<&Record>>

Worker ID ごとにグルーピング

pub fn sorted_by_time(&self) -> Vec<&Record>

タイムスタンプでソートした Iterator

pub fn len(&self) -> usize

Record 数

pub fn is_empty(&self) -> bool

空かどうか