Merge pull request #125 from tinycedar/master

Remove warnings accoring to cargo build

src/bin/toshi.rs

@@ -170,7 +170,7 @@ fn run(catalog: Arc<RwLock<IndexCatalog>>, settings: &Settings) -> impl Future<I
         let run = future::lazy(move || connect_to_consul(&settings)).and_then(move |_| {
             tokio::spawn(commit_watcher);
 
-            let mut consul = Consul::builder()
+            let consul = Consul::builder()
                 .with_cluster_name(cluster_name)
                 .with_address(consul_addr)
                 .build()

src/cluster/placement/background.rs

@@ -2,21 +2,17 @@ use crate::cluster::{consul::Consul, ClusterError};
 use futures::{try_ready, Future, Poll};
 use futures_watch::{Store, Watch};
 use log::debug;
-use std::collections::{HashSet, VecDeque};
-use std::hash::Hash;
+use std::collections::HashSet;
 use std::net::SocketAddr;
 use std::time::{Duration, Instant};
 use tokio::sync::mpsc;
 use tokio::timer::Delay;
 use tower_consul::ConsulService;
-use tower_discover::Change;
-use tower_service::Service;
 
 pub struct Background {
     consul: Consul,
     // TODO: better D/S for this?
     store: Store<HashSet<SocketAddr>>,
-    nodes: HashSet<SocketAddr>,
     state: State,
     interval: Duration,
 }
@@ -32,7 +28,6 @@ impl Background {
         let bg = Background {
             consul,
             store,
-            nodes: HashSet::new(),
             state,
             interval,
         };

src/cluster/placement/mod.rs

@@ -1,17 +1,14 @@
 use crate::cluster::consul::Consul;
 use crate::cluster::placement_proto::{server, PlacementReply, PlacementRequest};
-use futures::{future, try_ready, Async, Future, Poll, Stream};
+use futures::{future, Future, Stream};
 use futures_watch::Watch;
 use log::error;
 use std::collections::HashSet;
-use std::fmt;
 use std::net::SocketAddr;
 use tokio::executor::DefaultExecutor;
 use tokio::net::TcpListener;
-use tower_discover::{Change, Discover};
 use tower_grpc::{Error, Request, Response};
 use tower_h2::Server;
-use tower_service::Service;
 
 pub mod background;
 
@@ -54,7 +51,7 @@ impl Place {
 impl server::Placement for Place {
     type GetPlacementFuture = GrpcFuture<PlacementReply>;
 
-    fn get_placement(&mut self, request: Request<PlacementRequest>) -> Self::GetPlacementFuture {
+    fn get_placement(&mut self, _request: Request<PlacementRequest>) -> Self::GetPlacementFuture {
         unimplemented!()
     }
 }