Skip to content

Commit b948af9

Browse files
committed
Fix deployment config UpdateScale
1 parent cc424f5 commit b948af9

File tree

7 files changed

+60
-29
lines changed

7 files changed

+60
-29
lines changed

pkg/apps/apis/apps/types.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -138,7 +138,6 @@ const (
138138
// +genclient:method=Instantiate,verb=create,subresource=instantiate,input=DeploymentRequest
139139
// +genclient:method=Rollback,verb=create,subresource=rollback,input=DeploymentConfigRollback
140140
// +genclient:method=GetScale,verb=get,subresource=scale,result=k8s.io/api/extensions/v1beta1.Scale
141-
// +genclient:method=UpdateScale,verb=update,subresource=scale,input=k8s.io/api/extensions/v1beta1.Scale,result=k8s.io/api/extensions/v1beta1.Scale
142141
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
143142

144143
// DeploymentConfig represents a configuration for a single deployment (represented as a
Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
package scheme
2+
3+
import (
4+
extensionsv1beta1 "k8s.io/kubernetes/pkg/apis/extensions/v1beta1"
5+
)
6+
7+
func init() {
8+
// Needed for GetScale/UpdateScale
9+
extensionsv1beta1.AddToScheme(Scheme)
10+
}

pkg/apps/generated/internalclientset/typed/apps/internalversion/deploymentconfig.go

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@ type DeploymentConfigInterface interface {
3030
Instantiate(deploymentConfigName string, deploymentRequest *apps.DeploymentRequest) (*apps.DeploymentConfig, error)
3131
Rollback(deploymentConfigName string, deploymentConfigRollback *apps.DeploymentConfigRollback) (*apps.DeploymentConfig, error)
3232
GetScale(deploymentConfigName string, options v1.GetOptions) (*v1beta1.Scale, error)
33-
UpdateScale(deploymentConfigName string, scale *v1beta1.Scale) (*v1beta1.Scale, error)
3433

3534
DeploymentConfigExpansion
3635
}
@@ -202,17 +201,3 @@ func (c *deploymentConfigs) GetScale(deploymentConfigName string, options v1.Get
202201
Into(result)
203202
return
204203
}
205-
206-
// UpdateScale takes the top resource name and the representation of a scale and updates it. Returns the server's representation of the scale, and an error, if there is any.
207-
func (c *deploymentConfigs) UpdateScale(deploymentConfigName string, scale *v1beta1.Scale) (result *v1beta1.Scale, err error) {
208-
result = &v1beta1.Scale{}
209-
err = c.client.Put().
210-
Namespace(c.ns).
211-
Resource("deploymentconfigs").
212-
Name(deploymentConfigName).
213-
SubResource("scale").
214-
Body(scale).
215-
Do().
216-
Into(result)
217-
return
218-
}
Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,33 @@
1+
package internalversion
2+
3+
import (
4+
v1beta1 "k8s.io/api/extensions/v1beta1"
5+
"k8s.io/apimachinery/pkg/runtime"
6+
kapi "k8s.io/kubernetes/pkg/api"
7+
)
8+
9+
type DeploymentConfigExpansion interface {
10+
UpdateScale(deploymentConfigName string, scale *v1beta1.Scale) (result *v1beta1.Scale, err error)
11+
}
12+
13+
var scaleCodec = kapi.Codecs.LegacyCodec(v1beta1.SchemeGroupVersion)
14+
15+
// UpdateScale takes the top resource name and the representation of a scale and updates it. Returns the server's representation of the scale, and an error, if there is any.
16+
func (c *deploymentConfigs) UpdateScale(deploymentConfigName string, scale *v1beta1.Scale) (result *v1beta1.Scale, err error) {
17+
// FIXME: make non-homogenous subresource GV client generation work
18+
data, err := runtime.Encode(scaleCodec, scale)
19+
if err != nil {
20+
return nil, err
21+
}
22+
23+
result = &v1beta1.Scale{}
24+
err = c.client.Put().
25+
Namespace(c.ns).
26+
Resource("deploymentconfigs").
27+
Name(deploymentConfigName).
28+
SubResource("scale").
29+
Body(data).
30+
Do().
31+
Into(result)
32+
return
33+
}

pkg/apps/generated/internalclientset/typed/apps/internalversion/fake/fake_deploymentconfig.go

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -154,14 +154,3 @@ func (c *FakeDeploymentConfigs) GetScale(deploymentConfigName string, options v1
154154
}
155155
return obj.(*v1beta1.Scale), err
156156
}
157-
158-
// UpdateScale takes the representation of a scale and updates it. Returns the server's representation of the scale, and an error, if there is any.
159-
func (c *FakeDeploymentConfigs) UpdateScale(deploymentConfigName string, scale *v1beta1.Scale) (result *v1beta1.Scale, err error) {
160-
obj, err := c.Fake.
161-
Invokes(testing.NewUpdateSubresourceAction(deploymentconfigsResource, "scale", c.ns, scale), &v1beta1.Scale{})
162-
163-
if obj == nil {
164-
return nil, err
165-
}
166-
return obj.(*v1beta1.Scale), err
167-
}
Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,17 @@
1+
package fake
2+
3+
import (
4+
v1beta1 "k8s.io/api/extensions/v1beta1"
5+
testing "k8s.io/client-go/testing"
6+
)
7+
8+
// UpdateScale takes the representation of a scale and updates it. Returns the server's representation of the scale, and an error, if t
9+
func (c *FakeDeploymentConfigs) UpdateScale(deploymentConfigName string, scale *v1beta1.Scale) (result *v1beta1.Scale, err error) {
10+
obj, err := c.Fake.
11+
Invokes(testing.NewUpdateSubresourceAction(deploymentconfigsResource, "scale", c.ns, scale), &v1beta1.Scale{})
12+
13+
if obj == nil {
14+
return nil, err
15+
}
16+
return obj.(*v1beta1.Scale), err
17+
}
Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1 @@
11
package internalversion
2-
3-
type DeploymentConfigExpansion interface{}

0 commit comments

Comments
 (0)