KeyKind is type markers for multimodal storage.

KeyKind is type markers for multimodal storage.

DirectorySyncFunc adapts a function to act as a DirectorySyncer.

DBEngine : which bTreeStore engine to use for the underlying persistence storage.

Format represents the output format type.

BTreeStore combines writer + reader + lifecycle.

BatchKVItem represents a single KV item in a batch.

BatchKVRequest represents batch operations request.

BatchKVResponse represents batch operations response.

BinaryCodecV1 is the default codec using efficient binary encoding. Format: term(8) | index(8) | type(1) | appendedAt(8) | dataLen(varint) | data | ex

BlobStoreRelayConfig holds object-store streamer settings.

BlobStoreStreamer reads WAL records from storage engines and writes them to partitionlog segments on object storage. One namespace maps to one partiti

BlobStoreStreamerClient implements the relayer.Streamer interface by reading committed WAL records from a partitionlog stream on object storage.

BlobStoreStreamerConfig holds configuration for a BlobStoreStreamer.

BoltDBEmbed wraps an initialized BoltDB (bbolt) database and related metadata.

BoltTxnQueue encapsulates Boltdb Transactions and provides an API that allow multiple operation to be put in queue that is supposed to be Executed in

ChangeNotification represents a change notification from UnisonDB.

ChangeNotifier is called on successful local writes.

Cluster wraps a single Raft instance.

ClusterDiscover is an interface that wraps the basic OnChangeEvent Method. OnChangeEvent notifies the provider when there is a change in the cluster d

ClusterEventFilter decides whether to notify cluster listeners about a membership event. Returning false skips ClusterDiscover notifications for the e

Codec defines the interface for encoding and decoding raft log entries. Implementations must be safe for concurrent use.

ColumnPredicate defines a function used to filter column keys.

Config holds ZeroMQ notifier configuration.

Config stores all tunable parameters for WAL.

Config holds ZeroMQ notifier configuration.

Config : top-level configuration.

DataMutator provides in-place mutation of fields within encoded data. This is used to inject Raft index as LSN into engine's FlatBuffer records after

DeletionPredicate is a function that determines if a segment ID is safe to delete.

Dialer is the interface used by NamespaceStreamLayer to dial peers.

DirectorySyncer syncs a directory path to stable storage.

Engine manages WAL, MemTable (SkipList), and BtreeStore for a given namespace.

EngineConfig embeds all the config needed for Engine.

FSMSnapshotStore wraps a standard raft.SnapshotStore and overrides the index/term used in snapshot metadata to match the actual flushed state of the F

Raft assumes that when you take a snapshot, everything up to that index is persisted. But we have a gap between what's applied to memtable vs what's f

Formatter is the interface for output formatting.

FuzzerService runs the fuzzer for stress testing.

GCounter represents a Grow-Only Counter CRDT. It maintains per-replica counters and merges by taking the max of each replica's count.

GCounterData represents the serialized format of G-Counter data from UnisonDB.

GRPCStatsHandler Implements grpc stats handler for monitoring purposes.