From b1ced1a05e5ead15c2963d1146b2f3a0240d08f8 Mon Sep 17 00:00:00 2001 From: danielqsj Date: Tue, 29 Oct 2019 18:01:09 +0800 Subject: [PATCH] remove unused func --- test/e2e/storage/testsuites/volumemode.go | 20 -------------------- 1 file changed, 20 deletions(-) diff --git a/test/e2e/storage/testsuites/volumemode.go b/test/e2e/storage/testsuites/volumemode.go index 3ccedf7a3ec..a270e5a1966 100644 --- a/test/e2e/storage/testsuites/volumemode.go +++ b/test/e2e/storage/testsuites/volumemode.go @@ -29,7 +29,6 @@ import ( metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/fields" "k8s.io/apimachinery/pkg/util/errors" - "k8s.io/apimachinery/pkg/util/wait" clientset "k8s.io/client-go/kubernetes" volevents "k8s.io/kubernetes/pkg/controller/volume/events" "k8s.io/kubernetes/pkg/kubelet/events" @@ -480,22 +479,3 @@ func listPodDirectory(h utils.HostExec, path string, node *v1.Node) ([]string, e } return strings.Split(out, "\n"), nil } - -// NOTE(avalluri): The below code is intentionally copied from e2e/common package. -// Testsuites depending on common package is not desirable as that pulls quite -// many tests which are not interested by storage suites. -func eventOccurred(c clientset.Interface, namespace, eventSelector, msg string) wait.ConditionFunc { - options := metav1.ListOptions{FieldSelector: eventSelector} - return func() (bool, error) { - events, err := c.CoreV1().Events(namespace).List(options) - if err != nil { - return false, fmt.Errorf("got error while getting events: %v", err) - } - for _, event := range events.Items { - if strings.Contains(event.Message, msg) { - return true, nil - } - } - return false, nil - } -}