forked from LaconicNetwork/kompose
28 lines
666 B
Go
28 lines
666 B
Go
package testutils
|
|
|
|
import (
|
|
"errors"
|
|
|
|
"k8s.io/kubernetes/pkg/api"
|
|
"k8s.io/kubernetes/pkg/runtime"
|
|
)
|
|
|
|
// CheckForHeadless is helper function for tests.
|
|
// It checks if all Services in objects are Headless Services and if there is at least one such Services.
|
|
func CheckForHeadless(objects []runtime.Object) error {
|
|
serviceCreated := false
|
|
for _, obj := range objects {
|
|
if svc, ok := obj.(*api.Service); ok {
|
|
serviceCreated = true
|
|
// Check if it is a headless services
|
|
if svc.Spec.ClusterIP != "None" {
|
|
return errors.New("this is not a Headless services")
|
|
}
|
|
}
|
|
}
|
|
if !serviceCreated {
|
|
return errors.New("no Service created")
|
|
}
|
|
return nil
|
|
}
|