Function read_segment

nodedb/src/engine/timeseries/reader.rs:294–311

Read a segment file, auto-detecting its type.

(
    path: &Path,
    registry: &DictionaryRegistry,
)

/// Read a segment file, auto-detecting its type.
pub fn read_segment(
    path: &Path,
    registry: &DictionaryRegistry,
) -> Result<SegmentData, SegmentReadError> {
    let data = std::fs::read(path)?;

    let header_end = decode_tseg_header(&data)?;
    let kind = data
        .get(header_end)
        .copied()
        .ok_or(SegmentReadError::TooSmall { size: data.len() })?;

    match kind {
        KIND_METRIC => read_metric_segment_from_bytes(&data).map(SegmentData::Metric),
        KIND_LOG => read_log_segment_from_bytes(&data, registry).map(SegmentData::Log),
        k => Err(SegmentReadError::UnknownKind { kind: k }),
    }
}

// ── Aggregation helpers ───────────────────────────────────────────────────────