Paxos Implementation

Cargo.toml

@@ -21,4 +21,5 @@ shlex = "1.3.0"
 tokio = { version = "1.41.1", features = ["full"] }
 pest = "2.6"
 pest_derive = "2.6"
-bit-set = "0.8.0"
+rsntp = "4.0.0"
+chrono = "0.4.40"

src/db/main.rs

@@ -1,5 +1,6 @@
 mod loki_kv;
 mod parser;
+mod paxos;
 mod server_multithread;
 use tokio::net::TcpListener;
 

src/db/paxos/mod.rs

@@ -0,0 +1 @@
+pub mod timeserver;

src/db/paxos/timeserver.rs

@@ -0,0 +1,29 @@
+use chrono::{DateTime, Local};
+use rsntp::SntpClient;
+
+struct TTInterval {
+    earliest: usize,
+    latest: usize,
+}
+
+trait timeserver {
+    fn new() -> Self;
+    fn now() -> Option<TTInterval>;
+    fn after() -> bool;
+    fn before() -> bool;
+}
+
+struct NTPTimeServer{
+    identifier: String,
+    client: SntpClient
+}
+
+impl timeserver for NTPTimeServer{
+    fn new() -> Self{
+        let client = SntpClient::new();
+        NTPTimeServer { identifier: "id-TODO", client }
+    }
+    fn now() -> Option<TTInterval>{}
+    fn after() -> bool{}
+    fn before() -> bool{}
+}