Function read_metric_segment_from_bytes

nodedb/src/engine/timeseries/reader.rs:193–219

Read and decode a metric segment from in-memory bytes.

(data: &[u8])

/// Read and decode a metric segment from in-memory bytes.
pub fn read_metric_segment_from_bytes(data: &[u8]) -> Result<MetricSegmentData, SegmentReadError> {
    let header_end = decode_tseg_header(data)?;
    let mut cur = Cursor::new(&data[header_end..]);

    let kind = cur
        .read_u8()
        .ok_or(SegmentReadError::TooSmall { size: data.len() })?;
    if kind != KIND_METRIC {
        return Err(SegmentReadError::UnknownKind { kind });
    }

    let _sample_count = cur
        .read_u64_le()
        .ok_or(SegmentReadError::TooSmall { size: data.len() })?;
    let block_len = cur
        .read_u32_le()
        .ok_or(SegmentReadError::TooSmall { size: data.len() })? as usize;

    let gorilla_block = cur
        .read_bytes(block_len)
        .ok_or(SegmentReadError::TooSmall { size: data.len() })?;

    let mut decoder = GorillaDecoder::new(gorilla_block);
    let samples = decoder.decode_all();

    Ok(MetricSegmentData { samples })
}

/// Read and decode a log segment from disk.
///