tidesdb 0.7.0

TidesDB is a high-performance embeddable, durable, adaptive, and optionally cloud-native key-value storage engine
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
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131

// Package tidesdb
// Copyright (C) TidesDB
//
// Licensed under the Mozilla Public License, v. 2.0 (the "License");

//! Statistics types for TidesDB.

use crate::config::ColumnFamilyConfig;

/// Statistics for a column family.
#[derive(Debug, Clone)]
pub struct Stats {
    /// Number of levels
    pub num_levels: i32,
    /// Memtable size in bytes
    pub memtable_size: usize,
    /// Size of each level in bytes
    pub level_sizes: Vec<usize>,
    /// Number of SSTables in each level
    pub level_num_sstables: Vec<i32>,
    /// Column family configuration (if available)
    pub config: Option<ColumnFamilyConfig>,
    /// Total number of keys across memtable and all sstables
    pub total_keys: u64,
    /// Total data size (klog + vlog) across all sstables
    pub total_data_size: u64,
    /// Average key size in bytes
    pub avg_key_size: f64,
    /// Average value size in bytes
    pub avg_value_size: f64,
    /// Number of keys per level
    pub level_key_counts: Vec<u64>,
    /// Read amplification (point lookup cost multiplier)
    pub read_amp: f64,
    /// Cache hit rate (0.0 if cache disabled)
    pub hit_rate: f64,
    /// Whether column family uses B+tree format
    pub use_btree: bool,
    /// Total B+tree nodes across all SSTables (only populated if use_btree=true)
    pub btree_total_nodes: u64,
    /// Maximum tree height across all SSTables (only populated if use_btree=true)
    pub btree_max_height: u32,
    /// Average tree height across all SSTables (only populated if use_btree=true)
    pub btree_avg_height: f64,
}

/// Database-level aggregate statistics.
#[derive(Debug, Clone)]
pub struct DbStats {
    /// Number of column families
    pub num_column_families: i32,
    /// System total memory
    pub total_memory: u64,
    /// System available memory at open time
    pub available_memory: u64,
    /// Resolved memory limit (auto or configured)
    pub resolved_memory_limit: usize,
    /// Current memory pressure (0=normal, 1=elevated, 2=high, 3=critical)
    pub memory_pressure_level: i32,
    /// Number of pending flush operations (queued + in-flight)
    pub flush_pending_count: i32,
    /// Total bytes in active memtables across all CFs
    pub total_memtable_bytes: i64,
    /// Total immutable memtables across all CFs
    pub total_immutable_count: i32,
    /// Total SSTables across all CFs and levels
    pub total_sstable_count: i32,
    /// Total data size (klog + vlog) across all CFs
    pub total_data_size_bytes: u64,
    /// Number of currently open SSTable file handles
    pub num_open_sstables: i32,
    /// Current global sequence number
    pub global_seq: u64,
    /// Bytes held by in-flight transactions
    pub txn_memory_bytes: i64,
    /// Number of pending compaction tasks
    pub compaction_queue_size: usize,
    /// Number of pending flush tasks in queue
    pub flush_queue_size: usize,
    /// Whether unified memtable mode is active
    pub unified_memtable_enabled: bool,
    /// Bytes in unified active memtable
    pub unified_memtable_bytes: i64,
    /// Number of unified immutable memtables
    pub unified_immutable_count: i32,
    /// Whether unified memtable is currently flushing/rotating
    pub unified_is_flushing: bool,
    /// Next CF index to be assigned in unified mode
    pub unified_next_cf_index: u32,
    /// Current unified WAL generation counter
    pub unified_wal_generation: u64,
    /// Whether object store mode is active
    pub object_store_enabled: bool,
    /// Connector name ("s3", "gcs", "fs", etc.)
    pub object_store_connector: String,
    /// Current local file cache usage in bytes
    pub local_cache_bytes_used: usize,
    /// Configured maximum local cache size in bytes
    pub local_cache_bytes_max: usize,
    /// Number of files tracked in local cache
    pub local_cache_num_files: i32,
    /// Highest WAL generation confirmed uploaded
    pub last_uploaded_generation: u64,
    /// Number of pending upload jobs in the queue
    pub upload_queue_depth: usize,
    /// Lifetime count of objects uploaded to object store
    pub total_uploads: u64,
    /// Lifetime count of permanently failed uploads (after all retries)
    pub total_upload_failures: u64,
    /// Whether running in read-only replica mode
    pub replica_mode: bool,
}

/// Statistics for the block cache.
#[derive(Debug, Clone)]
pub struct CacheStats {
    /// Whether the cache is enabled
    pub enabled: bool,
    /// Total number of entries in the cache
    pub total_entries: usize,
    /// Total bytes used by the cache
    pub total_bytes: usize,
    /// Number of cache hits
    pub hits: usize,
    /// Number of cache misses
    pub misses: usize,
    /// Cache hit rate (0.0 to 1.0)
    pub hit_rate: f64,
    /// Number of cache partitions
    pub num_partitions: usize,
}