tidesdb_go

Jun 9, 2026

Changes in this version

+ const ComparatorCaseInsensitive

+ const ComparatorInt64

+ const ComparatorLexicographic

+ const ComparatorMemcmp

+ const ComparatorReverse

+ const ComparatorUint64

+ const ErrBusy

+ func RaiseOpenFileLimit(desired int64) int64

type ColumnFamilyConfig

+ ComparatorCtxStr string

type Config

+ FinishCompactionsOnClose bool

type DbStats

+ CompactionBytesRead uint64

+ CompactionBytesWritten uint64

+ CompactionCount uint64

+ FlushBytesWritten uint64

+ FlushCount uint64

+ UserBytesWritten uint64

+ UwalBytesWritten uint64

+ WalBytesWritten uint64

type Stats

+ CompactionBytesRead uint64

+ CompactionBytesWritten uint64

+ CompactionCount uint64

+ FlushBytesWritten uint64

+ FlushCount uint64

+ UserBytesWritten uint64

+ WalBytesWritten uint64

type TidesDB

+ func (db *TidesDB) CancelBackgroundWork() error

Apr 27, 2026

Changes in this version

type ColumnFamily

+ func (cf *ColumnFamily) CompactRange(startKey, endKey []byte) error

type ColumnFamilyConfig

+ TombstoneDensityMinEntries uint64

+ TombstoneDensityTrigger float64

type Config

+ MaxConcurrentFlushes int

type Stats

+ LevelTombstoneCounts []uint64

+ MaxSSTDensity float64

+ MaxSSTDensityLevel int

+ TombstoneRatio float64

+ TotalTombstones uint64

Apr 24, 2026

Changes in this version

type Transaction

+ func (txn *Transaction) SingleDelete(cf *ColumnFamily, key []byte) error

Mar 27, 2026

Changes in this version

+ const ErrReadonly

+ func CfConfigSaveToIni(iniFile, sectionName string, config ColumnFamilyConfig) error

+ func Finalize()

+ func Init() error

type ColumnFamilyConfig

+ ObjectLazyCompaction int

+ ObjectPrefetchCompaction int

+ ObjectTargetFileSize uint64

+ func CfConfigLoadFromIni(iniFile, sectionName string) (*ColumnFamilyConfig, error)

type Config

+ ObjectStore *ObjStore

+ ObjectStoreConfig *ObjStoreConfig

+ UnifiedMemtable bool

+ UnifiedMemtableSkipListMaxLevel int

+ UnifiedMemtableSkipListProbability float64

+ UnifiedMemtableSyncInterval uint64

+ UnifiedMemtableSyncMode SyncMode

+ UnifiedMemtableWriteBufferSize uint64

type DbStats

+ LastUploadedGeneration uint64

+ LocalCacheBytesMax uint64

+ LocalCacheBytesUsed uint64

+ LocalCacheNumFiles int

+ ObjectStoreConnector string

+ ObjectStoreEnabled bool

+ ReplicaMode bool

+ TotalUploadFailures uint64

+ TotalUploads uint64

+ UnifiedImmutableCount int

+ UnifiedIsFlushing bool

+ UnifiedMemtableBytes int64

+ UnifiedMemtableEnabled bool

+ UnifiedNextCFIndex uint32

+ UnifiedWalGeneration uint64

+ UploadQueueDepth uint64

type Iterator

+ func (iter *Iterator) KeyValue() ([]byte, []byte, error)

+ type ObjStore struct

+ func ObjStoreFsCreate(rootDir string) (*ObjStore, error)

+ type ObjStoreBackend int

+ const BackendFS

+ const BackendS3

+ const BackendUnknown

+ type ObjStoreConfig struct

+ CacheOnRead bool

+ CacheOnWrite bool

+ LocalCacheMaxBytes uint64

+ LocalCachePath string

+ MaxConcurrentDownloads int

+ MaxConcurrentUploads int

+ MultipartPartSize uint64

+ MultipartThreshold uint64

+ ReplicaMode bool

+ ReplicaReplayWal bool

+ ReplicaSyncIntervalUs uint64

+ ReplicateWal bool

+ SyncManifestToObject bool

+ WalSyncOnCommit bool

+ WalSyncThresholdBytes uint64

+ WalUploadSync bool

+ func ObjStoreDefaultConfig() ObjStoreConfig

type TidesDB

+ func (db *TidesDB) PromoteToPrimary() error

Mar 13, 2026

Changes in this version

type ColumnFamily

+ func (cf *ColumnFamily) PurgeCF() error

+ func (cf *ColumnFamily) SyncWal() error

+ type DbStats struct

+ AvailableMemory uint64

+ CompactionQueueSize uint64

+ FlushPendingCount int

+ FlushQueueSize uint64

+ GlobalSeq uint64

+ MemoryPressureLevel int

+ NumColumnFamilies int

+ NumOpenSstables int

+ ResolvedMemoryLimit uint64

+ TotalDataSizeBytes uint64

+ TotalImmutableCount int

+ TotalMemory uint64

+ TotalMemtableBytes int64

+ TotalSstableCount int

+ TxnMemoryBytes int64

type TidesDB

+ func (db *TidesDB) GetDbStats() (*DbStats, error)

+ func (db *TidesDB) Purge() error

Mar 7, 2026

Changes in this version

type Config

+ MaxMemoryUsage uint64

type TidesDB

+ func (db *TidesDB) GetComparator(name string) (bool, error)

Feb 21, 2026

Changes in this version

type ColumnFamily

+ func (cf *ColumnFamily) ClearCommitHook() error

+ func (cf *ColumnFamily) SetCommitHook(fn CommitHookFunc) error

+ type CommitHookFunc func(ops []CommitOp, commitSeq uint64) int

+ type CommitOp struct

+ IsDelete bool

+ Key []byte

+ TTL int64

+ Value []byte

Feb 20, 2026

Changes in this version

type ColumnFamily

+ func (cf *ColumnFamily) RangeCost(keyA, keyB []byte) (float64, error)

type TidesDB

+ func (db *TidesDB) DeleteColumnFamily(cf *ColumnFamily) error

Feb 12, 2026

Changes in this version

type TidesDB

+ func (db *TidesDB) Checkpoint(checkpointDir string) error

Feb 11, 2026

Changes in this version

type TidesDB

+ func (db *TidesDB) CloneColumnFamily(sourceName, destName string) error

type Transaction

+ func (txn *Transaction) Reset(isolation IsolationLevel) error

Feb 2, 2026

Changes in this version

type ColumnFamilyConfig

+ UseBtree int

type Stats

+ BtreeAvgHeight float64

+ BtreeMaxHeight uint32

+ BtreeTotalNodes uint64

+ UseBtree bool

Jan 27, 2026

Changes in this version

type Config

+ LogToFile bool

+ LogTruncationAt uint64

Jan 26, 2026

Changes in this version

type ColumnFamily

+ func (cf *ColumnFamily) IsCompacting() bool

+ func (cf *ColumnFamily) IsFlushing() bool

+ func (cf *ColumnFamily) UpdateRuntimeConfig(config ColumnFamilyConfig, persistToDisk bool) error

type CompressionAlgorithm

+ const SnappyCompression

type Stats

+ AvgKeySize float64

+ AvgValueSize float64

+ HitRate float64

+ LevelKeyCounts []uint64

+ ReadAmp float64

+ TotalDataSize uint64

+ TotalKeys uint64

type TidesDB

+ func (db *TidesDB) Backup(dir string) error

+ func (db *TidesDB) RenameColumnFamily(oldName, newName string) error

Jan 22, 2026

Changes in this version

+ const ErrConflict

+ const ErrCorruption

+ const ErrExists

+ const ErrIO

+ const ErrInvalidArgs

+ const ErrInvalidDB

+ const ErrLocked

+ const ErrMemory

+ const ErrMemoryLimit

+ const ErrNotFound

+ const ErrSuccess

+ const ErrTooLarge

+ const ErrUnknown

+ type CacheStats struct

+ Enabled bool

+ HitRate float64

+ Hits uint64

+ Misses uint64

+ NumPartitions uint64

+ TotalBytes uint64

+ TotalEntries uint64

type ColumnFamily

+ func (cf *ColumnFamily) FlushMemtable() error

+ func (cf *ColumnFamily) GetStats() (*Stats, error)

type ColumnFamilyConfig

+ BlockIndexPrefixLen int

+ BloomFPR float64

+ CompressionAlgorithm CompressionAlgorithm

+ DefaultIsolationLevel IsolationLevel

+ DividingLevelOffset int

+ EnableBlockIndexes bool

+ EnableBloomFilter bool

+ IndexSampleRatio int

+ KlogValueThreshold uint64

+ L0QueueStallThreshold int

+ L1FileCountTrigger int

+ LevelSizeRatio uint64

+ MinDiskSpace uint64

+ MinLevels int

+ SkipListMaxLevel int

+ SkipListProbability float32

+ SyncIntervalUs uint64

+ WriteBufferSize uint64

+ type CompressionAlgorithm int

+ const LZ4Compression

+ const LZ4FastCompression

+ const NoCompression

+ const ZstdCompression

type Config

+ BlockCacheSize uint64

+ LogLevel LogLevel

+ MaxOpenSSTables uint64

+ NumCompactionThreads int

+ NumFlushThreads int

+ func DefaultConfig() Config

+ type IsolationLevel int

+ const IsolationReadCommitted

+ const IsolationReadUncommitted

+ const IsolationRepeatableRead

+ const IsolationSerializable

+ const IsolationSnapshot

type Iterator

+ func (iter *Iterator) Seek(key []byte) error

+ func (iter *Iterator) SeekForPrev(key []byte) error

+ type LogLevel int

+ const LogDebug

+ const LogError

+ const LogFatal

+ const LogInfo

+ const LogNone

+ const LogWarn

+ type Stats struct

+ Config *ColumnFamilyConfig

+ LevelNumSSTables []int

+ LevelSizes []uint64

+ MemtableSize uint64

+ NumLevels int

+ type SyncMode int

+ const SyncFull

+ const SyncInterval

+ const SyncNone

type TidesDB

+ func (db *TidesDB) BeginTxnWithIsolation(isolation IsolationLevel) (*Transaction, error)

+ func (db *TidesDB) GetCacheStats() (*CacheStats, error)

+ func (db *TidesDB) RegisterComparator(name string, ctxStr string) error

type Transaction

+ func (txn *Transaction) ReleaseSavepoint(name string) error

+ func (txn *Transaction) RollbackToSavepoint(name string) error

+ func (txn *Transaction) Savepoint(name string) error

Nov 3, 2025

Changes in this version

+ const TDB_ERROR

+ const TDB_ERR_CHECKSUM

+ const TDB_ERR_COMPARATOR_NOT_FOUND

+ const TDB_ERR_CORRUPT

+ const TDB_ERR_EXISTS

+ const TDB_ERR_FULL

+ const TDB_ERR_INVALID_ARGS

+ const TDB_ERR_INVALID_CF

+ const TDB_ERR_INVALID_NAME

+ const TDB_ERR_IO

+ const TDB_ERR_LOCK

+ const TDB_ERR_MAX_COMPARATORS

+ const TDB_ERR_MEMORY

+ const TDB_ERR_NOT_FOUND

+ const TDB_ERR_READONLY

+ const TDB_ERR_THREAD

+ const TDB_ERR_TXN_ABORTED

+ const TDB_ERR_TXN_COMMITTED

+ const TDB_SUCCESS

+ type ColumnFamily struct

+ func (cf *ColumnFamily) Compact() error

type ColumnFamilyConfig

+ BackgroundCompactionInterval int

+ BloomFilterFPRate float64

+ CompactionThreads int

+ ComparatorName *string

+ EnableBackgroundCompaction bool

+ MaxSSTablesBeforeCompaction int

+ MemtableFlushSize int

+ SyncInterval int

+ SyncMode TidesDBSyncMode

+ UseSBHA bool

+ func DefaultColumnFamilyConfig() ColumnFamilyConfig

type ColumnFamilyStat

+ ComparatorName string

+ MemtableEntries int

+ TotalSSTableSize int64

+ type Config struct

+ DBPath string

+ EnableDebugLogging bool

+ type Iterator struct

+ func (iter *Iterator) Free()

+ func (iter *Iterator) Key() ([]byte, error)

+ func (iter *Iterator) Next()

+ func (iter *Iterator) Prev()

+ func (iter *Iterator) SeekToFirst() error

+ func (iter *Iterator) SeekToLast() error

+ func (iter *Iterator) Valid() bool

+ func (iter *Iterator) Value() ([]byte, error)

type TidesDB

+ func (db *TidesDB) BeginReadTxn() (*Transaction, error)

+ func (db *TidesDB) GetColumnFamily(name string) (*ColumnFamily, error)

+ func (db *TidesDB) GetColumnFamilyStats(name string) (*ColumnFamilyStat, error)

+ type TidesDBSyncMode int

+ const TDB_SYNC_BACKGROUND

+ const TDB_SYNC_FULL

+ const TDB_SYNC_NONE

type Transaction

+ func (txn *Transaction) NewIterator(columnFamily string) (*Iterator, error)

Apr 13, 2025

Changes in this version

+ type MergeCursor struct

+ func (c *MergeCursor) Free() error

+ func (c *MergeCursor) Get() ([]byte, []byte, error)

+ func (c *MergeCursor) Next() error

+ func (c *MergeCursor) Prev() error

type TidesDB

+ func (db *TidesDB) MergeCursorInit(columnFamily string) (*MergeCursor, error)

Mar 23, 2025

Changes in this version

+ type ColumnFamilyConfig struct

+ BloomFilter bool

+ CompressAlgo TidesDBCompressionAlgo

+ Compressed bool

+ FlushThreshold int32

+ MaxLevel int32

+ Name string

+ Probability float32

+ type ColumnFamilySSTableStat struct

+ NumBlocks int64

+ Path string

+ Size int64

+ type ColumnFamilyStat struct

+ Config ColumnFamilyConfig

+ IncrementalMerging bool

+ MemtableEntryCount int64

+ MemtableSize int64

+ Name string

+ NumSSTables int

+ SSTableStats []*ColumnFamilySSTableStat

type TidesDB

+ func (db *TidesDB) GetColumnFamilyStat(columnFamilyName string) (*ColumnFamilyStat, error)

Mar 22, 2025

Changes in this version

+ type Cursor struct

+ func (c *Cursor) Free() error

+ func (c *Cursor) Get() ([]byte, []byte, error)

+ func (c *Cursor) Next() error

+ func (c *Cursor) Prev() error

+ type TidesDB struct

+ func Open(directory string) (*TidesDB, error)

+ func (db *TidesDB) BeginTxn(columnFamily string) (*Transaction, error)

+ func (db *TidesDB) Close() error

+ func (db *TidesDB) CompactSSTables(columnFamilyName string, maxThreads int) error

+ func (db *TidesDB) CreateColumnFamily(name string, flushThreshold, maxLevel int, probability float32, ...) error

+ func (db *TidesDB) CursorInit(columnFamily string) (*Cursor, error)

+ func (db *TidesDB) Delete(columnFamilyName string, key []byte) error

+ func (db *TidesDB) DeleteByRange(columnFamilyName string, startKey, endKey []byte) error

+ func (db *TidesDB) DropColumnFamily(name string) error

+ func (db *TidesDB) Get(columnFamilyName string, key []byte) ([]byte, error)

+ func (db *TidesDB) ListColumnFamilies() (string, error)

+ func (db *TidesDB) Put(columnFamilyName string, key, value []byte, ttl int64) error

+ func (db *TidesDB) Range(columnFamilyName string, startKey, endKey []byte) ([][2][]byte, error)

+ func (db *TidesDB) StartIncrementalMerge(columnFamilyName string, seconds, minSSTables int) error

+ type TidesDBCompressionAlgo int

+ const TDB_COMPRESS_LZ4

+ const TDB_COMPRESS_SNAPPY

+ const TDB_COMPRESS_ZSTD

+ const TDB_NO_COMPRESSION

+ type Transaction struct

+ func (txn *Transaction) Commit() error

+ func (txn *Transaction) Delete(key []byte) error

+ func (txn *Transaction) Free() error

+ func (txn *Transaction) Get(key []byte) ([]byte, error)

+ func (txn *Transaction) Put(key, value []byte, ttl int64) error

+ func (txn *Transaction) Rollback() error