znippy-compress 0.9.7

Compression logic for Znippy, a parallel chunked compression system.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

// compress/src/lib.rs

/// **Introspection / emit marker** — record one functional-status row for the
/// nornir test matrix. Wraps `nornir_testmatrix::functional_status` behind the
/// `testmatrix` feature (a compiled-out `#[inline]` no-op otherwise, with no
/// nornir dep in the default build). The slot / stream packers call this at each
/// `run_ordered_sink` completion so `nornir test --features testmatrix` SEES the
/// ordered-sink compress path's health. Defined only under the feature — every
/// call site is itself `#[cfg(feature = "testmatrix")]`.
#[cfg(feature = "testmatrix")]
#[inline]
pub(crate) fn functional_status(component: &str, check: &str, ok: bool, detail: &str) {
    nornir_testmatrix::functional_status(component, check, ok, detail);
}

pub mod slot_packer;
pub mod stream_packer;

pub use slot_packer::compress_dir;
pub use stream_packer::{compress_stream, compress_stream_with_sink, ArchiveEntry, StreamCompressor};