Serialize a single RowUpdateEntry separately.

Prepare serialized individual row entry

withLogIndex set up the log Index that will be used by the segment to populate the log index when recovering the seal segment or after restart.

AppendColumnTxn appends a row with columns to the transaction.

AssembleChunks reconstructs the original data from chunked records.

BackupSegmentsAfter copies every sealed segment with ID greater than after into backupDir.

Bootstrap bootstraps the cluster. Should only be called on one node.

BytesPerSyncCallCount how many times this was called on current active segment.

CleanupStalePendingSegments scans pendingDeletion and segments maps. If a segment's file no longer exists on disk, it removes those entries from both

Clear removes all entries from all shards.

ClearIndexFromMemory releases the in-memory index entries to free memory. This can be called after the index has been copied to an external data struc

CommittedIndex returns the current committed index.

DecodeRecord decodes a WAL entry to its underlying payload. In Raft mode, WAL entries are encoded Raft logs; otherwise the data is returned as-is.

DecodeRecordPosition deserializes a byte slice into a RecordPosition.

Deprecated: Use LogRecordPb.ProtoReflect.Descriptor instead.

EncodeRecordPositionTo serializes a RecordPosition into the provided buffer. The buffer must be at least 12 bytes long. If it's shorter, a new 12-byte

Get retrieves the safe-to-GC index (alias for SafeGCIndex).

GetFirstRaftPosition returns the first raft log index and term for this memtable.

Initialize the global metrics registry.

LastIndex returns the last index written. 0 for no entries.

List returns the available snapshots.

Merge merges updates from another replica. Returns true if the counter was updated, false if the update was stale.

NewHTTPAPIEngine returns an Engine implementation backed by HTTP APIs. The provided client is optional; when nil a default client with a 10s timeout i

NewInboundConn creates a new InboundConn.

NewReader returns a new instance of WIOReader, allowing the caller to access WAL logs for replication, recovery, or log processing.

NewTLSCreds creates transport credentials for server-auth TLS. nolint:ireturn

Print displays the counter state in a formatted way.

RecordFlush logs flush-related stats.

SafeGCIndex implements SafeGCIndexProvider.

SeekNext advances the reader by one record, discarding the data.

SetCustomScopeResolver allows injecting a function to control scope resolution globally.

SetRaftPosition sets the raft log position for this memtable (only used in raft mode).

SetReadDeadline sets the read deadline.

TelemetryStreamInterceptor logs gRPC requests, responses, and status codes and basic metrics for streaming API.

WaitForLeader waits until the cluster has a leader.

WithCustomMarker sets the 4-byte marker written to new segments.

WithCustomMarkerValidator sets a validator for stored markers on open.

WithDecoder sets a decoder that transforms raw WAL bytes before returning.

asyncMemTableFlusher flushes the sealed mem table.

clampToUint32 clamps a value to uint32 range with a minimum.

mostly using it in the error path.