Merge pull request #17698 from rook/mergify/bp/release-1.20/pr-17672
test: remove unused label verification helpers (backport #17672)
This commit is contained in:
1 file changed
-45
@@ -19,57 +19,12 @@ package test
|
||||
import (
|
||||
"fmt"
|
||||
"os"
|
||||
"strings"
|
||||
"testing"
|
||||
|
||||
e "github.com/pkg/errors"
|
||||
"github.com/rook/rook/pkg/operator/ceph/controller"
|
||||
optest "github.com/rook/rook/pkg/operator/test"
|
||||
"github.com/stretchr/testify/assert"
|
||||
)
|
||||
|
||||
func checkLabel(key, value string, labels map[string]string) error {
|
||||
v, ok := labels[key]
|
||||
if !ok {
|
||||
return e.Errorf("label not present: expected={%s: %s}", key, value)
|
||||
}
|
||||
if v != value {
|
||||
return e.Errorf("label mismatch: expected={%s: %s} present={%s: %s}", key, value, key, v)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func combineErrors(errors ...error) error {
|
||||
errText := ""
|
||||
failure := false
|
||||
for _, e := range errors {
|
||||
if e != nil {
|
||||
failure = true
|
||||
errText = fmt.Sprintf("%v: %s", e, errText) // Will result in string ending in ": "
|
||||
}
|
||||
}
|
||||
if failure {
|
||||
errText = strings.TrimRight(errText, ": ") // Remove ": " from end
|
||||
return e.Errorf("%s", errText)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
// VerifyAppLabels returns a descriptive error if app labels are not present or not as expected.
|
||||
func VerifyAppLabels(appName, namespace string, labels map[string]string) error {
|
||||
errA := checkLabel("app", appName, labels)
|
||||
errB := checkLabel("rook_cluster", namespace, labels)
|
||||
return combineErrors(errA, errB)
|
||||
}
|
||||
|
||||
// VerifyPodLabels returns a descriptive error if pod labels are not present or not as expected.
|
||||
func VerifyPodLabels(appName, namespace, daemonType, daemonID string, labels map[string]string) error {
|
||||
errA := VerifyAppLabels(appName, namespace, labels)
|
||||
errB := checkLabel(controller.DaemonIDLabel, daemonID, labels)
|
||||
errC := checkLabel(daemonType, daemonID, labels)
|
||||
return combineErrors(errA, errB, errC)
|
||||
}
|
||||
|
||||
// AssertLabelsContainCephRequirements asserts that the labels under test contain the labels
|
||||
// which all Ceph pods should have. This can be used with labels for Kubernetes Deployments,
|
||||
// DaemonSets, etc.
|
||||
|
||||
Reference in new issue
Block a user