acta-core 0.1.0-alpha.1

Append-only columnar file format for time-series data
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

mod full;
mod options;
mod report;
pub(crate) mod statistics;

pub use options::{ValidationLevel, ValidationOptions};
pub use report::ValidationReport;

use std::path::Path;

use crate::error::Result;
use crate::format::scan::FileScan;
use crate::limits::Limits;

/// Walk every frame in `path` from the prologue to the end of the file.
///
/// The walk itself lives in [`FileScan`], which the reader shares, so the two
/// entry points cannot disagree about which files are well formed. Validation
/// keeps only the counts; it retains no per-block metadata.
pub(crate) fn validate_path(path: &Path, options: ValidationOptions) -> Result<ValidationReport> {
    if options.level() == ValidationLevel::Full {
        return full::validate_path(path, options.limits());
    }

    validate_structural_path(path, options.limits())
}

fn validate_structural_path(path: &Path, limits: Limits) -> Result<ValidationReport> {
    let mut scan = FileScan::open(path, limits)?;
    let walk = scan.walk_data_frames(|_frame, _block| Ok(()))?;

    let prologue = scan.prologue();
    let file_size = scan.file_size();
    if walk.incomplete_tail {
        return Ok(ValidationReport::with_incomplete_tail(
            prologue,
            walk.frame_count,
            file_size,
            walk.last_good_offset,
        ));
    }
    Ok(ValidationReport::complete(
        prologue,
        walk.frame_count,
        file_size,
    ))
}