WriteBatch appends multiple records to the active segment in a single batched operation. If the batch cannot fit entirely in the current segment, it h

WriteOffset returns the current write offset of the segment. go:inline

PositionForIndex returns the RecordPosition for the given log index.

Register adds a service to the server. Services are setup in registration order and closed in reverse order.

SealSegment seals the given segment.

* Record Layout: ┌──────────────────────────────────────────────────────────────┐ │ 0..3 CRC32C(header[4:8] || data) │ │ 4

Apply proposes data to the Raft cluster and waits for it to be committed. Returns the committed log index and error if the proposal fails or times out

Close gracefully shuts down the notifier.

LastIndex returns the last index written.

NewRaftTxn creates a new transaction in Raft mode.

KeyColumn returns the storage key for a wide-column cell. If the row key is already typed ([KeyTypeWideColumn][len][row]), it simply appends the colum

Namespace returns the namespace for this connection.

NewZeroMQNotifier creates a new ZeroMQ notifier.

AppliedIndex returns the last applied Raft log index.

[type][blobIDLenBE(4)][blobID][chunkBE(4)].

KeyKV returns the storage key for a key-value pair.

NewLogStore creates a new LogStore backed by the provided WAL.

Notify sends a notification to all subscribers.

Accept waits for and returns the next inbound connection.

ApplyRecordsLSNOnly applies WAL records with LSN validation only.

Close closes the log store. wal uses mmap so we use ref counting as safe coordinator.

DeleteRange removes all indices in [min, max] range.

FirstIndex returns the first index written.

ApplyRecord validates and applies a WAL record to the mem table which later get flushed to Btree Store.

Close releases the underlying segment reader and marks the Reader as closed.

IndexEntries returns a copy of the index metadata for this segment.

SerializeRowUpdateEntry encodes a single RowUpdateEntry into FlatBuffers.

ToGRPCError Convert business error to gRPC error. Custom types to avoid ordering issue while calling the function.

BackupLastRotatedSegment copies the most recently sealed WAL segment into backupDir and returns the backup path.

Close closes the stream layer.

Dial creates a new outbound connection to the given address.

NewNamespaceStreamLayer creates a new NamespaceStreamLayer.

[type][rowLenBE(4)][row][col] Why this format? - The rowLen tells us where the row ends and the column begins. - Big Endian is used so that keys sort

WaitForIndexFlush blocks until any pending index flush operations complete.

memTableWrite will write the provided key and value to the memTable.

Flush writes all entries from MemTable to BtreeStore.

GetLOB returns the full LOB value (joined).

NewBlobStoreStreamerClient creates a new BlobStoreStreamerClient. startLSN is the LSN of the last record already applied; tailing resumes from the nex

Read retrieves the WAL record at the given position.

ReleaseRecords releases the WAL records back to the shared pool once callers are done processing them. Callers must ensure they no longer reference th

WithSegmentSize sets the size for the Segment.

WithSyncOption sets the sync option for the Segment.

alignUp returns the next multiple of alignSize greater than or equal to n. go:inline

recoverWAL recover wal from last check point saved in btree store.

AppendKVTxn appends a key-value pair to the transaction.

GetFirstLast returns the first and last indices in the index. Returns (0, 0, false) if the index is empty.

NewBlobStoreStreamer returns an initialised BlobStoreStreamer. namespaceLogs must contain one partitionlog log per namespace.

NewWalIO initializes and returns a new instance of WalIO.

[type][rowLenBE(4)][row][col] Why this format? - The rowLen tells us where the row ends and the column begins. - Big Endian is used so that keys sort

WithReaderCommitCheck enables commit offset checking for readers. When enabled, readers will check against the committed position before advancing. If

WithSegmentCustomMarker sets the 4-byte marker written for new segments. Use WithSegmentCustomMarkerValidator to validate stored markers on open.

WithSegmentCustomMarkerValidator sets a validator for stored markers when opening segments.

Close flushes WAL data to disk using fsync and then closes all underlying WAL segments.

Close shuts down the streamer and flushes active partitionlog writers.

GetRowYValue returns all the mem table entries associated with the provided rowKey.

IsSealed returns true if the segment is sealed (on-disk flag).

NewMembership is used to setup and initialize a gossip Membership.

NewReaderFromLSN creates a WAL reader starting at the given LSN. It finds the segment containing the LSN and positions the reader appropriately. If ta

NumVoters helper functions returns the number of voting peers in the current raft configurations.

Read reads data from the connection.

Create creates a new snapshot using the flushed index/term from the holder instead of the applied index/term passed by Raft.

Delete removes an index from the map.

EventHandler handles events operation for Membership cluster.

GetTransactionRecords returns all the WalRecord that is part of the particular Txn.

IsZero returns true if the RecordPosition is uninitialized, meaning both SegmentID and Offset are zero.

NewMemTable returns an initialized mem-table.