Struct CompressionRuleStore 

pub struct CompressionRuleStore { /* private fields */ }

Persistence layer for TACO compression rules.

All rules are loaded at startup via CompressionRuleStore::list_active and cached in super::RuleBasedCompressor. Hit counts are flushed in batches via CompressionRuleStore::increment_hits during the maybe_autodream maintenance pass.

Implementations

impl CompressionRuleStore

pub fn new(pool: Arc<DbPool>) -> Self

Construct a store backed by the given pool.

pub async fn list_active(&self) -> Result<Vec<CompressionRule>, SqlxError>

Return all rules, ordered by ascending hit count (least-used first for pruning).

Errors

Returns a database error on failure.

pub async fn upsert(&self, rule: &CompressionRule) -> Result<(), SqlxError>

Insert or update a rule (keyed by (tool_glob, pattern)).

Errors

Returns a database error on failure.

pub async fn increment_hits( &self, batch: &[(String, u64)], ) -> Result<(), SqlxError>

Batch-increment hit counts for a set of rule IDs.

Called during the maybe_autodream maintenance pass. Uses individual UPDATE statements rather than a batch because the count of rules is small and cross-backend portability is preferred.

Errors

Returns a database error on failure.

pub async fn delete(&self, id: &str) -> Result<(), SqlxError>

Delete a rule by ID.

Errors

Returns a database error on failure.

pub async fn prune_lowest_hits(&self, max_rules: u32) -> Result<u64, SqlxError>

Prune the lowest-hit rules to keep the table below max_rules.

Returns the number of rules deleted.

Errors

Returns a database error on failure.

Trait Implementations

impl Clone for CompressionRuleStore

fn clone(&self) -> CompressionRuleStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.