@@ -12,7 +12,6 @@ import (
1212
1313	"code.cloudfoundry.org/bbs/test_helpers" 
1414	"code.cloudfoundry.org/bbs/test_helpers/sqlrunner" 
15- 	"code.cloudfoundry.org/consuladapter/consulrunner" 
1615	"code.cloudfoundry.org/inigo/helpers/portauthority" 
1716	"code.cloudfoundry.org/locket/cmd/locket/config" 
1817	"code.cloudfoundry.org/locket/cmd/locket/testrunner" 
3332	locketProcess          ifrit.Process 
3433	dbRunner               sqlrunner.SQLRunner 
3534	dbProcess              ifrit.Process 
36- 	consulRunner           * consulrunner.ClusterRunner 
3735	locketAPILocation      string 
3836	locketCACertFile       string 
3937	locketClientCertFile   string 
@@ -103,23 +101,11 @@ var _ = BeforeEach(func() {
103101	dbRunner  =  test_helpers .NewSQLRunner (dbName )
104102	dbProcess  =  ginkgomon .Invoke (dbRunner )
105103
106- 	consulStartingPort , err  :=  portAllocator .ClaimPorts (consulrunner .PortOffsetLength )
107- 	Expect (err ).NotTo (HaveOccurred ())
108- 	consulRunner  =  consulrunner .NewClusterRunner (
109- 		consulrunner.ClusterRunnerConfig {
110- 			StartingPort : int (consulStartingPort ),
111- 			NumNodes :     1 ,
112- 			Scheme :       "http" ,
113- 		},
114- 	)
115- 	consulRunner .Start ()
116- 
117104	locketRunner  =  testrunner .NewLocketRunner (locketPath , func (cfg  * config.LocketConfig ) {
118105		cfg .CaFile  =  locketCACertFile 
119106		cfg .CertFile  =  locketServerCertFile 
120107		cfg .KeyFile  =  locketServerKeyFile 
121108		cfg .ListenAddress  =  locketAPILocation 
122- 		cfg .ConsulCluster  =  consulRunner .ConsulCluster ()
123109		cfg .DatabaseDriver  =  dbRunner .DriverName ()
124110		cfg .DatabaseConnectionString  =  dbRunner .ConnectionString ()
125111	})
@@ -131,7 +117,6 @@ var _ = AfterEach(func() {
131117	bbsServer .Close ()
132118	ginkgomon .Interrupt (locketProcess , 5 * time .Second )
133119	ginkgomon .Interrupt (dbProcess , 5 * time .Second ) // we've been seeing the sql teardown take longer than the default of 1s 
134- 	consulRunner .Stop ()
135120})
136121
137122func  TestIntegration (t  * testing.T ) {
0 commit comments