GetLastModifiedAt returns the last modified time of the segment.

LenSlow returns the total number of entries by summing all shards.

LogIndex returns the shared sharded index mapping log index to record position.

MarkForDeletion marks the segment as candidate for deletion. If no active readers, it will immediately call cleanup. Otherwise, cleanup will be deferr

Format: [RecordProcessed:8][Pos:12][RaftIndex:8][RaftTerm:8] = 36 bytes.

NewService creates a new HTTP API service.

RegisterRoutes registers all HTTP API routes with the given router.

SealedMemTableCount returns the current number of sealed memtables.

WaitForAppendOrDone blocks until a put/delete operation occurs or context cancelled is done.

WithMSyncEveryWrite enables msync() after every write operation.

Write writes data to the connection. On the first call, it writes the namespace header before the data.

WriteBatch applies rate limiting before delegating to the underlying WalIO batch write.

ApplyRecords validates and applies multiple WAL records in batch to the mem table. This is more efficient than calling ApplyRecord multiple times as i

BtreeSnapshot returns the snapshot of the current btree store.

Decode decodes a Raft WAL entry and returns the inner payload (raft.Log.Data). For non-command log types (Noop, Barrier, Configuration), returns a Raf

HasAny returns true if there is at least one active reader across all shards.

NewRaftWALDecoder creates a RaftWALDecoder with the given codec. If codec is nil, BinaryCodecV1{} is used as default.

NewTxnQueue returns an initialized LMDBTxnQueue for Batch API queuing and commit.

NewWalRecovery creates and returns a new initialized instance of WalRecovery.

Recover restores WAL entries starting from the provided checkpoint.

RemoveServer removes a server from Raft if it exists in the latest configuration. This must be run on the leader or it will fail.

RunLoop executes a long-running retry loop with backoff and budgeting.

SegmentFileName returns the file name of a Segment file.

SerializeEventEntry encodes an EventEntry into FlatBuffers.

WAL returns the underlying walfs.WALog for this engine. In Raft mode, this WAL is shared with the Raft log store. The WAL must be created with RaftMod

Format: [version:1][length:1][namespace:N].

acquireLock attempts to acquire an exclusive lock on the namespace. this is in same path as our dbkernel pid.lock to prevent server start. if dbkernel

generateLargeRandomBytes returns random bytes of given size.

https://opentelemetry.io/docs/specs/semconv/rpc/rpc-spans/

persistRowColumnAction writes the columnEntries for the given rowKey in the wal and mem-table.

AddServer will add the given server to the cluster as a staging server.

ApplyBatch implements raft.BatchingFSM.

BuildColumnMap builds the columns from the provided mem-table entries. it modifies the provided columnEntries with the entries fetched from mem table.

CurrentWalIO returns the currently configured WalIO implementation for the Relayer. nolint:ireturn

Decode deserializes a raft.Log.

DeleteRow removes an entire row and all its associated column entries.

EnableRateLimitedWalIO configures the Relayer to apply a token bucket rate limiter on WAL writes. This helps control replication throughput and preven

GetLSN reads the LSN from a LogRecord FlatBuffer.

IsRaftMode returns true if the Engine is operating in Raft mode.

NewCluster creates a cluster with the given Raft instance, local server ID, and namespace.