Function encode_i64_pipeline

nodedb-codec/src/pipeline.rs:27–56

Encode i64 values through a cascading pipeline. For cascading codecs, chains the appropriate stages. For legacy codecs, delegates to the single-step encoder.

(values: &[i64], codec: ColumnCodec)

/// For cascading codecs, chains the appropriate stages. For legacy codecs,
/// delegates to the single-step encoder.
pub fn encode_i64_pipeline(values: &[i64], codec: ColumnCodec) -> Result<Vec<u8>, CodecError> {
    match codec {
        // Cascading chains — lz4 terminal.
        ColumnCodec::DeltaFastLanesLz4 => encode_delta_fastlanes_lz4(values),
        ColumnCodec::FastLanesLz4 => encode_fastlanes_lz4_i64(values),
        ColumnCodec::PcodecLz4 => {
            let pco_bytes = crate::pcodec::encode_i64(values)?;
            Ok(crate::lz4::encode(&pco_bytes))
        }
        // Cascading chains — rANS terminal (cold tier).
        ColumnCodec::DeltaFastLanesRans => encode_delta_fastlanes_rans(values),
        // Single-step codecs (small partitions / non-ALP-encodable data).
        ColumnCodec::DoubleDelta => Ok(crate::double_delta::encode(values)),
        ColumnCodec::Delta => Ok(crate::delta::encode(values)),
        ColumnCodec::Gorilla => Ok(crate::gorilla::encode_timestamps(values)),
        ColumnCodec::Raw => {
            let raw: Vec<u8> = values.iter().flat_map(|v| v.to_le_bytes()).collect();
            Ok(crate::raw::encode(&raw))
        }
        ColumnCodec::Lz4 => {
            let raw: Vec<u8> = values.iter().flat_map(|v| v.to_le_bytes()).collect();
            Ok(crate::lz4::encode(&raw))
        }
        ColumnCodec::Zstd => {
            let raw: Vec<u8> = values.iter().flat_map(|v| v.to_le_bytes()).collect();
            crate::zstd_codec::encode(&raw)
        }
        _ => Ok(crate::delta::encode(values)),
    }
}

/// Encode f64 values through a cascading pipeline.
pub fn encode_f64_pipeline(values: &[f64], codec: ColumnCodec) -> Result<Vec<u8>, CodecError> {