NoKV

type ColumnFamilySnapshot struct {
	Writes uint64 `json:"writes"`
	Reads  uint64 `json:"reads"`
}

type CoreAPI interface {
	Set(data *kv.Entry) error
	Get(key []byte) (*kv.Entry, error)
	Del(key []byte) error
	SetCF(cf kv.ColumnFamily, key, value []byte) error
	GetCF(cf kv.ColumnFamily, key []byte) (*kv.Entry, error)
	DelCF(cf kv.ColumnFamily, key []byte) error
	NewIterator(opt *utils.Options) utils.Iterator
	Info() *Stats
	Close() error
}

type DB struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type DBIterator struct {
	// contains filtered or unexported fields
}

type HotKeyStat struct {
	Key   string `json:"key"`
	Count int32  `json:"count"`
}

type Item struct {
	// contains filtered or unexported fields
}

type IteratorOptions struct {
	Reverse        bool // Direction of iteration. False is forward, true is backward.
	AllVersions    bool // Fetch all valid versions of the same key.
	InternalAccess bool // Used to allow internal access to keys.
	KeyOnly        bool // Avoid eager value materialisation.

	Prefix  []byte // Only iterate over this given prefix.
	SinceTs uint64 // Only read data that has version > SinceTs.
	// contains filtered or unexported fields
}

type LSMLevelStats struct {
	Level              int     `json:"level"`
	TableCount         int     `json:"tables"`
	SizeBytes          int64   `json:"size_bytes"`
	ValueBytes         int64   `json:"value_bytes"`
	StaleBytes         int64   `json:"stale_bytes"`
	IngestTables       int     `json:"ingest_tables"`
	IngestSizeBytes    int64   `json:"ingest_size_bytes"`
	IngestValueBytes   int64   `json:"ingest_value_bytes"`
	ValueDensity       float64 `json:"value_density"`
	IngestValueDensity float64 `json:"ingest_value_density"`
	IngestRuns         int64   `json:"ingest_runs"`
	IngestMs           float64 `json:"ingest_ms"`
	IngestTablesCount  int64   `json:"ingest_tables_compacted"`
	MergeRuns          int64   `json:"ingest_merge_runs"`
	MergeMs            float64 `json:"ingest_merge_ms"`
	MergeTables        int64   `json:"ingest_merge_tables"`
}

type Options struct {
	ValueThreshold     int64
	WorkDir            string
	MemTableSize       int64
	SSTableMaxSz       int64
	MaxBatchCount      int64
	MaxBatchSize       int64 // max batch size in bytes
	ValueLogFileSize   int
	ValueLogMaxEntries uint32

	// ValueLogGCInterval specifies how frequently to trigger a check for value
	// log garbage collection. Zero or negative values disable automatic GC.
	ValueLogGCInterval time.Duration
	// ValueLogGCDiscardRatio is the discard ratio for a value log file to be
	// considered for garbage collection. It must be in the range (0.0, 1.0).
	ValueLogGCDiscardRatio float64

	// Value log GC sampling parameters. Ratios <= 0 fall back to defaults.
	ValueLogGCSampleSizeRatio  float64
	ValueLogGCSampleCountRatio float64
	ValueLogGCSampleFromHead   bool

	// ValueLogVerbose enables verbose logging across value-log operations.
	ValueLogVerbose bool

	WriteBatchMaxCount int
	WriteBatchMaxSize  int64

	DetectConflicts bool
	HotRingEnabled  bool
	HotRingBits     uint8
	HotRingTopK     int
	// HotRingDecayInterval controls how often HotRing halves its global counters.
	// Zero disables periodic decay.
	HotRingDecayInterval time.Duration
	// HotRingDecayShift determines how aggressively counters decay (count >>= shift).
	HotRingDecayShift uint32
	// HotRingWindowSlots controls the number of sliding-window buckets tracked per key.
	// Zero disables the sliding window.
	HotRingWindowSlots int
	// HotRingWindowSlotDuration sets the duration of each sliding-window bucket.
	HotRingWindowSlotDuration time.Duration

	SyncWrites   bool
	ManifestSync bool
	// WriteHotKeyLimit caps how many consecutive writes a single key can issue
	// before the DB returns utils.ErrHotKeyWriteThrottle. Zero disables write-path
	// throttling.
	WriteHotKeyLimit int32
	// HotWriteBurstThreshold marks a key as “hot” for batching when its write
	// frequency exceeds this count; zero disables hot write batching.
	HotWriteBurstThreshold int32
	// HotWriteBatchMultiplier scales write batch limits when a hot key is
	// detected, allowing short-term coalescing of repeated writes.
	HotWriteBatchMultiplier int
	// WriteBatchWait adds an optional coalescing delay when the commit queue is
	// momentarily empty, letting small bursts share one WAL fsync/apply pass.
	// Zero disables the delay.
	WriteBatchWait time.Duration
	// CommitPipelineDepth controls the buffering between commit queue, value log
	// writes, and LSM apply. Values <= 0 fall back to a small default.
	CommitPipelineDepth int

	// Block cache configuration for read path optimization. Cached blocks
	// target L0/L1; colder data relies on the OS page cache.
	BlockCacheSize int
	BloomCacheSize int

	// RaftLagWarnSegments determines how many WAL segments a follower can lag
	// behind the active segment before stats surfaces a warning. Zero disables
	// the alert.
	RaftLagWarnSegments int64

	// EnableWALWatchdog enables the background WAL backlog watchdog which
	// surfaces typed-record warnings and optionally runs automated segment GC.
	EnableWALWatchdog bool
	// WALAutoGCInterval controls how frequently the watchdog evaluates WAL
	// backlog for automated garbage collection.
	WALAutoGCInterval time.Duration
	// WALAutoGCMinRemovable is the minimum number of removable WAL segments
	// required before an automated GC pass will run.
	WALAutoGCMinRemovable int
	// WALAutoGCMaxBatch bounds how many WAL segments are removed during a single
	// automated GC pass.
	WALAutoGCMaxBatch int
	// WALTypedRecordWarnRatio triggers a typed-record warning when raft records
	// constitute at least this fraction of WAL writes. Zero disables ratio-based
	// warnings.
	WALTypedRecordWarnRatio float64
	// WALTypedRecordWarnSegments triggers a typed-record warning when the number
	// of WAL segments containing raft records exceeds this threshold. Zero
	// disables segment-count warnings.
	WALTypedRecordWarnSegments int64

	// DiscardStatsFlushThreshold controls how many discard-stat updates must be
	// accumulated before they are flushed back into the LSM. Zero keeps the
	// default threshold.
	DiscardStatsFlushThreshold int

	// NumCompactors controls how many background compaction workers are spawned.
	// Zero uses an auto value derived from the host CPU count.
	NumCompactors int
	// NumLevelZeroTables controls when write throttling kicks in and feeds into
	// the compaction priority calculation. Zero falls back to the legacy default.
	NumLevelZeroTables int
	// IngestCompactBatchSize decides how many L0 tables to promote into the
	// ingest buffer per compaction cycle. Zero falls back to the legacy default.
	IngestCompactBatchSize int
	// IngestBacklogMergeScore triggers an ingest-merge task when the ingest
	// backlog score exceeds this threshold. Zero keeps the default (2.0).
	IngestBacklogMergeScore float64

	// CompactionValueWeight adjusts how aggressively the scheduler prioritises
	// levels whose entries reference large value log payloads. Higher values
	// make the compaction picker favour levels with high ValuePtr density.
	CompactionValueWeight float64

	// CompactionValueAlertThreshold triggers stats alerts when a level's
	// value-density (value bytes / total bytes) exceeds this ratio.
	CompactionValueAlertThreshold float64

	// IngestShardParallelism caps how many ingest shards can be compacted in a
	// single ingest-only pass. A value <= 0 falls back to 1 (sequential).
	IngestShardParallelism int
}

type Stats struct {
	EntryNum int64 // Mirrors Entries for backwards compatibility.
	// contains filtered or unexported fields
}

type StatsSnapshot struct {
	Entries                        int64                           `json:"entries"`
	FlushPending                   int64                           `json:"flush_pending"`
	FlushQueueLength               int64                           `json:"flush_queue_length"`
	FlushActive                    int64                           `json:"flush_active"`
	FlushWaitMs                    float64                         `json:"flush_wait_ms"`
	FlushLastWaitMs                float64                         `json:"flush_last_wait_ms"`
	FlushMaxWaitMs                 float64                         `json:"flush_max_wait_ms"`
	FlushBuildMs                   float64                         `json:"flush_build_ms"`
	FlushLastBuildMs               float64                         `json:"flush_last_build_ms"`
	FlushMaxBuildMs                float64                         `json:"flush_max_build_ms"`
	FlushReleaseMs                 float64                         `json:"flush_release_ms"`
	FlushLastReleaseMs             float64                         `json:"flush_last_release_ms"`
	FlushMaxReleaseMs              float64                         `json:"flush_max_release_ms"`
	FlushCompleted                 int64                           `json:"flush_completed"`
	CompactionBacklog              int64                           `json:"compaction_backlog"`
	CompactionMaxScore             float64                         `json:"compaction_max_score"`
	CompactionLastDurationMs       float64                         `json:"compaction_last_duration_ms"`
	CompactionMaxDurationMs        float64                         `json:"compaction_max_duration_ms"`
	CompactionRuns                 uint64                          `json:"compaction_runs"`
	CompactionIngestRuns           int64                           `json:"compaction_ingest_runs"`
	CompactionMergeRuns            int64                           `json:"compaction_ingest_merge_runs"`
	CompactionIngestMs             float64                         `json:"compaction_ingest_ms"`
	CompactionMergeMs              float64                         `json:"compaction_ingest_merge_ms"`
	CompactionIngestTables         int64                           `json:"compaction_ingest_tables"`
	CompactionMergeTables          int64                           `json:"compaction_ingest_merge_tables"`
	CompactionValueWeight          float64                         `json:"compaction_value_weight"`
	CompactionValueWeightSuggested float64                         `json:"compaction_value_weight_suggested,omitempty"`
	ValueLogSegments               int                             `json:"vlog_segments"`
	ValueLogPendingDel             int                             `json:"vlog_pending_deletes"`
	ValueLogDiscardQueue           int                             `json:"vlog_discard_queue"`
	ValueLogHead                   kv.ValuePtr                     `json:"vlog_head"`
	WALActiveSegment               int64                           `json:"wal_active_segment"`
	WALSegmentCount                int64                           `json:"wal_segment_count"`
	WALActiveSize                  int64                           `json:"wal_active_size"`
	WALSegmentsRemoved             uint64                          `json:"wal_segments_removed"`
	WALRecordCounts                wal.RecordMetrics               `json:"wal_record_counts"`
	WALSegmentsWithRaftRecords     int                             `json:"wal_segments_with_raft_records"`
	WALRemovableRaftSegments       int                             `json:"wal_removable_raft_segments"`
	WALTypedRecordRatio            float64                         `json:"wal_typed_record_ratio"`
	WALTypedRecordWarning          bool                            `json:"wal_typed_record_warning"`
	WALTypedRecordReason           string                          `json:"wal_typed_record_reason,omitempty"`
	WALAutoGCRuns                  uint64                          `json:"wal_auto_gc_runs"`
	WALAutoGCRemoved               uint64                          `json:"wal_auto_gc_removed"`
	WALAutoGCLastUnix              int64                           `json:"wal_auto_gc_last_unix"`
	RaftGroupCount                 int                             `json:"raft_group_count"`
	RaftLaggingGroups              int                             `json:"raft_lagging_groups"`
	RaftMinLogSegment              uint32                          `json:"raft_min_log_segment"`
	RaftMaxLogSegment              uint32                          `json:"raft_max_log_segment"`
	RaftMaxLagSegments             int64                           `json:"raft_max_lag_segments"`
	RaftLagWarnThreshold           int64                           `json:"raft_lag_warn_threshold"`
	RaftLagWarning                 bool                            `json:"raft_lag_warning"`
	WriteQueueDepth                int64                           `json:"write_queue_depth"`
	WriteQueueEntries              int64                           `json:"write_queue_entries"`
	WriteQueueBytes                int64                           `json:"write_queue_bytes"`
	WriteAvgBatchEntries           float64                         `json:"write_avg_batch_entries"`
	WriteAvgBatchBytes             float64                         `json:"write_avg_batch_bytes"`
	WriteAvgRequestWaitMs          float64                         `json:"write_avg_request_wait_ms"`
	WriteAvgValueLogMs             float64                         `json:"write_avg_vlog_ms"`
	WriteAvgApplyMs                float64                         `json:"write_avg_apply_ms"`
	WriteBatchesTotal              int64                           `json:"write_batches_total"`
	WriteThrottleActive            bool                            `json:"write_throttle_active"`
	TxnsActive                     int64                           `json:"txns_active"`
	TxnsStarted                    uint64                          `json:"txns_started"`
	TxnsCommitted                  uint64                          `json:"txns_committed"`
	TxnsConflicts                  uint64                          `json:"txns_conflicts"`
	RegionTotal                    int64                           `json:"region_total"`
	RegionNew                      int64                           `json:"region_new"`
	RegionRunning                  int64                           `json:"region_running"`
	RegionRemoving                 int64                           `json:"region_removing"`
	RegionTombstone                int64                           `json:"region_tombstone"`
	RegionOther                    int64                           `json:"region_other"`
	HotKeys                        []HotKeyStat                    `json:"hot_keys,omitempty"`
	HotWriteLimited                uint64                          `json:"hot_write_limited"`
	BlockL0HitRate                 float64                         `json:"block_l0_hit_rate"`
	BlockL1HitRate                 float64                         `json:"block_l1_hit_rate"`
	BloomHitRate                   float64                         `json:"bloom_hit_rate"`
	IndexHitRate                   float64                         `json:"index_hit_rate"`
	IteratorReused                 uint64                          `json:"iterator_reused"`
	ColumnFamilies                 map[string]ColumnFamilySnapshot `json:"column_families,omitempty"`
	LSMLevels                      []LSMLevelStats                 `json:"lsm_levels,omitempty"`
	LSMValueBytesTotal             int64                           `json:"lsm_value_bytes_total"`
	LSMValueDensityMax             float64                         `json:"lsm_value_density_max"`
	LSMValueDensityAlert           bool                            `json:"lsm_value_density_alert"`
}

type Txn struct {
	// contains filtered or unexported fields
}

type TxnIterator struct {
	// contains filtered or unexported fields
}