Add debug impl for Cluster

artillery-core/src/epidemic/cluster.rs

@@ -14,6 +14,7 @@ use std::{
 };
 use uuid::Uuid;
 
+#[derive(Debug)]
 pub struct Cluster {
     pub events: Receiver<ArtilleryClusterEvent>,
     comm: Sender<ArtilleryClusterRequest>,

artillery-ddata/benches/craq_bencher.rs

@@ -2,7 +2,6 @@ use criterion::{criterion_group, criterion_main, Criterion};
 
 use artillery_ddata::craq::prelude::*;
 
-use futures::stream::StreamExt;
 use rand::distributions::Alphanumeric;
 use rand::prelude::*;
 

artillery-ddata/examples/craq_node.rs

@@ -77,7 +77,8 @@ fn main() {
                 assert_eq!(nodes.len(), varargs.len(), "Node address parsing failed");
 
                 let chain = CraqChain::new(&nodes, node_index).unwrap();
-                CraqNode::start(cr_mode, chain, CraqConfig::default());
+                CraqNode::start(cr_mode, chain, CraqConfig::default())
+                    .expect("couldn't start CRAQ node");
             }
         }
         ("client", Some(client_matches)) => {

artillery-ddata/src/craq/client.rs

@@ -8,8 +8,7 @@ use super::{
 use std::net::{SocketAddr, ToSocketAddrs};
 use thrift::protocol::{TBinaryInputProtocol, TBinaryOutputProtocol};
 use thrift::transport::{
-    TFramedReadTransport, TFramedReadTransportFactory, TFramedWriteTransport,
-    TFramedWriteTransportFactory, TIoChannel, TTcpChannel as BiTcp,
+    TFramedReadTransport, TFramedWriteTransport, TIoChannel, TTcpChannel as BiTcp,
 };
 
 pub struct ReadObject {
@@ -47,6 +46,8 @@ impl fmt::Display for ReadObject {
     }
 }
 
+// Will be fixed as we implement stuff
+#[allow(dead_code)]
 pub struct DDataCraqClient {
     host: SocketAddr,
     cc: CraqClient,