isledb

type BloomMeta = manifest.BloomMeta

type CleanupStats struct {
	SSTsDeleted    int
	BytesReclaimed int64
	Duration       time.Duration
}

type CompactionConfig = manifest.CompactionConfig

type CompactionJob struct {
	Type      CompactionJobType
	InputSSTs []string
	InputRuns []uint32
	OutputRun *SortedRun
}

type CompactionJobType int

type CompactionLogPayload = manifest.CompactionLogPayload

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

type CompactorOptions struct {
	L0CompactionThreshold int

	MinSources    int
	MaxSources    int
	SizeThreshold int

	BloomBitsPerKey int
	BlockSize       int
	Compression     string
	TargetSSTSize   int64

	// ValidateSSTChecksum verifies SST checksums before compaction.
	ValidateSSTChecksum bool
	// SSTHashVerifier verifies SST signatures when present.
	SSTHashVerifier SSTHashVerifier

	CheckInterval     time.Duration
	OnCompactionStart func(CompactionJob)
	OnCompactionEnd   func(CompactionJob, error)
	OwnerID           string
	// GCMarkStorage allows using a custom storage backend for GC mark state.
	GCMarkStorage manifest.GCMarkStorage
}

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

type DBOptions struct {
	// ManifestStorage allows using a custom manifest storage backend.
	// If nil, the blob store is used.
	ManifestStorage manifest.Storage
	// GCMarkStorage allows using a custom storage backend for GC mark state.
	// If nil, the blob store is used.
	GCMarkStorage manifest.GCMarkStorage
}

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

type IteratorOptions struct {
	MinKey []byte
	MaxKey []byte
}

type KV struct {
	Key   []byte
	Value []byte
}

type Manifest = manifest.Manifest

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

type ReaderMetrics struct {
	RefreshTotal   prometheus.Counter
	RefreshErrors  prometheus.Counter
	RefreshLatency prometheus.Histogram

	GetTotal   prometheus.Counter
	GetErrors  prometheus.Counter
	GetHits    prometheus.Counter
	GetMisses  prometheus.Counter
	GetLatency prometheus.Histogram

	ScanTotal   prometheus.Counter
	ScanErrors  prometheus.Counter
	ScanLatency prometheus.Histogram
	ScanResults prometheus.Counter

	ScanLimitTotal   prometheus.Counter
	ScanLimitErrors  prometheus.Counter
	ScanLimitLatency prometheus.Histogram
	ScanLimitResults prometheus.Counter

	BlobFetchTotal   prometheus.Counter
	BlobFetchErrors  prometheus.Counter
	BlobFetchLatency prometheus.Histogram
	BlobCacheHits    prometheus.Counter
	BlobCacheMisses  prometheus.Counter
	BlobBytesTotal   prometheus.Counter

	SSTCacheHits       prometheus.Counter
	SSTCacheMisses     prometheus.Counter
	SSTDownloadTotal   prometheus.Counter
	SSTDownloadErrors  prometheus.Counter
	SSTDownloadLatency prometheus.Histogram
	SSTDownloadBytes   prometheus.Counter

	SSTRangeBlockCacheHits   prometheus.Counter
	SSTRangeBlockCacheMisses prometheus.Counter
	SSTRangeReadTotal        prometheus.Counter
	SSTRangeReadErrors       prometheus.Counter
	SSTRangeReadLatency      prometheus.Histogram
	SSTRangeReadBytes        prometheus.Counter
}

type ReaderOpenOptions struct {
	// CacheDir is the directory for disk caches (required).
	CacheDir string

	// SSTCacheSize is the maximum bytes for SST cache (default 1GB).
	SSTCacheSize int64

	// BlobCacheSize is the maximum bytes for blob cache (default 1GB).
	BlobCacheSize int64

	// BlobCacheMaxItemSize is the maximum size per item in the blob cache.
	BlobCacheMaxItemSize int64

	// BlockCacheSize is the maximum bytes for the in-memory block cache used
	// when range-reading SSTs. Default 0 disables the block cache.
	BlockCacheSize int64

	// AllowUnverifiedRangeRead permits range-reading SSTs without verifying
	// full-file checksums or signatures.
	AllowUnverifiedRangeRead bool

	// RangeReadMinSSTSize is the minimum SST size (bytes) required to use
	// range-read + block cache. Default 0 means no size threshold.
	RangeReadMinSSTSize int64

	// ValidateSSTChecksum verifies SST checksums on first download.
	// If enabled and checksum is missing or mismatched, reads fail.
	ValidateSSTChecksum bool

	// SSTHashVerifier verifies SST signatures when present.
	// If provided and the SST has a signature, verification is enforced.
	SSTHashVerifier SSTHashVerifier

	Metrics *ReaderMetrics

	BlobReadOptions config.BlobReadOptions
	ManifestStorage manifest.Storage
}

type ReaderOptions struct {
	// CacheDir is the directory for disk caches.
	CacheDir string

	// SSTCache is an optional pre-created SST cache.
	SSTCache diskcache.RefCountedCache

	// SSTCacheSize is the maximum bytes for SST cache (default 1GB).
	SSTCacheSize int64

	// BlobCache is an optional pre-created blob cache.
	BlobCache internal.BlobCache

	// BlobCacheSize is the maximum bytes for blob cache (default 1GB).
	BlobCacheSize int64

	// BlobCacheMaxItemSize is the maximum size per item in the blob cache.
	// Items larger than this will not be cached. Default 0 means no limit.
	BlobCacheMaxItemSize int64

	// BlockCacheSize is the maximum bytes for the in-memory block cache used
	// when range-reading SSTs. Default 0 disables the block cache.
	BlockCacheSize int64

	// AllowUnverifiedRangeRead permits range-reading SSTs without verifying
	// full-file checksums or signatures.
	AllowUnverifiedRangeRead bool

	// RangeReadMinSSTSize is the minimum SST size (bytes) required to use
	// range-read + block cache. Default 0 means no size threshold.
	RangeReadMinSSTSize int64

	ValueStorageConfig config.ValueStorageConfig
	ManifestStorage    manifest.Storage

	ManifestLogCache     cachestore.ManifestLogCache
	ManifestLogCacheSize int
	DisableManifestCache bool

	// ValidateSSTChecksum verifies SST checksums on first download.
	// If enabled and checksum is missing or mismatched, reads fail.
	ValidateSSTChecksum bool

	// SSTHashVerifier verifies SST signatures when present.
	// If provided and the SST has a signature, verification is enforced.
	SSTHashVerifier SSTHashVerifier

	Metrics *ReaderMetrics
}

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

type RetentionCompactorMode int

type RetentionCompactorOptions struct {
	Mode RetentionCompactorMode

	RetentionPeriod time.Duration

	RetentionCount int

	CheckInterval time.Duration

	SegmentDuration time.Duration

	OnCleanup func(CleanupStats)

	OnCleanupError func(error)
	// GCMarkStorage allows using a custom storage backend for GC mark state.
	// If nil, the blob store is used.
	GCMarkStorage manifest.GCMarkStorage
}

type RetentionCompactorStats struct {
	Mode            RetentionCompactorMode
	RetentionPeriod time.Duration
	L0SSTCount      int
	SortedRunCount  int
	TotalSize       int64
	OldestSST       time.Time
}

type SSTCache = diskcache.RefCountedCache

type SSTCacheStats = diskcache.Stats

type SSTHashSigner interface {
	Algorithm() string
	KeyID() string
	SignHash(hash []byte) ([]byte, error)
}

type SSTHashVerifier interface {
	VerifyHash(hash []byte, sig SSTSignature) error
}

type SSTIterator interface {
	Next() bool
	Entry() internal.MemEntry
	Err() error
	Close() error
}

type SSTMeta = manifest.SSTMeta

type SSTSignature = manifest.SSTSignature

type SSTWriterOptions struct {
	BloomBitsPerKey int
	BlockSize       int
	Compression     string
	Signer          SSTHashSigner
}

type SortedRun = manifest.SortedRun

type TailOptions struct {
	// MinKey and MaxKey constrain the tailing range (inclusive bounds).
	MinKey []byte
	MaxKey []byte

	// StartAfterKey resumes tailing from the next key after this value.
	// If set, it overrides MinKey as the lower bound.
	StartAfterKey []byte
	// PollInterval controls how often to check for new keys.
	PollInterval time.Duration
}

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

type TailingReaderOpenOptions struct {
	RefreshInterval time.Duration
	OnRefresh       func()
	OnRefreshError  func(error)

	ReaderOptions ReaderOpenOptions
}

type TailingReaderOptions struct {
	RefreshInterval time.Duration

	OnRefresh      func()
	OnRefreshError func(error)

	ReaderOptions ReaderOptions
}

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

type WriterMetrics struct {
	FlushTotal        prometheus.Counter
	FlushErrors       prometheus.Counter
	FlushLatency      prometheus.Histogram
	FlushBytes        prometheus.Counter
	PutTotal          prometheus.Counter
	PutErrors         prometheus.Counter
	BackPressureTotal prometheus.Counter
	PutBlobTotal      prometheus.Counter
	PutBlobErrors     prometheus.Counter
	PutBlobLatency    prometheus.Histogram
	BlobBytesTotal    prometheus.Counter
	DeleteTotal       prometheus.Counter
}

type WriterOptions struct {
	MemtableSize    int64
	FlushInterval   time.Duration
	BloomBitsPerKey int
	BlockSize       int
	Compression     string
	// MaxImmutableMemtables limits pending memtables waiting to be flushed.
	// When the limit is reached, writers return ErrBackpressure.
	MaxImmutableMemtables int

	OnFlushError func(error)
	ValueStorage config.ValueStorageConfig
	OwnerID      string

	Metrics *WriterMetrics
}