Struct PcapReader 

pub struct PcapReader { /* private fields */ }

PCAP数据集读取器

提供对PCAP数据集的高性能读取功能，支持：

• 自动索引管理和验证
• 顺序读取和文件切换
• 智能缓存和性能优化
• 多文件数据集统一访问

Implementations

impl PcapReader

pub fn new<P: AsRef<Path>>(base_path: P, dataset_name: &str) -> PcapResult<Self>

创建新的PCAP读取器

参数

• base_path - 基础路径
• dataset_name - 数据集名称

返回

返回初始化后的读取器实例

pub fn new_with_config<P: AsRef<Path>>( base_path: P, dataset_name: &str, configuration: ReaderConfig, ) -> PcapResult<Self>

创建新的PCAP读取器（带配置）

参数

• base_path - 基础路径
• dataset_name - 数据集名称
• configuration - 读取器配置信息

返回

返回初始化后的读取器实例

pub fn initialize(&mut self) -> PcapResult<()>

初始化读取器

确保索引可用并准备好读取操作

pub fn get_dataset_info(&mut self) -> PcapResult<DatasetInfo>

获取数据集信息

pub fn get_file_info_list(&mut self) -> PcapResult<Vec<FileInfo>>

获取文件信息列表

pub fn dataset_path(&self) -> &Path

获取数据集路径

pub fn dataset_name(&self) -> &str

获取数据集名称

pub fn read_packet(&mut self) -> PcapResult<Option<ValidatedPacket>>

读取下一个数据包（默认方法，带校验结果）

从当前位置读取下一个数据包，包含校验状态信息。如果当前文件读取完毕， 会自动切换到下一个文件。

返回

• Ok(Some(result)) - 成功读取到数据包和校验结果
• Ok(None) - 到达文件末尾，无更多数据包
• Err(error) - 读取过程中发生错误

pub fn read_packet_data_only(&mut self) -> PcapResult<Option<DataPacket>>

读取下一个数据包（仅返回数据，不返回校验信息）

从当前位置读取下一个数据包，仅返回数据包本身。如果当前文件读取完毕， 会自动切换到下一个文件。

返回

• Ok(Some(packet)) - 成功读取到数据包
• Ok(None) - 到达文件末尾，无更多数据包
• Err(error) - 读取过程中发生错误

pub fn read_packets(&mut self, count: usize) -> PcapResult<Vec<ValidatedPacket>>

批量读取多个数据包（默认方法，带校验结果）

参数

• count - 要读取的数据包数量

返回

pub fn read_packets_data_only( &mut self, count: usize, ) -> PcapResult<Vec<DataPacket>>

批量读取多个数据包（仅返回数据，不返回校验信息）

参数

• count - 要读取的数据包数量

返回

pub fn reset(&mut self) -> PcapResult<()>

重置读取器到数据集开始位置

将读取器重置到数据集的开始位置，后续读取将从第一个数据包开始。

pub fn index(&self) -> &IndexManager

获取索引管理器的引用 允许外部通过 reader.index().method() 的方式访问索引功能

pub fn index_mut(&mut self) -> &mut IndexManager

获取索引管理器的可变引用 允许外部通过 reader.index_mut().method() 的方式访问索引功能

pub fn seek_by_timestamp( &mut self, timestamp_ns: u64, ) -> PcapResult<Option<TimestampPointer>>

按时间戳查找数据包位置

参数

• timestamp_ns - 目标时间戳（纳秒）

返回

返回最接近指定时间戳的数据包索引条目，如果未找到则返回None

pub fn read_packets_by_time_range( &mut self, start_timestamp_ns: u64, end_timestamp_ns: u64, ) -> PcapResult<Vec<ValidatedPacket>>

按时间范围读取数据包

参数

• start_timestamp_ns - 开始时间戳（纳秒）
• end_timestamp_ns - 结束时间戳（纳秒）

返回

返回指定时间范围内的所有数据包

pub fn get_cache_stats(&self) -> CacheStats

获取缓存统计信息

pub fn clear_cache(&mut self) -> PcapResult<()>

清理缓存

pub fn seek_to_timestamp(&mut self, timestamp_ns: u64) -> PcapResult<u64>

跳转到指定时间戳（纳秒）

返回实际定位到的时间戳。如果精确匹配不存在，返回时间戳后面最接近的数据包。

参数

• timestamp_ns - 目标时间戳（纳秒）

返回

• Ok(actual_timestamp) - 成功跳转，返回实际定位到的时间戳
• Err(error) - 未找到数据包或发生错误

pub fn seek_to_packet(&mut self, packet_index: usize) -> PcapResult<()>

跳转到指定索引的数据包（从0开始）

参数

• packet_index - 目标数据包的全局索引（从0开始）

pub fn is_eof(&self) -> bool

检查是否已到达文件末尾

pub fn total_packets(&self) -> Option<usize>

获取总数据包数量（如果索引可用）

pub fn current_packet_index(&self) -> u64

获取当前数据包索引位置（全局序号，从0开始）

pub fn progress(&self) -> Option<f64>

获取当前读取进度（百分比：0.0 - 1.0）

pub fn skip_packets(&mut self, count: usize) -> PcapResult<usize>

跳过指定数量的数据包

参数

• count - 要跳过的数据包数量

返回

实际跳过的数据包数量（可能小于请求数量，如果到达末尾）

pub fn read_packet_by_timestamp( &mut self, timestamp_ns: u64, ) -> PcapResult<Option<ValidatedPacket>>

根据时间戳读取数据包

Trait Implementations

impl Drop for PcapReader

fn drop(&mut self)

Executes the destructor for this type.