kubernetes
/
kops
mirror of https://github.com/kubernetes/kops.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2191 from zytek/fix-replace 

Make `kops replace -f` consistent with `create -f`
This commit is contained in:
Justin Santa Barbara 2017-03-28 00:33:32 -04:00 committed by GitHub
parent 5c262bd8a7 e7432f0757
commit 2b924bcd43
1 changed files with 37 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

69
cmd/kops/replace.go
View File

@ -25,6 +25,7 @@ import (
"k8s.io/kops/cmd/kops/util"
"k8s.io/kops/util/pkg/vfs"
"bytes"
kopsapi "k8s.io/kops/pkg/apis/kops"
cmdutil "k8s.io/kubernetes/pkg/kubectl/cmd/util"
"k8s.io/kubernetes/pkg/kubectl/resource"
@ -72,40 +73,44 @@ func RunReplace(f *util.Factory, cmd *cobra.Command, out io.Writer, c *ReplaceOp
if err != nil {
return fmt.Errorf("error reading file %q: %v", f, err)
}
sections := bytes.Split(contents, []byte("\n---\n"))
for _, section := range sections {
o, gvk, err := codec.Decode(section, nil, nil)
if err != nil {
return fmt.Errorf("error parsing file %q: %v", f, err)
}
switch v := o.(type) {
case *kopsapi.Federation:
_, err = clientset.Federations().Update(v)
if err != nil {
return fmt.Errorf("error replacing federation: %v", err)
}
case *kopsapi.Cluster:
_, err = clientset.Clusters().Update(v)
if err != nil {
return fmt.Errorf("error replacing cluster: %v", err)
}
case *kopsapi.InstanceGroup:
clusterName := v.ObjectMeta.Labels[kopsapi.LabelClusterName]
if clusterName == "" {
return fmt.Errorf("must specify %q label with cluster name to replace instanceGroup", kopsapi.LabelClusterName)
}
_, err = clientset.InstanceGroups(clusterName).Update(v)
if err != nil {
return fmt.Errorf("error replacing instanceGroup: %v", err)
}
default:
glog.V(2).Infof("Type of object was %T", v)
return fmt.Errorf("Unhandled kind %q in %q", gvk, f)
}
o, gvk, err := codec.Decode(contents, nil, nil)
if err != nil {
return fmt.Errorf("error parsing file %q: %v", f, err)
}
switch v := o.(type) {
case *kopsapi.Federation:
_, err = clientset.Federations().Update(v)
if err != nil {
return fmt.Errorf("error replacing federation: %v", err)
}
case *kopsapi.Cluster:
_, err = clientset.Clusters().Update(v)
if err != nil {
return fmt.Errorf("error replacing cluster: %v", err)
}
case *kopsapi.InstanceGroup:
clusterName := v.ObjectMeta.Labels[kopsapi.LabelClusterName]
if clusterName == "" {
return fmt.Errorf("must specify %q label with cluster name to replace instanceGroup", kopsapi.LabelClusterName)
}
_, err = clientset.InstanceGroups(clusterName).Update(v)
if err != nil {
return fmt.Errorf("error replacing instanceGroup: %v", err)
}
default:
glog.V(2).Infof("Type of object was %T", v)
return fmt.Errorf("Unhandled kind %q in %q", gvk, f)
}
}
return nil