commit
3542f39f5f
|
@ -57,8 +57,7 @@ func (a *serviceAction) Execute(obj runtime.Unstructured, restore *api.Restore)
|
||||||
delete(spec, "clusterIP")
|
delete(spec, "clusterIP")
|
||||||
}
|
}
|
||||||
|
|
||||||
err = deleteNodePorts(obj, &spec)
|
if err := deleteNodePorts(obj, &spec); err != nil {
|
||||||
if err != nil {
|
|
||||||
return nil, nil, err
|
return nil, nil, err
|
||||||
}
|
}
|
||||||
return obj, nil, nil
|
return obj, nil, nil
|
||||||
|
@ -85,14 +84,17 @@ func getPreservedPorts(obj runtime.Unstructured) (map[string]bool, error) {
|
||||||
}
|
}
|
||||||
|
|
||||||
func deleteNodePorts(obj runtime.Unstructured, spec *map[string]interface{}) error {
|
func deleteNodePorts(obj runtime.Unstructured, spec *map[string]interface{}) error {
|
||||||
|
if serviceType, _ := collections.GetString(*spec, "type"); serviceType == "ExternalName" {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
preservedPorts, err := getPreservedPorts(obj)
|
preservedPorts, err := getPreservedPorts(obj)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
ports, err := collections.GetSlice(obj.UnstructuredContent(), "spec.ports")
|
ports, err := collections.GetSlice(obj.UnstructuredContent(), "spec.ports")
|
||||||
serviceType, _ := collections.GetString(*spec, "type")
|
if err != nil {
|
||||||
if err != nil && serviceType != "ExternalName" {
|
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue