remove unused parameter

Signed-off-by: Andres Taylor <[email protected]>
vitessio · Oct 9, 2024 · 74b891b · 74b891b
1 parent 594f64d
commit 74b891b
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 5 deletions.
diff --git a/go/tester/comparing_query_runner.go b/go/tester/comparing_query_runner.go
@@ -42,7 +42,12 @@ type (
 
 func (f ComparingQueryRunnerFactory) Close() {}
 
-func (f ComparingQueryRunnerFactory) NewQueryRunner(reporter Reporter, handleCreateTable CreateTableHandler, comparer utils.MySQLCompare, cluster *cluster.LocalProcessCluster, table func(name string) (ks string, err error)) QueryRunner {
+func (f ComparingQueryRunnerFactory) NewQueryRunner(
+	reporter Reporter,
+	handleCreateTable CreateTableHandler,
+	comparer utils.MySQLCompare,
+	cluster *cluster.LocalProcessCluster,
+) QueryRunner {
 	return newComparingQueryRunner(reporter, handleCreateTable, comparer, cluster)
 }
 

diff --git a/go/tester/tester.go b/go/tester/tester.go
@@ -65,7 +65,7 @@ type (
 	}
 
 	QueryRunnerFactory interface {
-		NewQueryRunner(reporter Reporter, handleCreateTable CreateTableHandler, comparer utils.MySQLCompare, cluster *cluster.LocalProcessCluster, table func(name string) (ks string, err error)) QueryRunner
+		NewQueryRunner(reporter Reporter, handleCreateTable CreateTableHandler, comparer utils.MySQLCompare, cluster *cluster.LocalProcessCluster) QueryRunner
 		Close()
 	}
 )
@@ -101,7 +101,7 @@ func NewTester(
 	if !t.autoVSchema() {
 		createTableHandler = func(*sqlparser.CreateTable) func() { return func() {} }
 	}
-	t.qr = factory.NewQueryRunner(reporter, createTableHandler, mcmp, clusterInstance, t.findTable)
+	t.qr = factory.NewQueryRunner(reporter, createTableHandler, mcmp, clusterInstance)
 
 	return t
 }

diff --git a/go/tester/tracer.go b/go/tester/tracer.go
@@ -56,8 +56,13 @@ func NewTracerFactory(traceFile *os.File, inner QueryRunnerFactory) *TracerFacto
 	}
 }
 
-func (t *TracerFactory) NewQueryRunner(reporter Reporter, handleCreateTable CreateTableHandler, comparer utils.MySQLCompare, cluster *cluster.LocalProcessCluster, table func(name string) (ks string, err error)) QueryRunner {
-	inner := t.inner.NewQueryRunner(reporter, handleCreateTable, comparer, cluster, table)
+func (t *TracerFactory) NewQueryRunner(
+	reporter Reporter,
+	handleCreateTable CreateTableHandler,
+	comparer utils.MySQLCompare,
+	cluster *cluster.LocalProcessCluster,
+) QueryRunner {
+	inner := t.inner.NewQueryRunner(reporter, handleCreateTable, comparer, cluster)
 	return newTracer(t.traceFile, comparer.MySQLConn, comparer.VtConn, reporter, inner)
 }