Add tests

Signed-off-by: Heinz N. Gies <heinz@licenser.net>

Cargo.toml

@@ -211,6 +211,7 @@ tempfile = { version = "3.8" }
 test-case = "3.1"
 testcontainers = { version = "0.14", features = ["watchdog"] }
 bytes = "1"
+mockito = "1"
 
 [features]
 default = ["integration"]

k8s/README.md

@@ -3,7 +3,7 @@ Experimental, for testing, don't use in production or if you do fix all the thin
 
 Based on https://kubernetes.io/docs/tutorials/stateful-application/cassandra/
 
-this are purely notes
+These are purely notes
 
 ```
 minikube start --cpus 16 --memory 8192 --disk-size 50000mb

packaging/cross_build.sh

@@ -113,7 +113,7 @@ echo "Successfully built the binary: ${TARGET_BIN}"
 # linking check
 echo "Printing linking information for the binary..."
 file "$TARGET_BIN"
-ldd "$TARGET_BIN" || true
+ldd "$TARGET_BIN"
 
 # back to the origin dir, just in case
 popd > /dev/null

src/connectors.rs

@@ -294,7 +294,7 @@ pub(crate) trait Context: Display + Clone {
     fn connector_type(&self) -> &ConnectorType;
 
     /// gets the API sender
-    fn raft(&self) -> &raft::ClusterInterface;
+    fn raft(&self) -> Option<&raft::Cluster>;
 
     /// the application context
     fn app_ctx(&self) -> &AppContext;
@@ -389,8 +389,8 @@ impl Context for ConnectorContext {
         &self.notifier
     }
 
-    fn raft(&self) -> &raft::ClusterInterface {
-        &self.app_ctx.raft
+    fn raft(&self) -> Option<&raft::Cluster> {
+        self.app_ctx.raft.as_ref()
     }
 
     fn app_ctx(&self) -> &AppContext {
@@ -1342,8 +1342,8 @@ pub(crate) mod unit_tests {
         fn connector_type(&self) -> &ConnectorType {
             &self.t
         }
-        fn raft(&self) -> &raft::ClusterInterface {
-            &self.app_ctx.raft
+        fn raft(&self) -> Option<&raft::Cluster> {
+            self.app_ctx.raft.as_ref()
         }
         fn app_ctx(&self) -> &AppContext {
             &self.app_ctx