mirror of
https://github.com/kubernetes/client-go.git
synced 2025-07-01 17:32:20 +00:00
[client-go] Add fake scale client
This adds a new fake scale client (for use in testing) to match the new polymorphic scale client. Kubernetes-commit: f22bfcd65acafc75235665feac3b147f16e30998
This commit is contained in:
parent
bb89f2cbb8
commit
22e2e0ebf1
@ -65,6 +65,7 @@ filegroup(
|
|||||||
name = "all-srcs",
|
name = "all-srcs",
|
||||||
srcs = [
|
srcs = [
|
||||||
":package-srcs",
|
":package-srcs",
|
||||||
|
"//staging/src/k8s.io/client-go/scale/fake:all-srcs",
|
||||||
"//staging/src/k8s.io/client-go/scale/scheme:all-srcs",
|
"//staging/src/k8s.io/client-go/scale/scheme:all-srcs",
|
||||||
],
|
],
|
||||||
tags = ["automanaged"],
|
tags = ["automanaged"],
|
||||||
|
28
scale/fake/BUILD
Normal file
28
scale/fake/BUILD
Normal file
@ -0,0 +1,28 @@
|
|||||||
|
load("@io_bazel_rules_go//go:def.bzl", "go_library")
|
||||||
|
|
||||||
|
go_library(
|
||||||
|
name = "go_default_library",
|
||||||
|
srcs = ["client.go"],
|
||||||
|
importpath = "k8s.io/client-go/scale/fake",
|
||||||
|
visibility = ["//visibility:public"],
|
||||||
|
deps = [
|
||||||
|
"//vendor/k8s.io/api/autoscaling/v1:go_default_library",
|
||||||
|
"//vendor/k8s.io/apimachinery/pkg/runtime/schema:go_default_library",
|
||||||
|
"//vendor/k8s.io/client-go/scale:go_default_library",
|
||||||
|
"//vendor/k8s.io/client-go/testing:go_default_library",
|
||||||
|
],
|
||||||
|
)
|
||||||
|
|
||||||
|
filegroup(
|
||||||
|
name = "package-srcs",
|
||||||
|
srcs = glob(["**"]),
|
||||||
|
tags = ["automanaged"],
|
||||||
|
visibility = ["//visibility:private"],
|
||||||
|
)
|
||||||
|
|
||||||
|
filegroup(
|
||||||
|
name = "all-srcs",
|
||||||
|
srcs = [":package-srcs"],
|
||||||
|
tags = ["automanaged"],
|
||||||
|
visibility = ["//visibility:public"],
|
||||||
|
)
|
67
scale/fake/client.go
Normal file
67
scale/fake/client.go
Normal file
@ -0,0 +1,67 @@
|
|||||||
|
/*
|
||||||
|
Copyright 2017 The Kubernetes Authors.
|
||||||
|
|
||||||
|
Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
|
you may not use this file except in compliance with the License.
|
||||||
|
You may obtain a copy of the License at
|
||||||
|
|
||||||
|
http://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
|
||||||
|
Unless required by applicable law or agreed to in writing, software
|
||||||
|
distributed under the License is distributed on an "AS IS" BASIS,
|
||||||
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
|
See the License for the specific language governing permissions and
|
||||||
|
limitations under the License.
|
||||||
|
*/
|
||||||
|
|
||||||
|
// Package fake provides a fake client interface to arbitrary Kubernetes
|
||||||
|
// APIs that exposes common high level operations and exposes common
|
||||||
|
// metadata.
|
||||||
|
package fake
|
||||||
|
|
||||||
|
import (
|
||||||
|
autoscalingapi "k8s.io/api/autoscaling/v1"
|
||||||
|
"k8s.io/apimachinery/pkg/runtime/schema"
|
||||||
|
"k8s.io/client-go/scale"
|
||||||
|
"k8s.io/client-go/testing"
|
||||||
|
)
|
||||||
|
|
||||||
|
// FakeScaleClient provides a fake implementation of scale.ScalesGetter.
|
||||||
|
type FakeScaleClient struct {
|
||||||
|
testing.Fake
|
||||||
|
}
|
||||||
|
|
||||||
|
func (f *FakeScaleClient) Scales(namespace string) scale.ScaleInterface {
|
||||||
|
return &fakeNamespacedScaleClient{
|
||||||
|
namespace: namespace,
|
||||||
|
fake: &f.Fake,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
type fakeNamespacedScaleClient struct {
|
||||||
|
namespace string
|
||||||
|
fake *testing.Fake
|
||||||
|
}
|
||||||
|
|
||||||
|
func (f *fakeNamespacedScaleClient) Get(resource schema.GroupResource, name string) (*autoscalingapi.Scale, error) {
|
||||||
|
obj, err := f.fake.
|
||||||
|
Invokes(testing.NewGetSubresourceAction(resource.WithVersion(""), f.namespace, "scale", name), &autoscalingapi.Scale{})
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
return obj.(*autoscalingapi.Scale), err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (f *fakeNamespacedScaleClient) Update(resource schema.GroupResource, scale *autoscalingapi.Scale) (*autoscalingapi.Scale, error) {
|
||||||
|
obj, err := f.fake.
|
||||||
|
Invokes(testing.NewUpdateSubresourceAction(resource.WithVersion(""), f.namespace, "scale", scale), &autoscalingapi.Scale{})
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
return obj.(*autoscalingapi.Scale), err
|
||||||
|
|
||||||
|
}
|
Loading…
Reference in New Issue
Block a user