diff --git a/staging/src/k8s.io/apiserver/pkg/storage/etcd/testing/BUILD b/staging/src/k8s.io/apiserver/pkg/storage/etcd/testing/BUILD index ac48442e50d..5d495404c6d 100644 --- a/staging/src/k8s.io/apiserver/pkg/storage/etcd/testing/BUILD +++ b/staging/src/k8s.io/apiserver/pkg/storage/etcd/testing/BUILD @@ -13,6 +13,7 @@ go_library( "//vendor/github.com/coreos/etcd/client:go_default_library", "//vendor/github.com/coreos/etcd/clientv3:go_default_library", "//vendor/github.com/coreos/etcd/etcdserver:go_default_library", + "//vendor/github.com/coreos/etcd/etcdserver/api/etcdhttp:go_default_library", "//vendor/github.com/coreos/etcd/etcdserver/api/v2http:go_default_library", "//vendor/github.com/coreos/etcd/integration:go_default_library", "//vendor/github.com/coreos/etcd/pkg/testutil:go_default_library", diff --git a/staging/src/k8s.io/apiserver/pkg/storage/etcd/testing/utils.go b/staging/src/k8s.io/apiserver/pkg/storage/etcd/testing/utils.go index 6ab310b601e..96d21b5812e 100644 --- a/staging/src/k8s.io/apiserver/pkg/storage/etcd/testing/utils.go +++ b/staging/src/k8s.io/apiserver/pkg/storage/etcd/testing/utils.go @@ -35,6 +35,7 @@ import ( etcd "github.com/coreos/etcd/client" "github.com/coreos/etcd/clientv3" "github.com/coreos/etcd/etcdserver" + "github.com/coreos/etcd/etcdserver/api/etcdhttp" "github.com/coreos/etcd/etcdserver/api/v2http" "github.com/coreos/etcd/integration" "github.com/coreos/etcd/pkg/testutil" @@ -154,6 +155,7 @@ func configureTestCluster(t *testing.T, name string, https bool) *EtcdTestServer if err != nil { t.Fatal(err) } + m.AuthToken = "simple" } else { cln := newLocalListener(t) m.ClientListeners = []net.Listener{cln} @@ -189,9 +191,9 @@ func (m *EtcdTestServer) launch(t *testing.T) error { if m.s, err = etcdserver.NewServer(&m.ServerConfig); err != nil { return fmt.Errorf("failed to initialize the etcd server: %v", err) } - m.s.SyncTicker = time.Tick(500 * time.Millisecond) + m.s.SyncTicker = time.NewTicker(500 * time.Millisecond) m.s.Start() - m.raftHandler = &testutil.PauseableHandler{Next: v2http.NewPeerHandler(m.s)} + m.raftHandler = &testutil.PauseableHandler{Next: etcdhttp.NewPeerHandler(m.s)} for _, ln := range m.PeerListeners { hs := &httptest.Server{ Listener: ln, diff --git a/test/e2e_node/services/etcd.go b/test/e2e_node/services/etcd.go index 9176ff7a0d7..8c40dc7797e 100644 --- a/test/e2e_node/services/etcd.go +++ b/test/e2e_node/services/etcd.go @@ -77,6 +77,7 @@ func NewEtcd(dataDir string) *EtcdServer { MaxWALFiles: maxWALFiles, TickMs: tickMs, ElectionTicks: electionTicks, + AuthToken: "simple", } return &EtcdServer{ diff --git a/test/integration/scale/BUILD b/test/integration/scale/BUILD index 120e556ce4b..5fd7eb7c093 100644 --- a/test/integration/scale/BUILD +++ b/test/integration/scale/BUILD @@ -14,6 +14,7 @@ go_test( deps = [ "//cmd/kube-apiserver/app/testing:go_default_library", "//test/integration/framework:go_default_library", + "//vendor/github.com/coreos/etcd/etcdserver/api/v3rpc:go_default_library", "//vendor/github.com/coreos/pkg/capnslog:go_default_library", "//vendor/k8s.io/api/apps/v1beta2:go_default_library", "//vendor/k8s.io/api/core/v1:go_default_library", diff --git a/test/integration/scale/scale_test.go b/test/integration/scale/scale_test.go index a40093571c1..fe92420ec1e 100644 --- a/test/integration/scale/scale_test.go +++ b/test/integration/scale/scale_test.go @@ -22,6 +22,7 @@ import ( "strings" "testing" + _ "github.com/coreos/etcd/etcdserver/api/v3rpc" // Force package logger init. "github.com/coreos/pkg/capnslog" appsv1beta2 "k8s.io/api/apps/v1beta2"