From 6232b9b361fcb37d2244699dca04893362593fd9 Mon Sep 17 00:00:00 2001
From: David Eads <deads@redhat.com>
Date: Thu, 11 Jan 2018 09:47:38 -0500
Subject: [PATCH] remove dead code

---
 test/util/verify.go | 142 --------------------------------------------
 1 file changed, 142 deletions(-)
 delete mode 100644 test/util/verify.go

diff --git a/test/util/verify.go b/test/util/verify.go
deleted file mode 100644
index 2957cc653851..000000000000
--- a/test/util/verify.go
+++ /dev/null
@@ -1,142 +0,0 @@
-package util
-
-import (
-	"fmt"
-	"net"
-	"strconv"
-
-	imageapi "github.com/openshift/origin/pkg/image/apis/image"
-	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	"k8s.io/apimachinery/pkg/util/intstr"
-	kapi "k8s.io/kubernetes/pkg/apis/core"
-)
-
-type ValidateFunc func(string) error
-
-// VerifyImage verifies if the latest image in given ImageStream is valid
-func VerifyImage(stream *imageapi.ImageStream, tag, ns string, validator ValidateFunc) error {
-	pod := CreatePodFromImage(stream, tag, ns)
-	if pod == nil {
-		return fmt.Errorf("Unable to create Pod for %+v", stream.Status.DockerImageRepository)
-	}
-	service := CreateServiceForPod(pod, ns)
-	if service == nil {
-		return fmt.Errorf("Unable to create Service for %+v", service)
-	}
-
-	defer CleanupServiceAndPod(pod, service, ns)
-
-	address, err := WaitForAddress(pod, service, ns)
-	if err != nil {
-		return fmt.Errorf("Failed to obtain address: %v", err)
-	}
-
-	return validator(address)
-}
-
-// WaitForAddress waits for the Pod to be running and then for the Service to
-// get the endpoint.
-func WaitForAddress(pod *kapi.Pod, service *kapi.Service, ns string) (string, error) {
-	client, err := GetClusterAdminKubeClient(KubeConfigPath())
-	if err != nil {
-		return "", err
-	}
-	watcher, err := client.Core().Endpoints(ns).Watch(metav1.ListOptions{})
-	if err != nil {
-		return "", fmt.Errorf("Unexpected error: %v", err)
-	}
-	defer watcher.Stop()
-	for event := range watcher.ResultChan() {
-		eventEndpoint, ok := event.Object.(*kapi.Endpoints)
-		if !ok {
-			return "", fmt.Errorf("Unable to convert object %+v to Endpoints", eventEndpoint)
-		}
-		if eventEndpoint.Name != service.Name {
-			continue
-		}
-		if len(eventEndpoint.Subsets) == 0 {
-			fmt.Printf("Waiting for %s address\n", eventEndpoint.Name)
-			continue
-		}
-		for _, s := range eventEndpoint.Subsets {
-			for _, p := range s.Ports {
-				for _, a := range s.Addresses {
-					addr := net.JoinHostPort(a.IP, strconv.Itoa(int(p.Port)))
-					fmt.Printf("Discovered new %s endpoint: %s\n", service.Name, addr)
-					return addr, nil
-				}
-			}
-		}
-	}
-	return "", fmt.Errorf("Service does not get any endpoints")
-}
-
-// CreatePodFromImage creates a Pod from the latest image available in the Image
-// Stream
-func CreatePodFromImage(stream *imageapi.ImageStream, tag, ns string) *kapi.Pod {
-	client, err := GetClusterAdminKubeClient(KubeConfigPath())
-	if err != nil {
-		return nil
-	}
-	imageName := stream.Status.DockerImageRepository
-	if len(tag) > 0 {
-		imageName += ":" + tag
-	}
-	pod := &kapi.Pod{
-		ObjectMeta: metav1.ObjectMeta{
-			Name:   ns,
-			Labels: map[string]string{"name": ns},
-		},
-		Spec: kapi.PodSpec{
-			Containers: []kapi.Container{
-				{
-					Name:  "sample",
-					Image: imageName,
-				},
-			},
-			RestartPolicy: kapi.RestartPolicyNever,
-		},
-	}
-	if pod, err := client.Core().Pods(ns).Create(pod); err != nil {
-		fmt.Printf("%v\n", err)
-		return nil
-	} else {
-		return pod
-	}
-}
-
-// CreateServiceForPod creates a service to serve the provided Pod
-func CreateServiceForPod(pod *kapi.Pod, ns string) *kapi.Service {
-	client, err := GetClusterAdminKubeClient(KubeConfigPath())
-	if err != nil {
-		return nil
-	}
-	service := &kapi.Service{
-		ObjectMeta: metav1.ObjectMeta{
-			Name: ns,
-		},
-		Spec: kapi.ServiceSpec{
-			Selector: map[string]string{"name": ns},
-			Ports: []kapi.ServicePort{{
-				Port:       8080,
-				TargetPort: intstr.IntOrString{Type: intstr.Int, IntVal: 8080},
-			}},
-		},
-	}
-	if service, err := client.Core().Services(ns).Create(service); err != nil {
-		fmt.Printf("%v\n", err)
-		return nil
-	} else {
-		return service
-	}
-}
-
-// CleanupServiceAndPod removes the Service and the Pod
-func CleanupServiceAndPod(pod *kapi.Pod, service *kapi.Service, ns string) {
-	client, err := GetClusterAdminKubeClient(KubeConfigPath())
-	if err != nil {
-		return
-	}
-	client.Core().Pods(ns).Delete(pod.Name, nil)
-	client.Core().Services(ns).Delete(service.Name, nil)
-}