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
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
//! Turso Configuration
//!
//! This module contains the TursoConfig struct and its implementation.
/// Configuration for Turso storage
#[derive(Debug, Clone)]
pub struct TursoConfig {
/// Maximum retry attempts for failed operations
pub max_retries: u32,
/// Base delay for exponential backoff (milliseconds)
pub retry_base_delay_ms: u64,
/// Maximum delay for exponential backoff (milliseconds)
pub retry_max_delay_ms: u64,
/// Enable connection pooling
pub enable_pooling: bool,
/// Enable keep-alive connection pool (reduces connection overhead)
#[cfg(feature = "keepalive-pool")]
pub enable_keepalive: bool,
/// Keep-alive interval (seconds)
#[cfg(feature = "keepalive-pool")]
pub keepalive_interval_secs: u64,
/// Stale connection threshold (seconds)
#[cfg(feature = "keepalive-pool")]
pub stale_threshold_secs: u64,
/// Compression threshold in bytes (default: 1024 = 1KB)
/// Payloads smaller than this won't be compressed
/// Only used when compression feature is enabled
pub compression_threshold: usize,
/// Enable compression for episodes (default: true)
/// Only used when compression feature is enabled
pub compress_episodes: bool,
/// Enable compression for patterns (default: true)
/// Only used when compression feature is enabled
pub compress_patterns: bool,
/// Enable compression for embeddings (default: true)
/// Only used when compression feature is enabled
pub compress_embeddings: bool,
/// Compression level for zstd (1-22, default: 3)
/// 1 = fastest, 22 = best compression
/// Only used when compression feature is enabled
pub compression_level: i32,
/// Enable transport compression for network operations (default: true)
///
/// **Architectural Note**: This flag is reserved for future custom transport implementations.
/// It is NOT currently wired into TursoStorage because libsql handles its own transport layer
/// internally. Compression IS applied at the data layer (embedding storage) via the
/// `compress()`/`decompress()` functions.
///
/// For details, see `tests/runtime_wiring_transport_compression.rs` which documents:
/// - CompressedTransport is a standalone utility for custom Transport implementations
/// - TursoStorage uses libsql::Database directly, not the Transport trait
/// - Data-layer compression (at embedding level) is the correct architectural approach
#[cfg(feature = "compression")]
pub enable_transport_compression: bool,
/// Cache configuration for performance optimization
/// When None, caching is disabled (default: Some(CacheConfig::default()))
pub cache_config: Option<crate::cache::CacheConfig>,
}
impl Default for TursoConfig {
fn default() -> Self {
Self {
max_retries: 3,
retry_base_delay_ms: 100,
retry_max_delay_ms: 5000,
enable_pooling: true,
#[cfg(feature = "keepalive-pool")]
enable_keepalive: true,
#[cfg(feature = "keepalive-pool")]
keepalive_interval_secs: 30,
#[cfg(feature = "keepalive-pool")]
stale_threshold_secs: 60,
// Compression settings (always present, only used when compression feature is enabled)
compression_threshold: 1024,
compress_episodes: true,
compress_patterns: true,
compress_embeddings: true,
compression_level: 3, // Default zstd level (good balance of speed/ratio)
#[cfg(feature = "compression")]
enable_transport_compression: true,
// Cache configuration (enabled by default)
cache_config: Some(crate::cache::CacheConfig::default()),
}
}
}