k3s/test/e2e/generated_clientset.go

311 lines
9.0 KiB
Go
Raw Normal View History

2016-02-08 21:00:09 +00:00
/*
Copyright 2014 The Kubernetes Authors.
2016-02-08 21:00:09 +00:00
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
import (
"strconv"
"time"
clientapi "k8s.io/client-go/1.4/pkg/api"
clientv1 "k8s.io/client-go/1.4/pkg/api/v1"
2016-02-08 21:00:09 +00:00
"k8s.io/kubernetes/pkg/api"
"k8s.io/kubernetes/pkg/api/v1"
"k8s.io/kubernetes/pkg/labels"
"k8s.io/kubernetes/pkg/runtime"
2016-02-08 21:00:09 +00:00
"k8s.io/kubernetes/pkg/util/intstr"
2016-07-26 15:13:18 +00:00
"k8s.io/kubernetes/pkg/util/uuid"
"k8s.io/kubernetes/pkg/util/wait"
2016-02-08 21:00:09 +00:00
"k8s.io/kubernetes/pkg/watch"
"k8s.io/kubernetes/test/e2e/framework"
2016-02-08 21:00:09 +00:00
. "github.com/onsi/ginkgo"
. "github.com/onsi/gomega"
)
func stagingClientPod(name, value string) clientv1.Pod {
return clientv1.Pod{
ObjectMeta: clientv1.ObjectMeta{
Name: name,
Labels: map[string]string{
"name": "foo",
"time": value,
},
},
Spec: clientv1.PodSpec{
Containers: []clientv1.Container{
{
Name: "nginx",
Image: "gcr.io/google_containers/nginx-slim:0.7",
Ports: []clientv1.ContainerPort{{ContainerPort: 80}},
},
},
},
}
}
2016-04-04 22:59:18 +00:00
func testingPod(name, value string) v1.Pod {
return v1.Pod{
ObjectMeta: v1.ObjectMeta{
Name: name,
Labels: map[string]string{
"name": "foo",
"time": value,
2016-02-08 21:00:09 +00:00
},
2016-04-04 22:59:18 +00:00
},
Spec: v1.PodSpec{
Containers: []v1.Container{
{
Name: "nginx",
Image: "gcr.io/google_containers/nginx-slim:0.7",
2016-04-04 22:59:18 +00:00
Ports: []v1.ContainerPort{{ContainerPort: 80}},
LivenessProbe: &v1.Probe{
Handler: v1.Handler{
HTTPGet: &v1.HTTPGetAction{
Path: "/index.html",
Port: intstr.FromInt(8080),
2016-02-08 21:00:09 +00:00
},
},
2016-04-04 22:59:18 +00:00
InitialDelaySeconds: 30,
2016-02-08 21:00:09 +00:00
},
},
},
2016-04-04 22:59:18 +00:00
},
}
}
func observePodCreation(w watch.Interface) {
select {
case event, _ := <-w.ResultChan():
if event.Type != watch.Added {
framework.Failf("Failed to observe pod creation: %v", event)
}
case <-time.After(framework.PodStartTimeout):
framework.Failf("Timeout while waiting for pod creation")
2016-04-04 22:59:18 +00:00
}
}
func observeObjectDeletion(w watch.Interface) (obj runtime.Object) {
2016-04-04 22:59:18 +00:00
deleted := false
timeout := false
timer := time.After(60 * time.Second)
for !deleted && !timeout {
select {
case event, _ := <-w.ResultChan():
if event.Type == watch.Deleted {
obj = event.Object
2016-04-04 22:59:18 +00:00
deleted = true
}
case <-timer:
timeout = true
2016-02-08 21:00:09 +00:00
}
2016-04-04 22:59:18 +00:00
}
if !deleted {
framework.Failf("Failed to observe pod deletion")
2016-04-04 22:59:18 +00:00
}
return
}
2016-02-08 21:00:09 +00:00
2016-04-04 22:59:18 +00:00
var _ = framework.KubeDescribe("Generated release_1_2 clientset", func() {
f := framework.NewDefaultFramework("clientset")
It("should create pods, delete pods, watch pods", func() {
podClient := f.Clientset_1_2.Core().Pods(f.Namespace.Name)
By("constructing the pod")
2016-07-26 15:13:18 +00:00
name := "pod" + string(uuid.NewUUID())
2016-04-04 22:59:18 +00:00
value := strconv.Itoa(time.Now().Nanosecond())
podCopy := testingPod(name, value)
pod := &podCopy
2016-02-08 21:00:09 +00:00
By("setting up watch")
selector := labels.SelectorFromSet(labels.Set(map[string]string{"time": value}))
options := api.ListOptions{LabelSelector: selector}
pods, err := podClient.List(options)
if err != nil {
framework.Failf("Failed to query for pods: %v", err)
2016-02-08 21:00:09 +00:00
}
Expect(len(pods.Items)).To(Equal(0))
options = api.ListOptions{
LabelSelector: selector,
ResourceVersion: pods.ListMeta.ResourceVersion,
}
w, err := podClient.Watch(options)
if err != nil {
framework.Failf("Failed to set up watch: %v", err)
2016-02-08 21:00:09 +00:00
}
2016-04-04 22:59:18 +00:00
By("creating the pod")
pod, err = podClient.Create(pod)
if err != nil {
framework.Failf("Failed to create pod: %v", err)
}
2016-02-08 21:00:09 +00:00
// We call defer here in case there is a problem with
// the test so we can ensure that we clean up after
// ourselves
defer podClient.Delete(pod.Name, api.NewDeleteOptions(0))
2016-04-04 22:59:18 +00:00
By("verifying the pod is in kubernetes")
options = api.ListOptions{
LabelSelector: selector,
ResourceVersion: pod.ResourceVersion,
}
pods, err = podClient.List(options)
if err != nil {
framework.Failf("Failed to query for pods: %v", err)
}
Expect(len(pods.Items)).To(Equal(1))
By("verifying pod creation was observed")
observePodCreation(w)
// We need to wait for the pod to be scheduled, otherwise the deletion
// will be carried out immediately rather than gracefully.
framework.ExpectNoError(f.WaitForPodRunning(pod.Name))
By("deleting the pod gracefully")
if err := podClient.Delete(pod.Name, api.NewDeleteOptions(30)); err != nil {
framework.Failf("Failed to delete pod: %v", err)
}
By("verifying pod deletion was observed")
obj := observeObjectDeletion(w)
lastPod := obj.(*api.Pod)
2016-04-04 22:59:18 +00:00
Expect(lastPod.DeletionTimestamp).ToNot(BeNil())
Expect(lastPod.Spec.TerminationGracePeriodSeconds).ToNot(BeZero())
options = api.ListOptions{LabelSelector: selector}
pods, err = podClient.List(options)
if err != nil {
framework.Failf("Failed to list pods to verify deletion: %v", err)
2016-04-04 22:59:18 +00:00
}
Expect(len(pods.Items)).To(Equal(0))
})
})
var _ = framework.KubeDescribe("Generated release_1_3 clientset", func() {
f := framework.NewDefaultFramework("clientset")
It("should create pods, delete pods, watch pods", func() {
podClient := f.Clientset_1_3.Core().Pods(f.Namespace.Name)
By("constructing the pod")
2016-07-26 15:13:18 +00:00
name := "pod" + string(uuid.NewUUID())
2016-04-04 22:59:18 +00:00
value := strconv.Itoa(time.Now().Nanosecond())
podCopy := testingPod(name, value)
pod := &podCopy
By("setting up watch")
selector := labels.SelectorFromSet(labels.Set(map[string]string{"time": value}))
options := api.ListOptions{LabelSelector: selector}
pods, err := podClient.List(options)
if err != nil {
framework.Failf("Failed to query for pods: %v", err)
}
Expect(len(pods.Items)).To(Equal(0))
options = api.ListOptions{
LabelSelector: selector,
ResourceVersion: pods.ListMeta.ResourceVersion,
}
w, err := podClient.Watch(options)
if err != nil {
framework.Failf("Failed to set up watch: %v", err)
}
By("creating the pod")
pod, err = podClient.Create(pod)
2016-02-08 21:00:09 +00:00
if err != nil {
framework.Failf("Failed to create pod: %v", err)
2016-02-08 21:00:09 +00:00
}
2016-04-04 22:59:18 +00:00
// We call defer here in case there is a problem with
// the test so we can ensure that we clean up after
// ourselves
defer podClient.Delete(pod.Name, api.NewDeleteOptions(0))
2016-02-08 21:00:09 +00:00
By("verifying the pod is in kubernetes")
options = api.ListOptions{
LabelSelector: selector,
ResourceVersion: pod.ResourceVersion,
}
2016-02-08 21:00:09 +00:00
pods, err = podClient.List(options)
if err != nil {
framework.Failf("Failed to query for pods: %v", err)
2016-02-08 21:00:09 +00:00
}
Expect(len(pods.Items)).To(Equal(1))
By("verifying pod creation was observed")
2016-04-04 22:59:18 +00:00
observePodCreation(w)
2016-02-08 21:00:09 +00:00
// We need to wait for the pod to be scheduled, otherwise the deletion
// will be carried out immediately rather than gracefully.
framework.ExpectNoError(f.WaitForPodRunning(pod.Name))
2016-02-08 21:00:09 +00:00
By("deleting the pod gracefully")
if err := podClient.Delete(pod.Name, api.NewDeleteOptions(30)); err != nil {
framework.Failf("Failed to delete pod: %v", err)
2016-02-08 21:00:09 +00:00
}
By("verifying pod deletion was observed")
obj := observeObjectDeletion(w)
lastPod := obj.(*v1.Pod)
2016-02-08 21:00:09 +00:00
Expect(lastPod.DeletionTimestamp).ToNot(BeNil())
Expect(lastPod.Spec.TerminationGracePeriodSeconds).ToNot(BeZero())
options = api.ListOptions{LabelSelector: selector}
pods, err = podClient.List(options)
if err != nil {
framework.Failf("Failed to list pods to verify deletion: %v", err)
2016-02-08 21:00:09 +00:00
}
Expect(len(pods.Items)).To(Equal(0))
})
})
var _ = framework.KubeDescribe("Staging client repo client", func() {
f := framework.NewDefaultFramework("clientset")
It("should create pods, delete pods, watch pods", func() {
podClient := f.StagingClient.Core().Pods(f.Namespace.Name)
By("constructing the pod")
name := "pod" + string(uuid.NewUUID())
value := strconv.Itoa(time.Now().Nanosecond())
podCopy := stagingClientPod(name, value)
pod := &podCopy
By("verifying no pod exists before the test")
pods, err := podClient.List(clientapi.ListOptions{})
if err != nil {
framework.Failf("Failed to query for pods: %v", err)
}
Expect(len(pods.Items)).To(Equal(0))
By("creating the pod")
pod, err = podClient.Create(pod)
if err != nil {
framework.Failf("Failed to create pod: %v", err)
}
// We call defer here in case there is a problem with
// the test so we can ensure that we clean up after
// ourselves
defer podClient.Delete(pod.Name, clientapi.NewDeleteOptions(0))
By("verifying the pod is in kubernetes")
timeout := 1 * time.Minute
if err := wait.PollImmediate(time.Second, timeout, func() (bool, error) {
pods, err = podClient.List(clientapi.ListOptions{})
if err != nil {
return false, err
}
if len(pods.Items) == 1 {
return true, nil
}
return false, nil
}); err != nil {
framework.Failf("Err : %s\n. Failed to wait for 1 pod to be created", err)
}
})
})