NewHashicorpLogWriter returns an io.Writer that parses hashicorp-style log output and forwards it to the given slog.Logger at the appropriate level. T

NewReaderWithStart return a reader that reads from provided offset, until EOF is encountered. It returns io.EOF when it reaches end of file. In Raft m

NewScopedMetricsTracker creates a MetricsTracker using a provided tally.Scope.

Put the Key and its Value at the given offset in the mem-table. for rowKey Put It uses MVCC as there can be multiple update ops for different columns

RecordError increments the error counter for a given operation (e.g., set, get, delete).

SegmentIndexFileName returns the file name of the index for a segment.

SnapshotIndexHolder returns the FlushedIndexHolder used for communicating the flushed index to FSMSnapshotStore. This ensures that Raft's snapshot met

SplitIntoChunks chunks the provided data into 1MB, chunks. If the data size is less than 1 MB, it returns the original data without chunking. else ret

StreamWAL start the wal Streaming for the namespace from the upstream.

StreamWAL periodically checks the partitionlog head, reads newly committed WAL records, and applies them via the configured WalIO.

TruncateTo truncates the segment to the specified log index. All entries after the given log index will be discarded. If the log index is not found in

WillExceed returns true if writing a record of the given dataSize would overflow the segment's allocated (memory-mapped) size.

WithDirectorySyncer overrides the directory syncer used for new segment files.

extractRequestID retrieves x-request-id or x-trace-id from gRPC metadata. If not present, it generates a new one.

getShard returns the shard for a given index using fast bitwise modulo.

newReaderTracker creates a new readerTracker with initialized shards.

openSegment opens segment with the provided ID.

varintSize returns the number of bytes needed to encode v as a varint.

BackupBtree writes a full snapshot of the B-Tree store to backupPath atomically.

BackupWalSegmentsAfter copies sealed WAL segments whose IDs are greater than afterID into backupDir.

Clone returns a deep copy of the MemberInformation.

CommittedPosition returns the current committed position. Returns NilRecordPosition if no position has been committed yet.

DeserializeEventEntry decodes a FlatBuffers EventEntry.

FuzzEngineOps concurrently runs fuzzing operations against an Engine using multiple worker goroutines.

GetLastRaftPosition returns the last raft log index and term for this memtable.

GetLog gets a log entry at a given index.

GetRequestInfo extracts namespace, request ID, and method from the context.

GetScope returns a scoped metrics collector for a specific package. nolint:ireturn

GetValue returns the total count across all replicas.

IsInMemorySealed returns true if the segment has been marked as sealed in memory.

MutateLSN updates the LSN field in a LogRecord FlatBuffer. The mutation is done in-place without allocating new memory. Note: FlatBuffers doesn't sto

NewFSMSnapshotStore creates a new FSMSnapshotStore wrapping the given SnapshotStore.

NewFormatter creates a new formatter for the given format.

NewMTLSCreds creates transport credentials for mutual TLS. nolint:ireturn

NewRelayer returns an initialized Relayer instance that uses gRPC streaming.

PositionForIndexWithBounds returns the RecordPosition for the given log index, returning typed errors for "not yet available" vs "truncated".

RecordOp logs operation count and latency.

RecoveredWALCount returns the number of WAL entries successfully recovered.

Run starts the UnisonDB server with the specified configuration.

StartNLocalRelayer launches multiple local relayers for a given engine.

WithCodec sets a custom codec for encoding/decoding log entries.

WithDecoder sets a custom decoder for the reader. When set, NextRecord() will use this decoder to convert raw bytes to decoded data.

clampInt64 clamps a value between min and max.

Flattens the key for formatting along with its labels, removes spaces.

getConfigs returns the benchmark configurations

itoa returns the ASCII bytes for a positive int. Faster than fmt.Sprintf in tight loops.

itoa returns the ASCII bytes for a positive int. Faster than fmt.Sprintf in tight loops.