Skip to main content

Mountain/IPC/Enhanced/MessageCompressor/
BatchConfig.rs

1#![allow(non_snake_case)]
2
3//! Compressor / batcher tunables - max batch size, max delay
4//! before flushing, the size threshold below which messages
5//! pass through uncompressed, and the algorithm + level pair.
6
7use serde::{Deserialize, Serialize};
8
9use crate::IPC::Enhanced::MessageCompressor::{CompressionAlgorithm, CompressionLevel};
10
11#[derive(Debug, Clone, Serialize, Deserialize)]
12pub struct Struct {
13	pub MaxBatchSize:usize,
14	pub MaxBatchDelayMs:u64,
15	pub CompressionThresholdBytes:usize,
16	pub CompressionLevel:CompressionLevel::Enum,
17	pub Algorithm:CompressionAlgorithm::Enum,
18}
19
20impl Default for Struct {
21	fn default() -> Self {
22		Self {
23			MaxBatchSize:100,
24			MaxBatchDelayMs:100,
25			CompressionThresholdBytes:1024,
26			CompressionLevel:CompressionLevel::Enum::Balanced,
27			Algorithm:CompressionAlgorithm::Enum::Brotli,
28		}
29	}
30}