v0.0.9 prep

Clean imports
Upversion

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "shotover-proxy"
-version = "0.0.8"
+version = "0.0.9"
 authors = ["Ben <ben@instaclustr.com>"]
 edition = "2018"
 

src/main.rs

@@ -17,7 +17,7 @@ use std::net::SocketAddr;
 use tokio::runtime;
 
 #[derive(Clap)]
-#[clap(version = "0.0.8", author = "Instaclustr")]
+#[clap(version = "0.0.9", author = "Instaclustr")]
 struct ConfigOpts {
  #[clap(short, long, default_value = "config/topology.yaml")]
  pub topology_file: String,

src/transforms/chain.rs

@@ -8,7 +8,6 @@ use futures::FutureExt;
 
 use itertools::Itertools;
 use metrics::{counter, timing};
-use std::sync::atomic::AtomicUsize;
 use std::sync::Arc;
 use tokio::sync::mpsc::{channel, Receiver, Sender};
 use tokio::sync::oneshot::Receiver as OneReceiver;
@@ -84,8 +83,8 @@ impl TransformChain {
  let (tx, mut rx) = tokio::sync::mpsc::channel::<ChannelMessage>(buffer_size);
 
  // If this is not a test, this should get removed by the compiler
- let mut count_outer: Arc<Mutex<usize>> = Arc::new(Mutex::new(0 as usize));
- let mut count = count_outer.clone();
+ let count_outer: Arc<Mutex<usize>> = Arc::new(Mutex::new(0 as usize));
+ let count = count_outer.clone();
 
  // Even though we don't keep the join handle, this thread will wrap up once all corresponding senders have been dropped.
  let _jh = tokio::spawn(async move {

src/transforms/redis_transforms/redis_cluster.rs

@@ -1,4 +1,4 @@
-use anyhow::{anyhow, Result};
+use anyhow::Result;
 use async_trait::async_trait;
 use serde::{Deserialize, Serialize};
 
@@ -14,7 +14,7 @@ use redis::cluster_async::{ClusterClientBuilder, ClusterConnection, RoutingInfo}
 use redis::{cmd as redis_cmd, Cmd, ErrorKind};
 use redis::{Pipeline, RedisError, RedisResult};
 
-use tracing::{info, trace, warn};
+use tracing::{trace, warn};
 
 use crate::transforms::{Transform, Transforms, TransformsFromConfig, Wrapper};
 use itertools::Itertools;