feat: Implement raft via gRPC (#63)

* Replace toy-rpc with tonic gRPC * implement glaredb cli for raft nodes and client * current progress * implement begin, allocate_table, and get_schema * implement scan * implement insert * cleanup * comment out old tests * clean up ConsensusClient * Implement change membership command * rewrite cluster tests to use RaftClientSource * add protoc to CI * switch raft to in-memory implementation * Remove application logic from raft cluster tests * cargo fmt * add tracing to RPC impls * Remove lemur from raft crate * remove raft_client example * Apply suggestions from code review Co-authored-by: Sean Smith <[email protected]> * remove protoc from ci * Remove lemur_impl from raft crate * Store tonic clients instead of endpoint in ConsensusClient * use shared n_retries * Add default num_retries * Apply suggestions from code review Co-authored-by: Rustom Shareef <[email protected]> * moved some mod.rs modules into their parent directories * implement ConsensusClient retry to find leader using macro * Fix missing delimiter * fix clippy issues * rewrite retry_rpc_on_leader macro to evaluate to an expression * remove panics in rpc server impls Co-authored-by: Sean Smith <[email protected]> Co-authored-by: Rustom Shareef <[email protected]>
GlareDB · Sep 22, 2022 · 9994be0 · 9994be0
1 parent 4d0d6db
commit 9994be0
Show file tree

Hide file tree

Showing 35 changed files with 1,172 additions and 1,114 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/crates/arrowstore/src/memory.rs b/crates/arrowstore/src/memory.rs
@@ -318,7 +318,7 @@ impl Index {
         for row_idx in 0..batch.num_rows() {
             let key = pk_cols
                 .iter()
-                .map(|col| ScalarValue::try_from_array(*col, row_idx))
+                .map(|col| ScalarValue::try_from_array(col, row_idx))
                 .collect::<Result<Vec<_>, _>>()?;
             if pk.insert(key, row_idx).is_some() {
                 return Err(MemoryError::DuplicatePrimaryKey);

diff --git a/crates/glaredb/Cargo.toml b/crates/glaredb/Cargo.toml
@@ -10,6 +10,7 @@ path = "src/bin/main.rs"
 [dependencies]
 logutil = {path = "../logutil"}
 lemur = {path = "../lemur"}
+raft = {path = "../raft"}
 storageengine = {path = "../storageengine"}
 sqlexec = {path = "../sqlexec"}
 pgsrv = {path = "../pgsrv"}