storage

Nov 11, 2026

Changes in this version

+ func SetTwinVerification(on bool) (previous bool)

+ func TwinTakes() (rows, indexes uint64)

type DB

+ func (db *DB) BeginCatalogSnapshot() CatalogSnapshot

Nov 9, 2026

Changes in this version

+ func WriteReplicationSnapshot(ctx context.Context, db *DB, wal *AdvancedWAL, w io.Writer) (watermark, epoch uint64, err error)

type DB

+ func LoadReplicationSnapshot(ctx context.Context, r io.Reader) (*DB, error)

+ func (db *DB) DetachAllPinnedForWrite()

+ func (db *DB) SnapshotForReadTxShared() (shadow *DB, release func())

+ func (db *DB) SnapshotForTxShared() (base, shadow *DB, release func())

+ type DerivedBorrower interface

+ BorrowDerived func() (any, bool)

Nov 6, 2026

Changes in this version

type DB

+ func (db *DB) SnapshotForRowsOnlyStatement(tenant, name string) (*StatementSnapshot, error)

Oct 11, 2026

Changes in this version

type DB

+ func (db *DB) SnapshotForReadTx() *DB

+ func (db *DB) SnapshotForWriteTx() *DB

+ type IndexNextBounds struct

+ Hi IndexRangeBound

+ Lo IndexRangeBound

type Table

+ func (t *Table) LookupSecondaryIndexRangeNext(idx *SecondaryIndex, prefix []any, lo, hi IndexRangeBound, ...) ([]int, error)

Sep 27, 2026

Changes in this version

+ func CloneVectorTopology(levels []int, neighbors [][][]int) ([]int, [][][]int)

Sep 14, 2026

Changes in this version

+ var ErrJobAlreadyRunning = errors.New("job already running")

+ var ErrJobQueueFull = errors.New("job queue is full")

+ var ErrSchedulerStopped = errors.New("scheduler is stopped")

type CatalogJob

+ MaxAttempts int

+ RetryDelayMs int64

type CatalogJobHistory

+ Attempts int

+ IdempotencyKey string

+ QueueWaitMs int64

+ QueuedAt time.Time

+ StartDelayMs int64

type CatalogManager

+ func (c *CatalogManager) ReserveJobRunID() int64

+ type ChangeWatch struct

+ C <-chan struct{}

+ func (w *ChangeWatch) Close()

+ func (w *ChangeWatch) SetTables(refs []TableRef)

+ func (w *ChangeWatch) Stats() ChangeWatchStats

+ type ChangeWatchStats struct

+ Broadcasts uint64

+ Coalesced uint64

+ Notifications uint64

type Column

+ StrictJSON bool

type DB

+ func (db *DB) HasChangeWatchers() bool

+ func (db *DB) UnlockContentForWriteTables(refs []TableRef)

+ func (db *DB) WatchChanges() (<-chan struct{}, func(), error)

+ func (db *DB) WatchTableChanges(refs []TableRef) (*ChangeWatch, error)

+ type JobRunInfo struct

+ Attempt int

+ IdempotencyKey string

+ RunID int64

+ func JobRunFromContext(ctx context.Context) (JobRunInfo, bool)

type Scheduler

+ func (s *Scheduler) RetryJob(name string) (int64, error)

+ func (s *Scheduler) SetMaxQueuedJobs(n int)

+ func (s *Scheduler) Stats() SchedulerStats

+ func (s *Scheduler) SubmitJob(job *CatalogJob) (int64, error)

+ type SchedulerStats struct

+ Completed uint64

+ LastStartDelay time.Duration

+ MaxStartDelay time.Duration

+ OldestQueuedAge time.Duration

+ QueueLimit int

+ Queued int

+ Rejected uint64

+ Retried uint64

+ Running int

+ TotalQueueWait time.Duration

+ WorkerLimit int

Sep 5, 2026

Changes in this version

+ const FTSPostingBlockSize

+ var ErrTableNotFound = errors.New("no such table")

type FTSIndex

+ PostingBlocks map[string][]FTSPostingBlock

+ PostingCounts map[string][]int32

+ type FTSPostingBlock struct

+ MaxFrequency int32

+ MinDocLen float64

Aug 30, 2026

Changes in this version

+ var ErrSaveToFileWouldBypassWALWatermark = errors.New(...)

Aug 27, 2026

Changes in this version

+ var ErrAdvancedWALCheckpointActiveTransactions = errors.New("advanced WAL checkpoint requires all transactions to be committed or aborted")

+ var ErrReplicaEpochMismatch = errors.New("replica WAL epoch does not match its bootstrap snapshot")

+ var ErrReplicaWALOrder = errors.New("replica WAL records are not strictly ordered")

+ func ApplyReplicaWALRecords(db *DB, epoch uint64, records []WALRecord) (int, error)

+ func InitializeReplicaState(db *DB, epoch, watermark uint64) error

+ func ReadCheckpointDataWatermark(filename string) (uint64, error)

+ func ReplicaApplyWatermark(db *DB) (epoch, appliedLSN uint64)

type AdvancedWAL

+ func (w *AdvancedWAL) CheckpointRequested() bool

+ func (w *AdvancedWAL) CheckpointWhileContentLocked(db *DB) error

+ func (w *AdvancedWAL) RequestCheckpoint()

type DB

+ func (db *DB) AdvancedWALMetadataDirty() bool

+ func (db *DB) DetachPinnedTableForSchemaWrite(tenant, name string) bool

+ func (db *DB) DetachPinnedTableForWrite(tenant, name string) bool

+ func (db *DB) IsTablePinnedForStream(table *Table) bool

+ func (db *DB) MarkAdvancedWALMetadataDirty()

+ func (db *DB) OpenPagedIndexRangeCursor(tenant, table, indexName string, startKey, endKey []byte) (cursor *PagedRowCursor, ok bool, err error)

+ func (db *DB) OpenPagedTableCursor(tenant, table string) (cursor *PagedRowCursor, ok bool, err error)

+ func (db *DB) PinTableForStream(table *Table) (release func(), ok bool)

type FTSIndex

+ StaleTerms int

+ StaleTokens int

+ type PagedRowCursor struct

+ func (c *PagedRowCursor) Done() bool

+ func (c *PagedRowCursor) NextBatch(limit int) ([][]any, error)

type Table

+ VectorIndexes map[string]*VectorIndex

+ func (t *Table) MarkVectorIndexesChanged()

+ func (t *Table) MarkVectorIndexesPersisted(generation int)

+ func (t *Table) UpdatedRowsSince(version int) (rows []int, ok bool)

+ func (t *Table) VectorIndexesPersistenceState() (generation int, dirty bool)

+ type VectorIndex struct

+ BuiltRows int

+ Column int

+ Dims int

+ Entry int

+ Format int

+ Kind string

+ Levels []int

+ MaxLevel int

+ Metric string

+ Neighbors [][][]int

+ StructVersion int

+ Version int

Aug 26, 2026

Changes in this version

+ type FTSDocument struct

+ DocLen float64

+ TermCount int32

+ TermStart int32

+ TokenCount int32

+ TokenStart int32

+ Valid bool

+ type FTSIndex struct

+ AvgDocLen float64

+ BuiltRows int

+ DocTermCounts []int32

+ DocTermIDs []int32

+ DocTokenIDs []int32

+ Docs []FTSDocument

+ Format int

+ NumDocs int

+ Postings map[string][]int32

+ StructVersion int

+ TermIDs map[string]int32

+ TotalDocLen float64

+ Version int

type Table

+ FTSIndexes map[string]*FTSIndex

+ func (t *Table) FTSIndexesPersistenceState() (generation int, dirty bool)

+ func (t *Table) MarkFTSIndexesChanged()

+ func (t *Table) MarkFTSIndexesPersisted(generation int)

Aug 25, 2026

Changes in this version

type CatalogManager

+ func (c *CatalogManager) RenameIndexColumnForTenant(tenant, table, from, to string)

type Table

+ func (t *Table) AnalyzeSummary() (rowCount, columnCount int, analyzedAt time.Time)

+ func (t *Table) RenameColumn(from, to string) error

Aug 21, 2026

Changes in this version

type BackendStats

+ AdmissionRejects int64

+ LargestRejectedBytes int64

type CacheStats

+ AdmissionRejects int64

+ LargestRejectedBytes int64

Aug 20, 2026

Changes in this version

type DB

+ func (db *DB) Replace(tn string, t *Table) error

+ type DerivedCloner interface

+ CloneDerived func() any

Aug 19, 2026

Changes in this version

type Scheduler

+ func (s *Scheduler) SetMaxConcurrentJobs(n int)

Aug 16, 2026

Changes in this version

type AdvancedWALConfig

+ SyncMode WALSyncMode

type StorageConfig

+ WALSync WALSyncMode

type WALConfig

+ SyncMode WALSyncMode

+ type WALSyncMode uint8

+ const WALSyncFull

+ const WALSyncNormal

+ func ParseWALSyncMode(s string) (WALSyncMode, error)

+ func (m WALSyncMode) String() string

Aug 15, 2026

Changes in this version

type CatalogManager

+ func (c *CatalogManager) HasMaterializedViews() bool

type DB

+ func (db *DB) ReleaseStatementSnapshot(snapshot *StatementSnapshot)

type PagedIndexLocator

+ func (locator *PagedIndexLocator) LookupUniqueBytesColumn(key []byte, column int, visit func([]byte) error) (bool, error)

type StatementSnapshot

+ func (s *StatementSnapshot) RestoredTables() ([]TableRef, bool)

type Table

+ func (t *Table) AddColumn(col Column) error

+ func (t *Table) Derived() any

+ func (t *Table) DerivedLock()

+ func (t *Table) DerivedUnlock()

+ func (t *Table) SetDerived(v any)

+ type TableRef struct

+ Table string

+ Tenant string

Aug 10, 2026

Changes in this version

type SecondaryIndex

+ func (idx *SecondaryIndex) Len() int

+ type SkipList struct

+ func NewSkipList() *SkipList

+ func (s *SkipList) All() []IndexEntry

+ func (s *SkipList) Clone() *SkipList

+ func (s *SkipList) Get(key []byte) (rowIDs []int, found bool)

+ func (s *SkipList) Insert(key []byte, rowID int)

+ func (s *SkipList) Len() int

+ func (s *SkipList) Range(startKey []byte, fn func(key []byte, rowIDs []int) bool)

+ func (s *SkipList) Remove(key []byte, rowID int) (removed bool)

Aug 8, 2026

Changes in this version

type Table

+ func (t *Table) StructVersion() int

+ func (t *Table) SwapRemoveSecondaryIndexRow(deleteRowID int, deletedRow []any, lastRowID int, lastRow []any, ...) error

Aug 8, 2026

Changes in this version

+ var ErrReplicaTooFarBehind = errors.New(...)

+ func ReadCheckpointEpoch(filename string) (uint64, error)

+ func SnapshotWithWatermark(db *DB, wal *AdvancedWAL) (data []byte, watermark uint64, epoch uint64, err error)

type AdvancedWAL

+ func (w *AdvancedWAL) Epoch() uint64

type Table

+ func ApplyWALRecord(db *DB, record *WALRecord) (*Table, error)

+ func (t *Table) SortedIndexNames() []string

type WALRecord

+ func ReadCommittedSince(wal *AdvancedWAL, sinceLSN uint64) ([]WALRecord, uint64, error)

Aug 6, 2026

Changes in this version

type PagedIndexLocator

+ func (locator *PagedIndexLocator) ContainsUnique(key []byte) (bool, error)

Aug 5, 2026

Changes in this version

+ func AppendCanonicalIndexValue(dst []byte, value any) []byte

type DB

+ func (db *DB) LocatePagedIndex(tenant, table, indexName string) (*PagedIndexLocator, bool, error)

type PagedIndexBackend

+ func (b *PagedIndexBackend) LocateIndex(tenant, table, indexName string) (*PagedIndexLocator, bool, error)

+ type PagedIndexLocator struct

+ func (locator *PagedIndexLocator) LookupUniqueColumn(key []byte, column int, visit func(any) error) (bool, error)

Aug 5, 2026

Changes in this version

type DB

+ func (db *DB) ScanPagedIndexRange(tenant, table, indexName string, startValues, endValues []any, ...) (bool, error)

type PagedIndexBackend

+ func (b *PagedIndexBackend) ScanIndexRowsRange(tenant, table, indexName string, startValues, endValues []any, ...) error

Aug 4, 2026

Changes in this version

+ type SQLiteBackend struct

+ func NewSQLiteBackend(path string) (*SQLiteBackend, error)

+ func (b *SQLiteBackend) Close() error

+ func (b *SQLiteBackend) DeleteTable(tenant, name string) error

+ func (b *SQLiteBackend) ListTableNames(tenant string) ([]string, error)

+ func (b *SQLiteBackend) LoadTable(tenant, name string) (*Table, error)

+ func (b *SQLiteBackend) Mode() StorageMode

+ func (b *SQLiteBackend) SaveTable(tenant string, t *Table) error

+ func (b *SQLiteBackend) SetReadOnly(ro bool)

+ func (b *SQLiteBackend) Stats() BackendStats

+ func (b *SQLiteBackend) Sync() error

+ func (b *SQLiteBackend) TableExists(tenant, name string) bool

type StorageMode

+ const ModeSQLite

Aug 2, 2026

Changes in this version

type DB

+ func (db *DB) AppendRowsFast(tenant, tableName string, newRows [][]any) (ok bool, err error)

+ func (db *DB) DiscardCachedTable(tenant, name string) bool

+ func (db *DB) ScanRowsFast(tenant, tableName string, fn func(row []any) bool) (ok bool, err error)

type PagedIndexBackend

+ func (b *PagedIndexBackend) AppendRows(tenant, name string, newRows [][]any, newIndexKeys map[string][][]byte) (int64, error)

+ func (b *PagedIndexBackend) ScanRows(tenant, name string, fn func(row []any) bool) error

Aug 1, 2026

Changes in this version

+ var ErrIndexRangeUnsupported = errors.New("secondary index cannot serve this range")

+ func IndexRangeComponentEncodable(v any) bool

+ type IndexRangeBound struct

+ Absent bool

+ Inclusive bool

+ Value any

type Table

+ func (t *Table) LookupSecondaryIndexRange(idx *SecondaryIndex, prefix []any, lo, hi IndexRangeBound) ([]int, error)

Jul 29, 2026

Changes in this version

type DB

+ func (db *DB) SnapshotForRowDeleteStatement(tenant, name string, rowIDs []int) (*StatementSnapshot, error)

+ func (db *DB) SnapshotForRowUpdateStatement(tenant, name string, rowIDs []int) (*StatementSnapshot, error)

type Table

+ func (t *Table) DeleteSecondaryIndexRow(rowID int)

Jul 26, 2026

Changes in this version

type CatalogManager

+ func (c *CatalogManager) Revision() uint64

+ type CatalogSnapshot struct

+ func (s CatalogSnapshot) Equal(other CatalogSnapshot) bool

type DB

+ func (db *DB) AbortAmbientWALTx() error

+ func (db *DB) AdoptCatalog(catalog *CatalogManager)

+ func (db *DB) AmbientWALTx() (TxID, bool)

+ func (db *DB) BeginAmbientWALTx() (bool, error)

+ func (db *DB) CommitAmbientWALTx() error

+ func (db *DB) IsClosed() bool

+ func (db *DB) IsShadow() bool

+ func (db *DB) MetaSnapshot() *DB

+ func (db *DB) PromoteShadow()

+ func (db *DB) SnapshotCatalog() CatalogSnapshot

+ func (db *DB) StatementAdvancedWAL() *AdvancedWAL

+ func (db *DB) StatementWAL() *WALManager

type Table

+ func (t *Table) DirtyRows() ([]int, bool)

+ func (t *Table) MarkRowUpdated(idx int)

Jul 22, 2026

Changes in this version

type BufferPool

+ func (bp *BufferPool) SetEvictionSaver(f func(tenant, name string, table *Table))

+ func (bp *BufferPool) Snapshot() []PooledEntry

type CatalogManager

+ func (c *CatalogManager) GetTriggersForEvent(table string, event TriggerEvent) (before, after []*CatalogTrigger)

type HybridBackend

+ func (h *HybridBackend) IsDirty(tenant, name string, currentVersion int) bool

+ func (h *HybridBackend) PooledTables() []PooledTableRef

type PagedIndexBackend

+ func (b *PagedIndexBackend) IsDirty(tenant, name string, currentVersion int) bool

+ func (b *PagedIndexBackend) PooledTables() []PooledTableRef

+ type PooledEntry struct

+ Name string

+ Table *Table

+ Tenant string

+ type PooledTableRef struct

+ Table *Table

+ Tenant string

Jul 16, 2026

Changes in this version

+ func CanonicalIndexValueEqual(left, right any) bool

+ func ReadCheckpointWatermark(filename string) (uint64, error)

type CatalogIndex

+ Tenant string

type CatalogManager

+ func (c *CatalogManager) DeleteIndexForTenant(tenant, schema, name string) error

+ func (c *CatalogManager) DeleteIndexesForTenantTable(tenant, table string)

+ func (c *CatalogManager) GetIndexForTenant(tenant, schema, name string) (*CatalogIndex, bool)

+ func (c *CatalogManager) GetIndexesForTenant(tenant string) []*CatalogIndex

+ func (c *CatalogManager) RegisterIndexForTenant(tenant string, idx *CatalogIndex) error

type DB

+ func (db *DB) SnapshotForAppendOnlyTableStatement(tenant, name string) (*StatementSnapshot, error)

+ func (db *DB) SnapshotForTableStatement(tenant, name string) (*StatementSnapshot, error)

type WALChange

+ func CollectWALChangesFromSnapshot(snapshot *StatementSnapshot, next *DB) []WALChange

Jul 15, 2026

Changes in this version

+ type ColumnStats struct

+ DistinctCount int

+ HasMinMax bool

+ Max string

+ Min string

+ NullCount int

type DB

+ func (db *DB) Extensions() []ExtensionInfo

+ func (db *DB) RestoreStatementSnapshot(snapshot *StatementSnapshot)

+ func (db *DB) SnapshotForStatement() *StatementSnapshot

+ func (db *DB) SnapshotForTx() (base *DB, shadow *DB)

+ func (db *DB) Use(extension Extension) error

+ type Extension interface

+ ExtensionInfo func() ExtensionInfo

+ Register func(db *DB) error

+ type ExtensionCapability string

+ const CapabilityFilesystem

+ const CapabilityNetwork

+ const CapabilitySecrets

+ const CapabilityWrite

+ type ExtensionInfo struct

+ Capabilities []ExtensionCapability

+ Description string

+ LoadedAt time.Time

+ Name string

+ Version string

+ type StatementSnapshot struct

type Table

+ Stats *TableStats

+ func (t *Table) Analyze() *TableStats

+ func (t *Table) ClearSecondaryIndexes()

+ func (t *Table) InsertSecondaryIndexRow(rowID int, row []any) error

+ func (t *Table) InvalidateStats()

+ func (t *Table) ReindexSecondaryIndexRows(oldToNew map[int]int)

+ func (t *Table) Statistics() *TableStats

+ func (t *Table) UpdateSecondaryIndexRow(rowID int, before, after []any) error

+ type TableStats struct

+ AnalyzedAt time.Time

+ Columns map[string]ColumnStats

+ RowCount int

+ Stale bool

Jul 14, 2026

Changes in this version

+ var ErrReadOnlyStorage = errors.New("storage is read-only")

+ func CanonicalIndexKey(values []any) []byte

type BackendStats

+ CacheHits int64

+ CacheMisses int64

+ CachedPages int

+ MaxCachePages int

+ PageReads int64

+ PinnedPages int

+ TransientFrames int

+ TransientPages int

type DB

+ func (db *DB) PagedIndexMetadata(tenant, table string) (*Table, bool, error)

+ func (db *DB) PagedIndexRows(tenant, table, indexName string, values []any) ([][]any, bool, error)

type DiskBackend

+ func (b *DiskBackend) IsReadOnly() bool

+ func (b *DiskBackend) SetReadOnly(readOnly bool)

type HybridBackend

+ func (h *HybridBackend) SetReadOnly(readOnly bool)

+ type PagedIndexBackend struct

+ func NewPagedIndexBackend(dir string, maxMemoryBytes int64, readOnly bool) (*PagedIndexBackend, error)

+ func (b *PagedIndexBackend) Close() error

+ func (b *PagedIndexBackend) DeleteTable(tenant, name string) error

+ func (b *PagedIndexBackend) IndexMetadata(tenant, name string) (*Table, error)

+ func (b *PagedIndexBackend) IsReadOnly() bool

+ func (b *PagedIndexBackend) ListTableNames(tenant string) ([]string, error)

+ func (b *PagedIndexBackend) LoadTable(tenant, name string) (*Table, error)

+ func (b *PagedIndexBackend) LookupIndexRows(tenant, table, indexName string, values []any) ([][]any, bool, error)

+ func (b *PagedIndexBackend) Mode() StorageMode

+ func (b *PagedIndexBackend) SaveTable(tenant string, t *Table) error

+ func (b *PagedIndexBackend) SetReadOnly(readOnly bool)

+ func (b *PagedIndexBackend) Stats() BackendStats

+ func (b *PagedIndexBackend) Sync() error

+ func (b *PagedIndexBackend) TableExists(tenant, name string) bool

type StorageMode

+ const ModePagedIndex

Jul 12, 2026

Changes in this version

type Column

+ Affinity SQLiteAffinity

+ DeclaredType string

+ DefaultValue any

+ HasDefault bool

+ NotNull bool

+ type IndexEntry struct

+ Key []byte

+ RowIDs []int

+ type SQLiteAffinity uint8

+ const AffinityBlob

+ const AffinityDefault

+ const AffinityInteger

+ const AffinityNumeric

+ const AffinityReal

+ const AffinityText

+ func (a SQLiteAffinity) String() string

+ type SecondaryIndex struct

+ Columns []string

+ Entries []IndexEntry

+ Name string

+ Unique bool

type Table

+ Indexes map[string]*SecondaryIndex

+ func (t *Table) CheckSecondaryIndexConstraints(row []any, skipRow int) error

+ func (t *Table) CreateSecondaryIndex(name string, columns []string, unique bool) error

+ func (t *Table) DropSecondaryIndex(name string) bool

+ func (t *Table) FindSecondaryIndex(columns []string) *SecondaryIndex

+ func (t *Table) LookupSecondaryIndexPoint(idx *SecondaryIndex, values []any) ([]int, error)

+ func (t *Table) LookupSecondaryIndexPrefix(idx *SecondaryIndex, values []any) ([]int, error)

+ func (t *Table) RebuildSecondaryIndexes() error

Jul 9, 2026

Changes in this version

+ type CatalogIndex struct

+ Columns []string

+ CreatedAt time.Time

+ Name string

+ Schema string

+ Table string

+ Unique bool

type CatalogManager

+ func (c *CatalogManager) DeleteIndex(schema, name string) error

+ func (c *CatalogManager) DeleteIndexesForTable(table string)

+ func (c *CatalogManager) GetIndex(schema, name string) (*CatalogIndex, bool)

+ func (c *CatalogManager) GetIndexes() []*CatalogIndex

+ func (c *CatalogManager) RegisterIndex(idx *CatalogIndex) error

type DB

+ func (db *DB) ApplyWALChanges(changes []WALChange) error

+ func (db *DB) DeepClonePair() (*DB, *DB)

type HybridBackend

+ func (h *HybridBackend) SetEncryptor(enc *Encryptor)

Jul 5, 2026

Changes in this version

+ const EncryptionKeySize

+ const EncryptionSaltSize

+ func DeriveKeyFromPassphrase(passphrase string, salt []byte) []byte

+ func NewEncryptionSalt() ([]byte, error)

+ type AuditEntry struct

+ Error string

+ Hash string

+ PrevHash string

+ Seq uint64

+ Statement string

+ Success bool

+ Tenant string

+ Timestamp time.Time

+ User string

+ type AuditLog struct

+ func NewAuditLog() *AuditLog

+ func OpenAuditLog(path string) (*AuditLog, error)

+ func (a *AuditLog) Append(tenant, user, statement string, success bool, errMsg string) AuditEntry

+ func (a *AuditLog) Close() error

+ func (a *AuditLog) Entries() []AuditEntry

+ func (a *AuditLog) Verify() error

type CatalogManager

+ func (c *CatalogManager) IsRBACEnabled() bool

+ func (c *CatalogManager) SetRBACEnabled(enabled bool)

type DB

+ func (db *DB) AttachAuditLog(log *AuditLog)

+ func (db *DB) AuditLog() *AuditLog

+ func (db *DB) IsRBACEnabled() bool

+ func (db *DB) SetRBACEnabled(enabled bool)

type DiskBackend

+ func (b *DiskBackend) SetEncryptor(enc *Encryptor)

+ type Encryptor struct

+ func NewEncryptor(key []byte) (*Encryptor, error)

+ func (e *Encryptor) Decrypt(blob []byte) ([]byte, error)

+ func (e *Encryptor) Encrypt(plaintext []byte) ([]byte, error)

type StorageConfig

+ EncryptionKey []byte

Jul 4, 2026

Changes in this version

+ func GenerateRandomPassword(n int) (string, error)

type AdvancedWAL

+ func (w *AdvancedWAL) NewAutoTxID() TxID

type CatalogManager

+ func (c *CatalogManager) Authenticate(name, password string) bool

+ func (c *CatalogManager) CreateRole(name string) error

+ func (c *CatalogManager) CreateUser(name, password string, roles []string) error

+ func (c *CatalogManager) DropRole(name string) error

+ func (c *CatalogManager) DropUser(name string) error

+ func (c *CatalogManager) GetUser(name string) (CatalogUser, bool)

+ func (c *CatalogManager) GrantPermission(roleName string, perm Permission, schema, table string) error

+ func (c *CatalogManager) GrantRoleToUser(userName, roleName string) error

+ func (c *CatalogManager) HasPermission(userName string, perm Permission, schema, table string) bool

+ func (c *CatalogManager) HasUsers() bool

+ func (c *CatalogManager) ListRoles() []CatalogRole

+ func (c *CatalogManager) ListUsers() []CatalogUser

+ func (c *CatalogManager) RevokePermission(roleName string, perm Permission, schema, table string) error

+ func (c *CatalogManager) RevokeRoleFromUser(userName, roleName string) error

+ func (c *CatalogManager) SetUserDisabled(name string, disabled bool) error

+ type CatalogRole struct

+ CreatedAt time.Time

+ Grants []Grant

+ Name string

+ type CatalogUser struct

+ CreatedAt time.Time

+ Disabled bool

+ Name string

+ PasswordHash string

+ Roles []string

type DB

+ func (db *DB) LockContentForRead()

+ func (db *DB) LockContentForWrite()

+ func (db *DB) UnlockContentForRead()

+ func (db *DB) UnlockContentForWrite()

type DiskBackend

+ func NewJSONBackend(dir string, compress bool) (*DiskBackend, error)

type ForeignKeyRef

+ OnDelete ReferentialAction

+ OnUpdate ReferentialAction

+ type Grant struct

+ Permission Permission

+ Schema string

+ Table string

+ type Permission string

+ const PermAll

+ const PermDDL

+ const PermDelete

+ const PermInsert

+ const PermSelect

+ const PermUpdate

+ func ParsePermission(s string) (Permission, error)

+ type ReferentialAction int

+ const Cascade

+ const NoAction

+ const Restrict

+ const SetNull

+ func (a ReferentialAction) String() string

type StorageMode

+ const ModeJSON

Jul 3, 2026

Changes in this version

type AdvancedWALConfig

+ CheckpointMaxBytes int64

+ type CatalogDependency struct

+ CreatedAt time.Time

+ DependencyType string

+ DependsOnName string

+ DependsOnSchema string

+ DependsOnType string

+ ObjectName string

+ ObjectType string

+ Schema string

+ type CatalogJobHistory struct

+ DurationMs int64

+ ErrorMessage string

+ FinishedAt time.Time

+ JobName string

+ RunID int64

+ StartedAt time.Time

+ Status string

type CatalogManager

+ func (c *CatalogManager) AddJobHistory(run *CatalogJobHistory) error

+ func (c *CatalogManager) DeleteMaterializedView(schema, name string) error

+ func (c *CatalogManager) DeleteView(schema, name string) error

+ func (c *CatalogManager) FinishMaterializedViewRefresh(schema, name string, refreshedAt time.Time, durationMs int64, rowCount int64, ...) error

+ func (c *CatalogManager) GetDependencies() []CatalogDependency

+ func (c *CatalogManager) GetMaterializedView(schema, name string) (*CatalogMaterializedView, bool)

+ func (c *CatalogManager) GetMaterializedViews() []*CatalogMaterializedView

+ func (c *CatalogManager) GetView(schema, name string) (*CatalogView, bool)

+ func (c *CatalogManager) ListJobHistory() []*CatalogJobHistory

+ func (c *CatalogManager) MarkMaterializedViewsStaleByDependency(schema, changedName string) []string

+ func (c *CatalogManager) RegisterMaterializedView(mv *CatalogMaterializedView) error

+ func (c *CatalogManager) SetDependencies(schema, objectName, objectType string, deps []CatalogDependency)

+ func (c *CatalogManager) TryBeginMaterializedViewRefresh(schema, name string) bool

+ func (c *CatalogManager) UpdateJobRuntimePtr(name string, lastRun time.Time, nextRun *time.Time) error

+ type CatalogMaterializedView struct

+ CacheTableName string

+ CreatedAt time.Time

+ DailyAt string

+ InvalidateOnChange bool

+ IsRefreshing bool

+ IsStale bool

+ LastDurationMs int64

+ LastError string

+ LastRefreshAt *time.Time

+ Name string

+ RefreshEveryMs int64

+ SQLText string

+ Schema string

+ StaleAfterMs int64

+ Timezone string

+ UpdatedAt time.Time

+ WithData bool

type DB

+ func (db *DB) DeleteJob(name string) error

+ func (db *DB) HealthCheck() DBHealth

+ func (db *DB) IsReadOnly() bool

+ func (db *DB) JobScheduler() *Scheduler

+ func (db *DB) RegisterJob(job *CatalogJob) error

+ func (db *DB) RestartJobScheduler(executor JobExecutor) error

+ func (db *DB) SetReadOnly(ro bool)

+ func (db *DB) StartJobScheduler(executor JobExecutor) error

+ func (db *DB) StopJobScheduler()

+ type DBHealth struct

+ AdvancedWALActive bool

+ BackendStats BackendStats

+ Closed bool

+ Closing bool

+ Error string

+ LastCloseAt time.Time

+ LastSyncAt time.Time

+ Mode StorageMode

+ ModeName string

+ OK bool

+ Path string

+ ReadOnly bool

+ Recovery RecoveryStatus

+ SchedulerRunning bool

+ Tables int

+ Tenants int

+ WALActive bool

+ type RecoveryStatus struct

+ CheckpointLoaded bool

+ Mode StorageMode

+ Path string

+ RecoveredAt time.Time

+ RecoveredOperations int

+ RecoveredTransactions uint64

+ Truncated bool

type Scheduler

+ func (s *Scheduler) UpsertJob(job *CatalogJob) error

type StorageConfig

+ CheckpointMaxBytes int64

+ ReadOnly bool

type WALConfig

+ CheckpointMaxBytes int64

Apr 25, 2026

Changes in this version

type CatalogManager

+ func (c *CatalogManager) DropTrigger(name string) error

+ func (c *CatalogManager) GetTriggers(table string, timing TriggerTiming, event TriggerEvent) []*CatalogTrigger

+ func (c *CatalogManager) ListTriggers() []*CatalogTrigger

+ func (c *CatalogManager) RegisterTrigger(t *CatalogTrigger) error

+ type CatalogTrigger struct

+ Body string

+ CreatedAt time.Time

+ Event TriggerEvent

+ ForEachRow bool

+ Name string

+ Table string

+ Timing TriggerTiming

+ WhenExpr string

type ColType

+ const BitmapType

+ const HASHType

+ const URLType

+ const YAMLType

+ type TriggerEvent string

+ const TriggerDelete

+ const TriggerInsert

+ const TriggerUpdate

+ type TriggerTiming string

+ const TriggerAfter

+ const TriggerBefore

+ const TriggerInsteadOf

Apr 8, 2026

Changes in this version

type StorageMode

+ const ModeAdvancedWAL

Feb 15, 2026

Changes in this version

+ func AsBigRat(v any) (*big.Rat, bool)

+ func DecimalAdd(a, b any) (*big.Rat, error)

+ func DecimalFromAny(v any) (*big.Rat, bool)

+ func DecimalToString(r *big.Rat) string

+ func JSONMarshal(v any) ([]byte, error)

+ func ParseUUID(s string) (uuid.UUID, error)

+ func UUIDToBytes(u uuid.UUID) []byte

type ColType

+ const BlobType

+ const DecimalType

+ const GeometryType

+ const IntervalType

+ const MoneyType

+ const UUIDType

+ const XMLType

Feb 14, 2026

Changes in this version

+ type BackendStats struct

+ CacheHitRate float64

+ DiskUsedBytes int64

+ EvictionCount int64

+ LoadCount int64

+ MemoryLimitBytes int64

+ MemoryUsedBytes int64

+ Mode StorageMode

+ SyncCount int64

+ TablesInMemory int

+ TablesOnDisk int

type ColType

+ const VectorType

type DB

+ func OpenDB(cfg StorageConfig) (*DB, error)

+ func (db *DB) Backend() StorageBackend

+ func (db *DB) BackendStats() BackendStats

+ func (db *DB) Close() error

+ func (db *DB) Config() *StorageConfig

+ func (db *DB) Evict(tenant, name string) error

+ func (db *DB) ListTenants() []string

+ func (db *DB) MigrateToBackend(b StorageBackend) error

+ func (db *DB) SetBackend(b StorageBackend)

+ func (db *DB) ShallowCloneForTable(tenant, tableName string) *DB

+ func (db *DB) StorageMode() StorageMode

+ func (db *DB) Sync() error

+ func (db *DB) SyncTable(tenant string, t *Table) error

+ func (db *DB) TableExists(tenant, name string) bool

+ type DiskBackend struct

+ func NewDiskBackend(dir string, compress bool) (*DiskBackend, error)

+ func (b *DiskBackend) Close() error

+ func (b *DiskBackend) DeleteTable(tenant, name string) error

+ func (b *DiskBackend) GetMeta(tenant, name string) *TableMeta

+ func (b *DiskBackend) ImportFromDB(db *DB) error

+ func (b *DiskBackend) IsDirty(tenant, name string, currentVersion int) bool

+ func (b *DiskBackend) ListTableNames(tenant string) ([]string, error)

+ func (b *DiskBackend) LoadTable(tenant, name string) (*Table, error)

+ func (b *DiskBackend) Mode() StorageMode

+ func (b *DiskBackend) SaveTable(tenant string, t *Table) error

+ func (b *DiskBackend) Stats() BackendStats

+ func (b *DiskBackend) Sync() error

+ func (b *DiskBackend) TableExists(tenant, name string) bool

+ type HybridBackend struct

+ func NewHybridBackend(dir string, maxMemoryBytes int64, compress bool, mode StorageMode) (*HybridBackend, error)

+ func (h *HybridBackend) Close() error

+ func (h *HybridBackend) DeleteTable(tenant, name string) error

+ func (h *HybridBackend) Disk() *DiskBackend

+ func (h *HybridBackend) ListTableNames(tenant string) ([]string, error)

+ func (h *HybridBackend) LoadTable(tenant, name string) (*Table, error)

+ func (h *HybridBackend) MarkDirty(tenant, name string)

+ func (h *HybridBackend) Mode() StorageMode

+ func (h *HybridBackend) SaveTable(tenant string, t *Table) error

+ func (h *HybridBackend) Stats() BackendStats

+ func (h *HybridBackend) Sync() error

+ func (h *HybridBackend) TableExists(tenant, name string) bool

+ type MemoryBackend struct

+ func NewMemoryBackend(savePath string) *MemoryBackend

+ func (m *MemoryBackend) Close() error

+ func (m *MemoryBackend) DeleteTable(_, _ string) error

+ func (m *MemoryBackend) ListTableNames(_ string) ([]string, error)

+ func (m *MemoryBackend) LoadTable(_, _ string) (*Table, error)

+ func (m *MemoryBackend) Mode() StorageMode

+ func (m *MemoryBackend) SaveTable(_ string, _ *Table) error

+ func (m *MemoryBackend) Stats() BackendStats

+ func (m *MemoryBackend) Sync() error

+ func (m *MemoryBackend) TableExists(_, _ string) bool

+ type StorageBackend interface

+ Close func() error

+ DeleteTable func(tenant, name string) error

+ ListTableNames func(tenant string) ([]string, error)

+ LoadTable func(tenant, name string) (*Table, error)

+ Mode func() StorageMode

+ SaveTable func(tenant string, t *Table) error

+ Stats func() BackendStats

+ Sync func() error

+ TableExists func(tenant, name string) bool

+ type StorageConfig struct

+ CheckpointEvery uint64

+ CheckpointInterval time.Duration

+ CompressFiles bool

+ MaxMemoryBytes int64

+ Mode StorageMode

+ Path string

+ SyncOnMutate bool

+ func DefaultStorageConfig(mode StorageMode) StorageConfig

+ type StorageMode int

+ const ModeDisk

+ const ModeHybrid

+ const ModeIndex

+ const ModeMemory

+ const ModeWAL

+ func ParseStorageMode(s string) (StorageMode, error)

+ func (m StorageMode) String() string

type Table

+ func (t *Table) DirtyFrom() int

+ func (t *Table) MarkDirtyFrom(idx int)

+ func (t *Table) ResetDirty()

+ type TableMeta struct

+ Cols []Column

+ DiskSize int64

+ FilePath string

+ Name string

+ RowCount int

+ Tenant string

+ Version int

Dec 18, 2025

Changes in this version

+ type CatalogColumn struct

+ DataType string

+ DefaultValue *string

+ IsNullable bool

+ Name string

+ Position int

+ Schema string

+ TableName string

+ type CatalogFunction struct

+ ArgTypes []string

+ Description string

+ FunctionType string

+ IsDeterministic bool

+ Language string

+ Name string

+ ReturnType string

+ Schema string

+ type CatalogJob struct

+ CatchUp bool

+ CreatedAt time.Time

+ CronExpr string

+ Enabled bool

+ IntervalMs int64

+ LastRunAt *time.Time

+ MaxRuntimeMs int64

+ Name string

+ NextRunAt *time.Time

+ NoOverlap bool

+ RunAt *time.Time

+ SQLText string

+ ScheduleType string

+ Timezone string

+ UpdatedAt time.Time

+ type CatalogManager struct

+ func NewCatalogManager() *CatalogManager

+ func (c *CatalogManager) DeleteJob(name string) error

+ func (c *CatalogManager) GetAllColumns() []CatalogColumn

+ func (c *CatalogManager) GetColumns(schema, tableName string) []CatalogColumn

+ func (c *CatalogManager) GetFunctions() []*CatalogFunction

+ func (c *CatalogManager) GetJob(name string) (*CatalogJob, error)

+ func (c *CatalogManager) GetTables() []*CatalogTable

+ func (c *CatalogManager) GetViews() []*CatalogView

+ func (c *CatalogManager) ListEnabledJobs() []*CatalogJob

+ func (c *CatalogManager) ListJobs() []*CatalogJob

+ func (c *CatalogManager) RegisterFunction(fn *CatalogFunction) error

+ func (c *CatalogManager) RegisterJob(job *CatalogJob) error

+ func (c *CatalogManager) RegisterTable(schema, name string, cols []Column) error

+ func (c *CatalogManager) RegisterView(schema, name, sqlText string) error

+ func (c *CatalogManager) UpdateJobRuntime(name string, lastRun, nextRun time.Time) error

+ type CatalogTable struct

+ CreatedAt time.Time

+ Name string

+ RowCount int64

+ Schema string

+ Type string

+ UpdatedAt time.Time

+ type CatalogView struct

+ CreatedAt time.Time

+ Name string

+ SQLText string

+ Schema string

type DB

+ func (db *DB) Catalog() *CatalogManager

+ type JobExecutor interface

+ ExecuteSQL func(ctx context.Context, sql string) (interface{}, error)

+ type Scheduler struct

+ func NewScheduler(db *DB, executor JobExecutor) *Scheduler

+ func (s *Scheduler) AddJob(job *CatalogJob) error

+ func (s *Scheduler) RemoveJob(name string) error

+ func (s *Scheduler) Start() error

+ func (s *Scheduler) Stop()

Oct 1, 2025

Changes in this version

+ var ErrRowNotFound = fmt.Errorf("row not found")

+ var ErrSerializationFailure = fmt.Errorf("could not serialize access due to concurrent update")

+ var ErrTxNotActive = fmt.Errorf("transaction is not active")

+ func EstimateColumnSize(typ ColType) int64

+ func EstimateTableSize(t *Table) int64

+ func EstimateValueSize(val any) int64

+ func FanIn(ctx context.Context, channels ...<-chan interface{}) <-chan interface

+ func FanOut(ctx context.Context, input <-chan interface{}, workers int) []<-chan interface

+ func SaveToBytes(db *DB) ([]byte, error)

+ func SaveToFile(db *DB, filename string) error

+ func SaveToWriter(db *DB, w io.Writer) error

+ type AdvancedWAL struct

+ func OpenAdvancedWAL(config AdvancedWALConfig) (*AdvancedWAL, error)

+ func (w *AdvancedWAL) Checkpoint(db *DB) error

+ func (w *AdvancedWAL) Close() error

+ func (w *AdvancedWAL) GetCommittedLSN() LSN

+ func (w *AdvancedWAL) GetFlushedLSN() LSN

+ func (w *AdvancedWAL) GetNextLSN() LSN

+ func (w *AdvancedWAL) LogAbort(txID TxID) (LSN, error)

+ func (w *AdvancedWAL) LogBegin(txID TxID) (LSN, error)

+ func (w *AdvancedWAL) LogCommit(txID TxID) (LSN, error)

+ func (w *AdvancedWAL) LogDelete(txID TxID, tenant, table string, rowID int64, before []any, cols []Column) (LSN, error)

+ func (w *AdvancedWAL) LogInsert(txID TxID, tenant, table string, rowID int64, data []any, cols []Column) (LSN, error)

+ func (w *AdvancedWAL) LogUpdate(txID TxID, tenant, table string, rowID int64, before, after []any, ...) (LSN, error)

+ func (w *AdvancedWAL) Recover(db *DB) (int, error)

+ func (w *AdvancedWAL) ShouldCheckpoint() bool

+ type AdvancedWALConfig struct

+ BufferSize int

+ CheckpointEvery uint64

+ CheckpointInterval time.Duration

+ CheckpointPath string

+ Compress bool

+ Path string

+ type BatchHandler func(items []interface{}) error

+ type BatchProcessor struct

+ func NewBatchProcessor(maxSize int, interval time.Duration, handler BatchHandler) *BatchProcessor

+ func (bp *BatchProcessor) Add(item interface{}) error

+ func (bp *BatchProcessor) Run(ctx context.Context, wg *sync.WaitGroup)

+ type BufferPool struct

+ func NewBufferPool(policy *MemoryPolicy) *BufferPool

+ func (bp *BufferPool) Get(tenant, name string) (*Table, bool)

+ func (bp *BufferPool) GetMemoryLimit() int64

+ func (bp *BufferPool) GetMemoryUsage() int64

+ func (bp *BufferPool) GetStats() CacheStats

+ func (bp *BufferPool) Put(tenant, name string, table *Table) error

+ func (bp *BufferPool) Remove(tenant, name string)

+ type CacheStats struct

+ CacheHits int64

+ CacheMisses int64

+ EvictionCount int64

+ EvictionSize int64

+ HitRate float64

+ MemoryLimit int64

+ MemoryUsed int64

+ MemoryUtilization float64

+ TablesInMemory int

+ TablesOnDisk int

+ type CacheStrategy int

+ const StrategyARC

+ const StrategyLFU

+ const StrategyLRU

+ const StrategyNone

+ func (s CacheStrategy) String() string

+ type CachedTable struct

+ AccessCount int64

+ DiskOffset int64

+ LastAccess time.Time

+ LoadedAt time.Time

+ OnDisk bool

+ Pinned bool

+ Size int64

+ Table *Table

+ type ColType int

+ const ArrayType

+ const BoolType

+ const ByteType

+ const Complex128Type

+ const Complex64Type

+ const ComplexType

+ const DateTimeType

+ const DateType

+ const DurationType

+ const Float32Type

+ const Float64Type

+ const FloatType

+ const Int16Type

+ const Int32Type

+ const Int64Type

+ const Int8Type

+ const IntType

+ const InterfaceType

+ const JsonType

+ const JsonbType

+ const MapType

+ const PointerType

+ const RuneType

+ const SliceType

+ const StringType

+ const TextType

+ const TimeType

+ const TimestampType

+ const Uint16Type

+ const Uint32Type

+ const Uint64Type

+ const Uint8Type

+ const UintType

+ func (t ColType) String() string

+ type Column struct

+ Constraint ConstraintType

+ ForeignKey *ForeignKeyRef

+ Name string

+ PointerTable string

+ Type ColType

+ type ConcurrencyConfig struct

+ BatchInterval time.Duration

+ BatchSize int

+ QueueTimeout time.Duration

+ ReadQueueSize int

+ ReadWorkers int

+ WorkerTimeout time.Duration

+ WriteQueueSize int

+ WriteWorkers int

+ func DefaultConcurrencyConfig() ConcurrencyConfig

+ type ConcurrencyManager struct

+ func NewConcurrencyManager(config ConcurrencyConfig) *ConcurrencyManager

+ func (cm *ConcurrencyManager) Shutdown(timeout time.Duration) error

+ func (cm *ConcurrencyManager) Stats() *ConcurrencyStats

+ func (cm *ConcurrencyManager) SubmitRead(ctx context.Context, data interface{}) <-chan WorkResult

+ func (cm *ConcurrencyManager) SubmitWrite(ctx context.Context, data interface{}) <-chan WorkResult

+ type ConcurrencyStats struct

+ ActiveWorkers atomic.Int64

+ CompletedReads atomic.Uint64

+ CompletedWrites atomic.Uint64

+ FailedRequests atomic.Uint64

+ QueuedReads atomic.Int64

+ QueuedWrites atomic.Int64

+ TotalRequests atomic.Uint64

+ type ConstraintType int

+ const ForeignKey

+ const NoConstraint

+ const PrimaryKey

+ const Unique

+ func (c ConstraintType) String() string

+ type DB struct

+ func LoadFromBytes(b []byte) (*DB, error)

+ func LoadFromFile(filename string) (*DB, error)

+ func LoadFromReader(r io.Reader) (*DB, error)

+ func NewDB() *DB

+ func (db *DB) AdvancedWAL() *AdvancedWAL

+ func (db *DB) AttachAdvancedWAL(wal *AdvancedWAL)

+ func (db *DB) DeepClone() *DB

+ func (db *DB) Drop(tn, name string) error

+ func (db *DB) Get(tn, name string) (*Table, error)

+ func (db *DB) ListTables(tn string) []*Table

+ func (db *DB) MVCC() *MVCCManager

+ func (db *DB) Put(tn string, t *Table) error

+ func (db *DB) WAL() *WALManager

+ type ForeignKeyRef struct

+ Column string

+ Table string

+ type IsolationLevel uint8

+ const ReadCommitted

+ const RepeatableRead

+ const Serializable

+ const SnapshotIsolation

+ type LRUNode struct

+ type LRUQueue struct

+ func NewLRUQueue() *LRUQueue

+ func (lru *LRUQueue) Access(key string, table *CachedTable)

+ func (lru *LRUQueue) Add(key string, table *CachedTable)

+ func (lru *LRUQueue) Remove(key string)

+ func (lru *LRUQueue) RemoveLRU() (string, *CachedTable)

+ type LSN uint64

+ type MVCCManager struct

+ func NewMVCCManager() *MVCCManager

+ func (m *MVCCManager) AbortTx(tx *TxContext)

+ func (m *MVCCManager) BeginTx(level IsolationLevel) *TxContext

+ func (m *MVCCManager) CommitTx(tx *TxContext) (Timestamp, error)

+ func (m *MVCCManager) GCWatermark() Timestamp

+ func (m *MVCCManager) IsVisible(tx *TxContext, rv *RowVersion) bool

+ type MVCCTable struct

+ func NewMVCCTable(name string, cols []Column, isTemp bool) *MVCCTable

+ func (t *MVCCTable) DeleteVersion(tx *TxContext, rowID int64) error

+ func (t *MVCCTable) GarbageCollect(watermark Timestamp) int

+ func (t *MVCCTable) GetVisibleVersion(mvcc *MVCCManager, tx *TxContext, rowID int64) *RowVersion

+ func (t *MVCCTable) InsertVersion(tx *TxContext, data []any) int64

+ func (t *MVCCTable) UpdateVersion(tx *TxContext, rowID int64, newData []any) error

+ type MemoryPolicy struct

+ AccessWindow time.Duration

+ EnableEviction bool

+ EvictionBatchSize int

+ EvictionThreshold float64

+ IgnoreTables []string

+ MaxMemoryBytes int64

+ PinnedTables []string

+ Strategy CacheStrategy

+ TrackAccessPatterns bool

+ func DefaultMemoryPolicy() *MemoryPolicy

+ func LimitedMemoryPolicy(maxMB int64) *MemoryPolicy

+ type ParallelIterator struct

+ func NewParallelIterator(items []interface{}, workers int) *ParallelIterator

+ func (pi *ParallelIterator) ForEach(fn func(item interface{}) error) error

+ func (pi *ParallelIterator) Map(fn func(item interface{}) (interface{}, error)) ([]interface{}, error)

+ func (pi *ParallelIterator) WithContext(ctx context.Context) *ParallelIterator

+ type Pipeline struct

+ func NewPipeline(ctx context.Context, stages ...PipelineStage) *Pipeline

+ func (p *Pipeline) Execute(input []interface{}) <-chan interface{}

+ type PipelineStage func(ctx context.Context, input <-chan interface{}) <-chan interface

+ type RateLimiter struct

+ func NewRateLimiter(opsPerSecond int) *RateLimiter

+ func (rl *RateLimiter) Stop()

+ func (rl *RateLimiter) Wait(ctx context.Context) error

+ type RowVersion struct

+ CreatedAt Timestamp

+ Data []any

+ DeletedAt Timestamp

+ NextVersion *RowVersion

+ XMax TxID

+ XMin TxID

+ type Table struct

+ Cols []Column

+ IsTemp bool

+ Name string

+ Rows [][]any

+ Version int

+ func NewTable(name string, cols []Column, isTemp bool) *Table

+ func (t *Table) ColIndex(name string) (int, error)

+ type Timestamp uint64

+ type TxContext struct

+ ID TxID

+ IsolationLevel IsolationLevel

+ ReadSet map[string]map[int64]Timestamp

+ ReadSnapshot Timestamp

+ StartTime Timestamp

+ Status TxStatus

+ WriteSet map[string]map[int64]bool

+ func (tx *TxContext) RecordRead(table string, rowID int64, version Timestamp)

+ func (tx *TxContext) RecordWrite(table string, rowID int64)

+ type TxID uint64

+ type TxStatus uint8

+ const TxStatusAborted

+ const TxStatusCommitted

+ const TxStatusInProgress

+ type WALChange struct

+ Drop bool

+ Name string

+ Table *Table

+ Tenant string

+ func CollectWALChanges(prev, next *DB) []WALChange

+ type WALConfig struct

+ CheckpointEvery uint64

+ CheckpointInterval time.Duration

+ Path string

+ type WALManager struct

+ func OpenWAL(db *DB, cfg WALConfig) (*WALManager, error)

+ func (w *WALManager) Checkpoint(db *DB) error

+ func (w *WALManager) Close() error

+ func (w *WALManager) LogTransaction(changes []WALChange) (bool, error)

+ type WALOperationType uint8

+ const WALOpAbort

+ const WALOpBegin

+ const WALOpCheckpoint

+ const WALOpCommit

+ const WALOpDelete

+ const WALOpInsert

+ const WALOpUpdate

+ func (t WALOperationType) String() string

+ type WALRecord struct

+ AfterImage []any

+ BeforeImage []any

+ Checksum uint32

+ Columns []Column

+ LSN LSN

+ OpType WALOperationType

+ RowID int64

+ Table string

+ Tenant string

+ Timestamp time.Time

+ TxID TxID

+ type WALTxState struct

+ Operations []LSN

+ StartLSN LSN

+ Status TxStatus

+ TxID TxID

+ type WorkHandler func(ctx context.Context, req WorkRequest) WorkResult

+ type WorkRequest struct

+ Context context.Context

+ Data interface{}

+ ID uint64

+ Result chan WorkResult

+ Type WorkType

+ type WorkResult struct

+ Data interface{}

+ Error error

+ ID uint64

+ type WorkType uint8

+ const WorkTypeBatch

+ const WorkTypeDelete

+ const WorkTypeRead

+ const WorkTypeScan

+ const WorkTypeWrite

+ type WorkerPool struct

+ func NewWorkerPool(name string, size int, workQueue chan WorkRequest, handler WorkHandler, ...) *WorkerPool

+ func (wp *WorkerPool) Start()