mirror of https://github.com/k3s-io/k3s
123 lines
3.7 KiB
Go
123 lines
3.7 KiB
Go
/*
|
|
Copyright 2016 The Kubernetes Authors All rights reserved.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package e2e_node
|
|
|
|
import (
|
|
"time"
|
|
|
|
"k8s.io/kubernetes/pkg/api"
|
|
"k8s.io/kubernetes/pkg/client/restclient"
|
|
client "k8s.io/kubernetes/pkg/client/unversioned"
|
|
|
|
. "github.com/onsi/ginkgo"
|
|
. "github.com/onsi/gomega"
|
|
)
|
|
|
|
const (
|
|
serviceCreateTimeout = 2 * time.Minute
|
|
)
|
|
|
|
var _ = Describe("Container Conformance Test", func() {
|
|
var cl *client.Client
|
|
|
|
BeforeEach(func() {
|
|
// Setup the apiserver client
|
|
cl = client.NewOrDie(&restclient.Config{Host: *apiServerAddress})
|
|
})
|
|
|
|
Describe("container conformance blackbox test", func() {
|
|
Context("when running a container that terminates", func() {
|
|
var terminateCase ConformanceContainer
|
|
BeforeEach(func() {
|
|
terminateCase = ConformanceContainer{
|
|
Container: api.Container{
|
|
Image: "gcr.io/google_containers/busybox:1.24",
|
|
Name: "busybox",
|
|
Command: []string{"sh", "-c", "env"},
|
|
ImagePullPolicy: api.PullIfNotPresent,
|
|
},
|
|
Client: cl,
|
|
Phase: api.PodSucceeded,
|
|
NodeName: *nodeName,
|
|
}
|
|
})
|
|
It("it should start successfully [Conformance]", func() {
|
|
err := terminateCase.Create()
|
|
Expect(err).NotTo(HaveOccurred())
|
|
|
|
phase := api.PodPending
|
|
for start := time.Now(); time.Since(start) < serviceCreateTimeout; time.Sleep(time.Second * 30) {
|
|
ccontainer, err := terminateCase.Get()
|
|
if err != nil || ccontainer.Phase != api.PodPending {
|
|
phase = ccontainer.Phase
|
|
break
|
|
}
|
|
}
|
|
Expect(phase).Should(Equal(terminateCase.Phase))
|
|
})
|
|
It("it should report its phase as 'succeeded' [Conformance]", func() {
|
|
ccontainer, err := terminateCase.Get()
|
|
Expect(err).NotTo(HaveOccurred())
|
|
Expect(ccontainer).Should(CContainerEqual(terminateCase))
|
|
})
|
|
It("it should be possible to delete [Conformance]", func() {
|
|
err := terminateCase.Delete()
|
|
Expect(err).NotTo(HaveOccurred())
|
|
})
|
|
})
|
|
Context("when running a container with invalid image", func() {
|
|
var invalidImageCase ConformanceContainer
|
|
BeforeEach(func() {
|
|
invalidImageCase = ConformanceContainer{
|
|
Container: api.Container{
|
|
Image: "foo.com/foo/foo",
|
|
Name: "foo",
|
|
Command: []string{"foo", "'Should not work'"},
|
|
ImagePullPolicy: api.PullIfNotPresent,
|
|
},
|
|
Client: cl,
|
|
Phase: api.PodPending,
|
|
NodeName: *nodeName,
|
|
}
|
|
})
|
|
It("it should not start successfully [Conformance]", func() {
|
|
err := invalidImageCase.Create()
|
|
Expect(err).NotTo(HaveOccurred())
|
|
|
|
phase := api.PodPending
|
|
for start := time.Now(); time.Since(start) < serviceCreateTimeout; time.Sleep(time.Second * 30) {
|
|
ccontainer, err := invalidImageCase.Get()
|
|
if err != nil || ccontainer.Phase != api.PodPending {
|
|
phase = ccontainer.Phase
|
|
break
|
|
}
|
|
}
|
|
Expect(phase).Should(Equal(invalidImageCase.Phase))
|
|
})
|
|
It("it should report its phase as 'pending' [Conformance]", func() {
|
|
ccontainer, err := invalidImageCase.Get()
|
|
Expect(err).NotTo(HaveOccurred())
|
|
Expect(ccontainer).Should(CContainerEqual(invalidImageCase))
|
|
})
|
|
It("it should be possible to delete [Conformance]", func() {
|
|
err := invalidImageCase.Delete()
|
|
Expect(err).NotTo(HaveOccurred())
|
|
})
|
|
})
|
|
})
|
|
})
|