change: Rename tower-batch to tower-batch-control (#6907)

Cargo.lock

@@ -4718,7 +4718,7 @@ dependencies = [
 ]
 
 [[package]]
-name = "tower-batch"
+name = "tower-batch-control"
 version = "0.2.40"
 dependencies = [
  "color-eyre",
@@ -5728,7 +5728,7 @@ dependencies = [
  "tinyvec",
  "tokio",
  "tower",
- "tower-batch",
+ "tower-batch-control",
  "tower-fallback",
  "tracing",
  "tracing-error",

Cargo.toml

@@ -10,7 +10,7 @@ members = [
         "zebra-node-services",
         "zebra-test",
         "zebra-utils",
-        "tower-batch",
+        "tower-batch-control",
         "tower-fallback",
 ]
 

book/src/dev/overview.md

@@ -123,7 +123,7 @@ into several components:
   of blocks and transactions: all consensus
   rules that can be checked independently of the chain state, such as
   verification of signatures, proofs, and scripts. Internally, the library
-  uses [`tower-batch`](https://doc.zebra.zfnd.org/tower_batch/index.html) to
+  uses [`tower-batch-control`](https://doc.zebra.zfnd.org/tower_batch_control/index.html) to
   perform automatic, transparent batch processing of contemporaneous
   verification requests.
 

book/src/dev/rfcs/0011-async-rust-in-zebra.md

@@ -14,7 +14,7 @@ with the [tokio](https://docs.rs/tokio/) executor.
 
 At a higher level, Zebra also uses [`tower::Service`s](https://docs.rs/tower/0.4.1/tower/trait.Service.html),
 [`tower::Buffer`s](https://docs.rs/tower/0.4.1/tower/buffer/struct.Buffer.html),
-and our own [`tower-batch`](https://github.com/ZcashFoundation/zebra/tree/main/tower-batch)
+and our own [`tower-batch-control`](https://github.com/ZcashFoundation/zebra/tree/main/tower-batch-control)
 implementation.
 
 # Motivation
@@ -737,7 +737,7 @@ particularly important for code that modifies Zebra's highly concurrent crates:
 - `zebra-network`
 - `zebra-state`
 - `zebra-consensus`
-- `tower-batch`
+- `tower-batch-control`
 - `tower-fallback`
 
 ## Monitoring Async Code

tower-batch-control/Cargo.toml

@@ -1,5 +1,5 @@
 [package]
-name = "tower-batch"
+name = "tower-batch-control"
 version = "0.2.40"
 authors = ["Zcash Foundation <zebra@zfnd.org>"]
 license = "MIT"

tower-batch-control/tests/ed25519.rs

@@ -7,7 +7,7 @@ use ed25519_zebra::*;
 use futures::stream::{FuturesOrdered, StreamExt};
 use rand::thread_rng;
 use tower::{Service, ServiceExt};
-use tower_batch::Batch;
+use tower_batch_control::Batch;
 use tower_fallback::Fallback;
 
 // ============ service impl ============

tower-batch-control/tests/worker.rs

@@ -4,7 +4,7 @@ use std::time::Duration;
 
 use tokio_test::{assert_pending, assert_ready, assert_ready_err, task};
 use tower::{Service, ServiceExt};
-use tower_batch::{error, Batch};
+use tower_batch_control::{error, Batch};
 use tower_test::mock;
 
 #[tokio::test]

zebra-consensus/Cargo.toml

@@ -54,7 +54,7 @@ orchard = "0.4.0"
 zcash_proofs = { version = "0.11.0", features = ["local-prover", "multicore", "download-params"] }
 
 tower-fallback = { path = "../tower-fallback/" }
-tower-batch = { path = "../tower-batch/" }
+tower-batch-control = { path = "../tower-batch-control/" }
 
 zebra-script = { path = "../zebra-script" }
 zebra-state = { path = "../zebra-state" }

zebra-consensus/src/primitives/ed25519.rs

@@ -14,7 +14,7 @@ use rand::thread_rng;
 use rayon::prelude::*;
 use tokio::sync::watch;
 use tower::{util::ServiceFn, Service};
-use tower_batch::{Batch, BatchControl};
+use tower_batch_control::{Batch, BatchControl};
 use tower_fallback::Fallback;
 use zebra_chain::primitives::ed25519::{batch, *};
 

zebra-consensus/src/primitives/ed25519/tests.rs

@@ -5,7 +5,7 @@ use std::time::Duration;
 use color_eyre::eyre::{eyre, Result};
 use futures::stream::{FuturesUnordered, StreamExt};
 use tower::ServiceExt;
-use tower_batch::Batch;
+use tower_batch_control::Batch;
 
 use crate::primitives::ed25519::*;
 

zebra-consensus/src/primitives/groth16.rs

@@ -22,7 +22,7 @@ use rayon::prelude::*;
 use tokio::sync::watch;
 use tower::{util::ServiceFn, Service};
 
-use tower_batch::{Batch, BatchControl};
+use tower_batch_control::{Batch, BatchControl};
 use tower_fallback::{BoxedError, Fallback};
 
 use zebra_chain::{

zebra-consensus/src/primitives/halo2.rs

@@ -17,7 +17,7 @@ use rayon::prelude::*;
 use thiserror::Error;
 use tokio::sync::watch;
 use tower::{util::ServiceFn, Service};
-use tower_batch::{Batch, BatchControl};
+use tower_batch_control::{Batch, BatchControl};
 use tower_fallback::Fallback;
 
 #[cfg(test)]

zebra-consensus/src/primitives/redjubjub.rs

@@ -14,7 +14,7 @@ use rand::thread_rng;
 use rayon::prelude::*;
 use tokio::sync::watch;
 use tower::{util::ServiceFn, Service};
-use tower_batch::{Batch, BatchControl};
+use tower_batch_control::{Batch, BatchControl};
 use tower_fallback::Fallback;
 
 use zebra_chain::primitives::redjubjub::{batch, *};

zebra-consensus/src/primitives/redjubjub/tests.rs

@@ -7,7 +7,7 @@ use std::time::Duration;
 use color_eyre::eyre::{eyre, Result};
 use futures::stream::{FuturesUnordered, StreamExt};
 use tower::ServiceExt;
-use tower_batch::Batch;
+use tower_batch_control::Batch;
 
 async fn sign_and_verify<V>(mut verifier: V, n: usize) -> Result<(), V::Error>
 where

zebra-consensus/src/primitives/redpallas.rs

@@ -14,7 +14,7 @@ use rand::thread_rng;
 use rayon::prelude::*;
 use tokio::sync::watch;
 use tower::{util::ServiceFn, Service};
-use tower_batch::{Batch, BatchControl};
+use tower_batch_control::{Batch, BatchControl};
 use tower_fallback::Fallback;
 
 use zebra_chain::primitives::reddsa::{batch, orchard, Error};

zebra-consensus/src/primitives/redpallas/tests.rs

@@ -7,7 +7,7 @@ use std::time::Duration;
 use color_eyre::eyre::{eyre, Result};
 use futures::stream::{FuturesUnordered, StreamExt};
 use tower::ServiceExt;
-use tower_batch::Batch;
+use tower_batch_control::Batch;
 
 use zebra_chain::primitives::reddsa::{
     orchard::{Binding, SpendAuth},