Struct CodecEngine 

pub struct CodecEngine {
    pub ml_routing: bool,
    pub brotli_threshold: usize,
    pub prefer_m2m_for_api: bool,
    /* private fields */
}

Codec engine with automatic algorithm selection

Fields

ml_routing: bool

ML routing enabled (requires inference module)

brotli_threshold: usize

Minimum size for Brotli (bytes)

prefer_m2m_for_api: bool

Prefer M2M for LLM API payloads (default: true)

Implementations

impl CodecEngine

pub fn new() -> Self

Create new codec engine

pub fn with_ml_routing(self, enabled: bool) -> Self

Enable ML-based routing (requires loaded model)

pub fn with_hydra(self, model: HydraModel) -> Self

Set Hydra model for ML-based algorithm selection

pub fn with_brotli_threshold(self, threshold: usize) -> Self

Set Brotli threshold

pub fn with_encoding(self, encoding: Encoding) -> Self

Set token-native encoding

pub fn compress_with_tokens( &self, content: &str, algorithm: Algorithm, encoding: Encoding, ) -> Result<CompressionResult>

Compress with specified algorithm and track token counts

This method counts tokens before and after compression to provide accurate token savings metrics. Use this when token efficiency matters more than raw speed.

pub fn secure_compress( &self, content: &str, scanner: &SecurityScanner, ) -> Result<CompressionResult>

Secure compress: Run cognitive security scan before compression

This method combines security scanning with compression:

1. Scans plaintext for threats using Hydra/patterns
2. If safe, compresses with optimal algorithm
3. If threat detected and blocking enabled, returns error

Epistemic basis:

• K: Threats exist in plaintext, not compressed form
• K: Security scan must happen before compression
• B: Combined scan provides defense in depth

pub fn secure_compress_ml( &self, content: &str, ) -> Result<(CompressionResult, bool)>

Secure compress with ML-based algorithm selection

Uses Hydra for both security scanning and algorithm selection.

pub fn compress_auto_with_tokens( &self, content: &str, encoding: Encoding, ) -> Result<(CompressionResult, Algorithm)>

Compress with automatic algorithm selection and token tracking

pub fn compress( &self, content: &str, algorithm: Algorithm, ) -> Result<CompressionResult>

Compress with specified algorithm

pub fn compress_auto( &self, content: &str, ) -> Result<(CompressionResult, Algorithm)>

Compress with automatic algorithm selection

pub fn compress_value( &self, value: &Value, ) -> Result<(CompressionResult, Algorithm)>

Compress JSON value with automatic selection

pub fn select_algorithm(&self, analysis: &ContentAnalysis) -> Algorithm

Select optimal algorithm based on content analysis

pub fn select_algorithm_for_content(&self, content: &str) -> Algorithm

Select algorithm with full content access (for ML routing)

pub fn decompress(&self, wire: &str) -> Result<String>

Decompress content (auto-detects algorithm from wire format)

pub fn decompress_value(&self, wire: &str) -> Result<Value>

Decompress to JSON value

pub fn compress_best(&self, content: &str) -> Result<CompressionResult>

Try all algorithms and return best result

pub fn analyze(&self, content: &str) -> ContentAnalysis

Get analysis for content

Trait Implementations

impl Clone for CodecEngine

fn clone(&self) -> CodecEngine

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for CodecEngine

fn default() -> Self

Returns the “default value” for a type.