From 813a052461bab9dfe8e3b86d6607050e54259906 Mon Sep 17 00:00:00 2001
From: Ben <ben.bromhead@gmail.com>
Date: Fri, 30 Oct 2020 13:33:33 +1300
Subject: [PATCH] v0.0.9 prep

Clean imports
Upversion
---
 Cargo.toml                                       | 2 +-
 src/main.rs                                      | 2 +-
 src/transforms/chain.rs                          | 5 ++---
 src/transforms/redis_transforms/redis_cluster.rs | 4 ++--
 4 files changed, 6 insertions(+), 7 deletions(-)

diff --git a/Cargo.toml b/Cargo.toml
index 9e48e5a41..4c87a42f4 100644
--- a/Cargo.toml
+++ b/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"
 
diff --git a/src/main.rs b/src/main.rs
index b149756a9..d82ea58fb 100644
--- a/src/main.rs
+++ b/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,
diff --git a/src/transforms/chain.rs b/src/transforms/chain.rs
index c44005b47..e3dbda68e 100644
--- a/src/transforms/chain.rs
+++ b/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 {
diff --git a/src/transforms/redis_transforms/redis_cluster.rs b/src/transforms/redis_transforms/redis_cluster.rs
index 96ff02780..8374b6f41 100644
--- a/src/transforms/redis_transforms/redis_cluster.rs
+++ b/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;