Skip to content

Commit

Permalink
Fix create form (#5002)
Browse files Browse the repository at this point in the history
  • Loading branch information
Sebastian Florek authored Mar 12, 2020
1 parent fda7fcf commit c461975
Show file tree
Hide file tree
Showing 2 changed files with 20 additions and 9 deletions.
13 changes: 9 additions & 4 deletions src/app/backend/client/manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -264,10 +264,15 @@ func (self *clientManager) VerberClient(req *restful.Request, config *rest.Confi
return nil, err
}

return NewResourceVerber(k8sClient.CoreV1().RESTClient(),
k8sClient.ExtensionsV1beta1().RESTClient(), k8sClient.AppsV1().RESTClient(),
k8sClient.BatchV1().RESTClient(), k8sClient.BatchV1beta1().RESTClient(), k8sClient.AutoscalingV1().RESTClient(),
k8sClient.StorageV1().RESTClient(), k8sClient.RbacV1().RESTClient(),
return NewResourceVerber(
k8sClient.CoreV1().RESTClient(),
k8sClient.ExtensionsV1beta1().RESTClient(),
k8sClient.AppsV1().RESTClient(),
k8sClient.BatchV1().RESTClient(),
k8sClient.BatchV1beta1().RESTClient(),
k8sClient.AutoscalingV1().RESTClient(),
k8sClient.StorageV1().RESTClient(),
k8sClient.RbacV1().RESTClient(),
apiextensionsRestClient,
pluginsclient.DashboardV1alpha1().RESTClient(),
config), nil
Expand Down
16 changes: 11 additions & 5 deletions src/app/backend/resource/deployment/deploy.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,6 @@ import (
"log"
"strings"

"github.com/kubernetes/dashboard/src/app/backend/errors"
apps "k8s.io/api/apps/v1"
api "k8s.io/api/core/v1"
"k8s.io/apimachinery/pkg/api/resource"
Expand All @@ -34,6 +33,8 @@ import (
"k8s.io/client-go/dynamic"
client "k8s.io/client-go/kubernetes"
"k8s.io/client-go/rest"

"github.com/kubernetes/dashboard/src/app/backend/errors"
)

const (
Expand Down Expand Up @@ -304,8 +305,8 @@ func DeployAppFromFile(cfg *rest.Config, spec *AppDeploymentFromFileSpec) (bool,
log.Printf("Namespace for deploy from file: %s\n", spec.Namespace)
d := yaml.NewYAMLOrJSONDecoder(reader, 4096)
for {
data := unstructured.Unstructured{}
if err := d.Decode(&data); err != nil {
data := &unstructured.Unstructured{}
if err := d.Decode(data); err != nil {
if err == io.EOF {
return true, nil
}
Expand Down Expand Up @@ -347,11 +348,16 @@ func DeployAppFromFile(cfg *rest.Config, spec *AppDeploymentFromFileSpec) (bool,
}

groupVersionResource := schema.GroupVersionResource{Group: gv.Group, Version: gv.Version, Resource: resource.Name}
namespace := spec.Namespace

if strings.Compare(spec.Namespace, "_all") == 0 {
_, err = dynamicClient.Resource(groupVersionResource).Namespace(data.GetNamespace()).Create(&data, metaV1.CreateOptions{})
namespace = data.GetNamespace()
}

if resource.Namespaced {
_, err = dynamicClient.Resource(groupVersionResource).Namespace(namespace).Create(data, metaV1.CreateOptions{})
} else {
_, err = dynamicClient.Resource(groupVersionResource).Namespace(spec.Namespace).Create(&data, metaV1.CreateOptions{})
_, err = dynamicClient.Resource(groupVersionResource).Create(data, metaV1.CreateOptions{})
}

if err != nil {
Expand Down

0 comments on commit c461975

Please sign in to comment.