znippy-compress 0.9.12

Compression logic for Znippy, a parallel chunked compression system.
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

// 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, compress_dir_with_policy};
pub use stream_packer::{
    compress_stream, compress_stream_with_policy, compress_stream_with_sink,
    compress_stream_with_sink_and_policy, ArchiveEntry, StreamCompressor,
};

/// Re-exported so a caller can state what it already knows about its input
/// without also depending on `znippy-common` directly.
pub use znippy_common::precompressed::{ContentHint, SkipPolicy};