hot fix: add sub batch arg

Author: gatsbyz

cmd/monitor/cmd.go

@@ -18,6 +18,7 @@ var (
 	// flags
 	rpcUrl          string
 	batchSizeValue  string
+	subBatchSize    int
 	blockCacheLimit int
 	intervalStr     string
 
@@ -77,6 +78,7 @@ var MonitorCmd = &cobra.Command{
 func init() {
 	MonitorCmd.PersistentFlags().StringVarP(&rpcUrl, "rpc-url", "r", "http://localhost:8545", "The RPC endpoint url")
 	MonitorCmd.PersistentFlags().StringVarP(&batchSizeValue, "batch-size", "b", "auto", "Number of requests per batch")
+	MonitorCmd.PersistentFlags().IntVarP(&subBatchSize, "sub-batch-size", "s", 50, "Number of requests per sub-batch")
 	MonitorCmd.PersistentFlags().IntVarP(&blockCacheLimit, "cache-limit", "c", 200, "Number of cached blocks for the LRU block data structure (Min 100)")
 	MonitorCmd.PersistentFlags().StringVarP(&intervalStr, "interval", "i", "5s", "Amount of time between batch block rpc calls")
 }

cmd/monitor/monitor.go

@@ -52,9 +52,6 @@ var (
 
 	// semaphore is a channel used to control the concurrency of block data fetch operations.
 	semaphore = make(chan struct{}, maxConcurrency)
-
-	// size of the sub batches to divide and conquer the total batch size with
-	subBatchSize = 50
 )
 
 type (