Add marks a reader ID as active.

Join attempts to join an existing membership cluster using the provided addresses.

NewStorageEngine initializes WAL, MemTable, and BtreeStore and returns an initialized Engine for a namespace.

NewWALog returns an initialized WALog that manages the segments in the provided dir with the given ext.

NewDefaultEngineConfig returns an initialized default config for engine.

Contains returns true if the given reader ID is currently tracked.

Len returns the total number of entries across all shards.

OpenSegmentFile opens an existing segment file or create a new one if not present. If SegmentFile is sealed it doesn't scan its content while opening.

String returns a string representation of the counter state.

Close gracefully shuts down all segments managed by the WALog.

Write appends the given data as a new record to the active segment. It returns RecordPosition indicating where the data was written.

WithMaxSegmentSize options sets the MaxSize of the Segment file.

Decode deserializes a byte slice into a raft.Log. The input buffer may be retained by the returned Log (zero-copy), so callers must not modify the buf

Current returns a pointer to the currently active WAL segment.

NewReader returns a new Reader that sequentially reads all segments in the WALog, starting from the beginning (lowest SegmentID).

Next returns the next available WAL record data and its current position. IMPORTANT: The returned `[]byte` is a slice of a memory-mapped file, so data

Read returns the data from the provided record position if found. IMPORTANT: The returned `[]byte` is a slice of a memory-mapped file, so data must no

FBEncode encodes the provided record into flat-buffer format.

ID returns a unique identifier for this codec version.

Set stores the position for an index.

NewShardedIndex creates a sharded index with the specified number of shards.

Append writes the provided data as a new record to the active WAL segment.

func (e *Engine) resumeFlush() { e.flushPaused.Store(false) }

Segments returns a snapshot (shallow) copy of all active segments managed by the WAL.

Update updates the register if the new timestamp is greater. Returns true if the register was updated, false if the update was stale.

Next returns the next chunk data and its position in the WAL. If there is no data, io. EOF will be returned. The position can be used to read the data

Encode serializes a raft.Log into a byte slice.

OpsReceivedCount returns the total number of Put and Delete operations received.

RotateSegment rotates the current segment and create a new active segment.

Close closes all segment readers to release their references. IMPORTANT: This method MUST be called after the Reader is no longer needed.

GetLog returns the *raft.Log at the given Index.

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

Remove closes the segment and removes its underlying files (segment and index).

HLCNow returns the current time in milliseconds since the Unix epoch.

NewTxn returns a new initialized batch Txn. Transactions are not allowed in RaftMode.

Get retrieves the position for an index. Returns the position and true if found, zero value and false otherwise.

SetRaftMode enables or disables Raft mode on the Engine. When in Raft mode, the Raft log IS the WAL.

GetEntryCount returns the total entry count in segment.

Truncate truncates the WAL to the specified log index. All entries after the given log index will be discarded. If logIndex is 0, all segments are del

IsSealed returns if teh provided flag has sealed bit set.

NewRaftTransportManager creates a new RaftTransportManager.

SerializeKVEntry encodes a single KeyValueEntry into FlatBuffers.

StoreLogs stores multiple log entries. The logs must be contiguous with each other. They may overwrite existing entries if there's a gap or conflict (

GetFlags returns the flags stored in segment header.

Commit the Txn.

CurrentOffset returns the current offset that it has seen.

DeserializeFBRootLogRecord converts the FlatBuffer WAL Log Record to Go Struct LogRecord.

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

Shutdown finalizes shutdown, optionally waiting for removal from the Raft config.

SetRaftApplier sets the RaftApplier used to propose commands to Raft.

SetPositionLookup sets the function used to look up WAL positions from Raft log indices.

StoreLog stores a single log entry.

AppendKVTxn append a key, value to the WAL as part of a Txn.

NewReader return a reader that reads from the beginning, until EOF is encountered. It returns io.EOF when it reaches end of file. In Raft mode, reads

Open opens a snapshot for reading.