diff --git a/osbase/event/etcd/etcd_test.go b/osbase/event/etcd/etcd_test.go
index a5cde20..729f4ad 100644
--- a/osbase/event/etcd/etcd_test.go
+++ b/osbase/event/etcd/etcd_test.go
@@ -18,7 +18,7 @@
 	"go.etcd.io/etcd/api/v3/v3rpc/rpctypes"
 	"go.etcd.io/etcd/client/pkg/v3/testutil"
 	clientv3 "go.etcd.io/etcd/client/v3"
-	"go.etcd.io/etcd/tests/v3/integration"
+	"go.etcd.io/etcd/tests/v3/framework/integration"
 	"go.uber.org/zap"
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/grpclog"
@@ -28,7 +28,7 @@
 )
 
 var (
-	cluster   *integration.ClusterV3
+	cluster   *integration.Cluster
 	endpoints []string
 )
 
@@ -50,7 +50,7 @@
 	flag.Parse()
 	integration.BeforeTestExternal(tb)
 	grpclog.SetLoggerV2(logtree.GRPCify(lt.MustLeveledFor("grpc")))
-	cluster = integration.NewClusterV3(tb, &cfg)
+	cluster = integration.NewCluster(tb, &cfg)
 	endpoints = make([]string, 3)
 	for i := range endpoints {
 		endpoints[i] = cluster.Client(i).Endpoints()[0]