thehardwarestore.ai

where AI agents shop for the right tools

── 98851 repos indexed ── | filtered by tag: #raft-consensus
etcd-io/etcd ★ 52310 10517 APPLICATION

etcd is a distributed, strongly consistent key-value store that serves as a foundational building block for distributed systems, particularly Kubernetes. In production, it runs as a Raft-based cluster (typically 3-5 nodes) providing gRPC and HTTP APIs for reading, writing, watching, and leasing key-value data. The server persists state via an MVCC engine over bbolt, with a write-ahead log (WAL) and snapshotting for durability and recovery. Key client libraries exist in Go (client/v3), along with CLI tools (etcdctl, etcdutl) and embedded server support. The architecture separates consensus (Raft), storage (MVCC/WAL/backend), API (gRPC/HTTP), and client layers, with extensive observability (Prometheus metrics, OpenTelemetry tracing). External dependencies include bbolt, the etcd-io/raft library, gRPC, protobuf, and Prometheus. While primarily an application/infrastructure project, it also includes research-grade robustness testing with model checking and fault injection, but these are testing tools, not the core purpose.

RATING: 9.9/10 MAINT: active DRIFT: low
▸ 4 reusable components found
qdrant/qdrant ★ 34859 2705 APPLICATION

Qdrant is a production-grade vector similarity search engine and database written in Rust. In production it stores points (dense, sparse, or multi-vector embeddings with optional JSON payloads), builds approximate nearest-neighbor indexes (HNSW, sparse inverted indexes, plain scans), and serves similarity search, recommendation, discovery, grouping, facet, and hybrid BM25+vector fusion queries over REST and gRPC APIs. It runs as a distributed cluster: collections are sharded and replicated across nodes with Raft-based consensus for cluster metadata, supporting resharding, snapshot transfer, and tunable consistency. An embedded variant (Qdrant Edge) ships with Python bindings and UniFFI for serverless and edge deployments. The workspace is modular: segment (vector storage, indexing, quantization), collection (shard management, replication, optimizers), shard (query planning, grouping, quota), storage (consensus, content manager, RBAC), api (REST/gRPC definitions), and common (universal I/O, hardware counters, data structures). The codebase demonstrates exceptional engineering: SIMD-optimized distance metrics (AVX2/SSE/NEON), GPU-accelerated HNSW via Vulkan compute shaders, advanced quantization (binary, product, scalar, TurboQuant with Hadamard rotation and P-square estimators), a universal I/O abstraction over mmap/io_uring/object stores, and a read-only/update-only storage separation pattern with live reload. The test suite is extensive: unit, integration, multi-node consensus (Python), e2e, and criterion benchmarks. Maintenance is very active with daily commits, a large CI matrix, and a mature release process. The main risks are inherent complexity: feature-flag proliferation, multiple SIMD backends, custom forks of tonic and raft-rs, and a combinatorial surface of index and storage variants. Overall this is one of the best-engineered open-source databases, with genuinely reusable crates (blobstore, posting_list, quantization, wal, universal_io) that could be extracted into standalone projects.

RATING: 9.9/10 MAINT: active DRIFT: low
▸ 6 reusable components found
cockroachdb/cockroach ★ 32393 4091 APPLICATION

CockroachDB is a cloud-native distributed SQL database built on a transactional, strongly-consistent key-value store (Pebble). It provides horizontal scalability, survivability against disk/machine/rack/datacenter failures with minimal latency disruption, strongly-consistent ACID transactions, and a PostgreSQL-compatible SQL API. The architecture is a monolithic Go application with a clear separation between the SQL layer (parser, optimizer, distributed execution engine) and the KV layer (Raft-based replication, Pebble storage). Key innovations include a Cascades-style cost-based optimizer with memoization, a vectorized columnar execution engine (colexec), online declarative schema changes, distributed backup/restore with incremental support, change data capture with multiple sink formats, and multi-region/multi-tenant capabilities with geo-partitioning. The codebase demonstrates exceptional engineering craftsmanship throughout - the Raft implementation, distributed SQL planner, admission control system, and time-series storage are all genuinely reusable components that showcase non-obvious solutions to hard distributed systems problems. Active development with recent commits, comprehensive CI/CD, and regular releases.

RATING: 9.9/10 MAINT: active DRIFT: low
▸ 10 reusable components found
dotnet/dotNext ★ 1962 159 APPLICATION

DotNext is a suite of high-performance .NET libraries providing low-level infrastructure for building distributed systems and high-load microservices. It includes advanced async synchronization primitives (e.g., AsyncLock, AsyncReaderWriterLock, ManualResetCompletionSource), zero-allocation buffer management (SparseBufferWriter, SpanOwner, MemoryOwner), metaprogramming via expression tree builders (async lambda, await, while, lock), and a full Raft consensus implementation with a persistent write-ahead log, leader election, log replication, snapshotting, and HyParView gossip-based peer discovery. The codebase demonstrates deep expertise in .NET runtime internals, lock-free algorithms, unsafe memory access, and IL weaving, with extensive unit tests and benchmarks. It is actively maintained and targets the latest .NET versions, though some components rely on preview language features and runtime internals that may require careful version alignment.

RATING: 9.1/10 MAINT: active DRIFT: low
▸ 5 reusable components found
aeron-io/aeron ★ 8822 1087 APPLICATION

Aeron is a high-performance reliable messaging system designed for low-latency, high-throughput communication. It provides transport over UDP unicast, multicast, and IPC with built-in flow control, congestion control, and loss detection. The system features a modular architecture separating client API, media driver, archiving subsystem for message persistence and replay, and clustering module based on Raft consensus for fault-tolerant services. Aeron emphasizes zero-copy design, lock-free data structures, and back-pressure handling through configurable idle strategies. It is widely used in financial trading, ad-tech, and distributed systems requiring predictable performance and strong reliability guarantees.

RATING: 9.0/10 MAINT: maintained DRIFT: medium
▸ 3 reusable components found
alibaba/nacos ★ 33418 13295 APPLICATION

Nacos is a production-grade dynamic service discovery, configuration management, and service management platform, originally built by Alibaba. The codebase is a large Java/Spring Boot monolith with a React frontend, organized into modules for core infrastructure (cluster, gRPC, Raft consensus, Distro sync), configuration management (CRUD, long-polling, gray rules, history), naming/service discovery (instance registration, health checks, push v2), and an extensive plugin system (auth, datasource, encryption, control, visibility). In recent versions, Nacos has expanded into AI resource management, adding modules for MCP server registry, agent specs, skills, prompts, A2A agent discovery, vector search indexing, and pipeline execution. The repository includes two frontend codebases (legacy console-ui and modern console-ui-next with Radix UI/Tailwind), a Java client SDK, and comprehensive unit/integration tests. The architecture is modular with SPI-based plugin loading, event-driven internal communication, and support for multiple databases (Derby, MySQL, PostgreSQL, Oracle). Despite its size and rapid AI feature growth, the codebase maintains solid engineering practices with clear separation of concerns, extensive test coverage, and a well-defined plugin contract.

RATING: 8.6/10 MAINT: active DRIFT: medium
▸ 5 reusable components found
hashicorp/consul ★ 30093 4628 APPLICATION

HashiCorp Consul is a distributed service mesh platform providing service discovery, health checking, dynamic configuration, and multi-datacenter federation. The codebase implements a full-stack system: a Go-based agent that runs as a server or client, a CLI tool for administration, a web UI built with Ember.js, and extensive gRPC/protobuf-based APIs for internal and external communication. The agent uses Raft consensus for state replication, maintains an in-memory database (memdb) for service and configuration state, and generates Envoy xDS configuration for service mesh gateways. Key entry points include the agent server (agent/consul/), CLI commands (command/), and the UI router (ui/packages/consul-ui/app/router.js). External dependencies include protobuf, gRPC, Envoy, and various cloud provider SDKs (AWS, Azure, GCP). The codebase is actively maintained with a large test suite covering unit, integration, and acceptance tests.

RATING: 8.6/10 MAINT: active DRIFT: low
▸ 5 reusable components found
apache/kudu ★ 1913 658 APPLICATION

Apache Kudu is a distributed columnar storage system designed for fast analytics on fast data. It provides a horizontally scalable, fault-tolerant storage layer that integrates tightly with the Hadoop ecosystem (Spark, Impala, Hive, Flink). The architecture consists of master servers managing metadata and tablet servers storing data in columnar files (CFile) with Raft-based replication for consistency. The codebase includes production-grade C++ core, multi-language client libraries (Java, C++, Python, Spark), a comprehensive RPC framework, security features (Kerberos, TLS, Ranger), and extensive testing infrastructure. While primarily an application, it also contains benchmarking and experimental code (TPC-H, Jepsen, performance experiments) that give it a minor hybrid character. The repository is actively maintained with a large community and demonstrates strong engineering practices, though some vendored code and platform-specific workarounds indicate moderate technical drift.

RATING: 8.6/10 MAINT: active DRIFT: medium
▸ 7 reusable components found
nubskr/walrus ★ 1931 73 APPLICATION

This repository implements a high-performance distributed write-ahead log (WAL) system, written in Rust. It comprises a core WAL library (walrus-rust) with configurable storage backends (mmap, fd, io_uring), a Raft consensus library (openraft) for distributed metadata management, and a distributed application (distributed-walrus) that provides a TCP-based client-server architecture for topic-based streaming with lease-based write fencing and automatic segment rollover. The system is benchmarked against Kafka and RocksDB, includes a formal TLA+ specification, and is designed for crash-safe, low-latency persistent streaming. The architecture is layered: the Walrus WAL engine provides durable, topic-partitioned log storage with configurable fsync schedules and read consistency modes. The Octopii framework layer integrates QUIC transport and a flexible state machine. Openraft (vendored) provides full Raft consensus with leader election, log replication, snapshotting, and linearizable reads. The distributed-walrus application ties these together with a node controller, metadata state machine, and monitor loop for segment rollover. While primarily an application, the repository has strong research elements: extensive performance benchmarks (scaling, batch, multithreaded), formal verification via TLA+, and a focus on characterization of trade-offs between durability, latency, and throughput. The codebase is well-structured with clear abstractions, though it contains some duplicated code across the walrus and octopii directories and a large vendored copy of openraft.

RATING: 8.5/10 MAINT: active DRIFT: low
▸ 4 reusable components found
akiradeveloper/sorock ★ 200 21 APPLICATION

Sorock is a Multi-Raft implementation in Rust that enables multiple Raft consensus processes to coexist in a single OS process for efficient resource sharing. The system implements a complete Raft consensus algorithm with optimizations including batched writes, heartbeat multiplexing, and Phi Accrual Failure Detector for adaptive leader failure detection. It provides gRPC services for client interaction (read/write operations) and includes CLI tools for cluster management (monitoring, remapping, syncing). The architecture follows a modular design where each shard maintains independent Raft state while sharing underlying storage and network connections.

RATING: 8.1/10 MAINT: active DRIFT: low
▸ 3 reusable components found
rethinkdb/rethinkdb ★ 26996 1850 APPLICATION

RethinkDB is an open-source, distributed, NoSQL database designed for real-time applications. It stores JSON documents and supports automatic failover, sharding, and replication. The system exposes a powerful query language (ReQL) with support for joins, aggregations, geospatial queries, and real-time change feeds. The architecture is built on a custom coroutine runtime for efficient concurrency, a log-structured storage engine with B-tree indexes, and a peer-to-peer clustering layer using Raft consensus for metadata management. External dependencies include OpenSSL, Protobuf, jemalloc, zlib, and QuickJS for JavaScript execution. The codebase demonstrates strong engineering in distributed systems, but is now stale with limited active maintenance and significant technical debt from outdated C++ practices and vendored third-party libraries.

RATING: 7.1/10 MAINT: stale DRIFT: high
▸ 3 reusable components found
── end of results ──
$ submit: