From c3178989d3896ce1488646a33c71b870468059b2 Mon Sep 17 00:00:00 2001 From: "yongzhi.yang" Date: Fri, 10 May 2019 16:58:24 +0800 Subject: [PATCH] Make this project can be run correctly. --- Godeps/Godeps.json | 2 +- controller.go | 10 +- controller_test.go | 10 +- go.mod | 2 +- go.sum | 2 + hack/boilerplate.go.txt | 13 +- hack/codegen.sh | 6 +- hack/update-codegen.sh | 2 +- main.go | 6 +- pkg/apis/migrate/v1/zz_generated.deepcopy.go | 13 +- pkg/client/clientset/versioned/clientset.go | 98 ---------- pkg/client/clientset/versioned/doc.go | 20 -- .../versioned/fake/clientset_generated.go | 82 -------- pkg/client/clientset/versioned/fake/doc.go | 20 -- .../clientset/versioned/fake/register.go | 56 ------ pkg/client/clientset/versioned/scheme/doc.go | 20 -- .../clientset/versioned/scheme/register.go | 56 ------ .../versioned/typed/migrate/v1/doc.go | 20 -- .../versioned/typed/migrate/v1/fake/doc.go | 20 -- .../typed/migrate/v1/fake/fake_foo.go | 140 -------------- .../typed/migrate/v1/fake/fake_migrate.go | 140 -------------- .../migrate/v1/fake/fake_migrate_client.go | 44 ----- .../versioned/typed/migrate/v1/foo.go | 174 ----------------- .../typed/migrate/v1/generated_expansion.go | 23 --- .../versioned/typed/migrate/v1/migrate.go | 174 ----------------- .../typed/migrate/v1/migrate_client.go | 95 --------- .../informers/externalversions/factory.go | 180 ------------------ .../informers/externalversions/generic.go | 64 ------- .../internalinterfaces/factory_interfaces.go | 38 ---- .../externalversions/migrate/interface.go | 46 ----- .../externalversions/migrate/v1/foo.go | 89 --------- .../externalversions/migrate/v1/interface.go | 52 ----- .../externalversions/migrate/v1/migrate.go | 89 --------- .../listers/migrate/v1/expansion_generated.go | 35 ---- pkg/client/listers/migrate/v1/foo.go | 94 --------- pkg/client/listers/migrate/v1/migrate.go | 94 --------- 36 files changed, 23 insertions(+), 2006 deletions(-) mode change 100644 => 100755 hack/codegen.sh delete mode 100644 pkg/client/clientset/versioned/clientset.go delete mode 100644 pkg/client/clientset/versioned/doc.go delete mode 100644 pkg/client/clientset/versioned/fake/clientset_generated.go delete mode 100644 pkg/client/clientset/versioned/fake/doc.go delete mode 100644 pkg/client/clientset/versioned/fake/register.go delete mode 100644 pkg/client/clientset/versioned/scheme/doc.go delete mode 100644 pkg/client/clientset/versioned/scheme/register.go delete mode 100644 pkg/client/clientset/versioned/typed/migrate/v1/doc.go delete mode 100644 pkg/client/clientset/versioned/typed/migrate/v1/fake/doc.go delete mode 100644 pkg/client/clientset/versioned/typed/migrate/v1/fake/fake_foo.go delete mode 100644 pkg/client/clientset/versioned/typed/migrate/v1/fake/fake_migrate.go delete mode 100644 pkg/client/clientset/versioned/typed/migrate/v1/fake/fake_migrate_client.go delete mode 100644 pkg/client/clientset/versioned/typed/migrate/v1/foo.go delete mode 100644 pkg/client/clientset/versioned/typed/migrate/v1/generated_expansion.go delete mode 100644 pkg/client/clientset/versioned/typed/migrate/v1/migrate.go delete mode 100644 pkg/client/clientset/versioned/typed/migrate/v1/migrate_client.go delete mode 100644 pkg/client/informers/externalversions/factory.go delete mode 100644 pkg/client/informers/externalversions/generic.go delete mode 100644 pkg/client/informers/externalversions/internalinterfaces/factory_interfaces.go delete mode 100644 pkg/client/informers/externalversions/migrate/interface.go delete mode 100644 pkg/client/informers/externalversions/migrate/v1/foo.go delete mode 100644 pkg/client/informers/externalversions/migrate/v1/interface.go delete mode 100644 pkg/client/informers/externalversions/migrate/v1/migrate.go delete mode 100644 pkg/client/listers/migrate/v1/expansion_generated.go delete mode 100644 pkg/client/listers/migrate/v1/foo.go delete mode 100644 pkg/client/listers/migrate/v1/migrate.go diff --git a/Godeps/Godeps.json b/Godeps/Godeps.json index 39da461..51bf21c 100644 --- a/Godeps/Godeps.json +++ b/Godeps/Godeps.json @@ -1,5 +1,5 @@ { - "ImportPath": "k8s.io/sample-controller", + "ImportPath": "github.com/yangyongzhi/sym-operator", "GoVersion": "unknown", "GodepVersion": "gen-godeps", "Packages": [ diff --git a/controller.go b/controller.go index eb80a07..5b238f8 100644 --- a/controller.go +++ b/controller.go @@ -38,11 +38,11 @@ import ( "k8s.io/client-go/util/workqueue" "k8s.io/klog" - samplev1alpha1 "k8s.io/sample-controller/pkg/apis/migrate/v1" - clientset "k8s.io/sample-controller/pkg/client/clientset/versioned" - samplescheme "k8s.io/sample-controller/pkg/client/clientset/versioned/scheme" - informers "k8s.io/sample-controller/pkg/client/informers/externalversions/migrate/v1" - listers "k8s.io/sample-controller/pkg/client/listers/migrate/v1" + samplev1alpha1 "github.com/yangyongzhi/sym-operator/pkg/apis/migrate/v1" + clientset "github.com/yangyongzhi/sym-operator/pkg/client/clientset/versioned" + samplescheme "github.com/yangyongzhi/sym-operator/pkg/client/clientset/versioned/scheme" + informers "github.com/yangyongzhi/sym-operator/pkg/client/informers/externalversions/migrate/v1" + listers "github.com/yangyongzhi/sym-operator/pkg/client/listers/migrate/v1" ) const controllerAgentName = "sample-controller" diff --git a/controller_test.go b/controller_test.go index 42e5fa0..a5bfdda 100644 --- a/controller_test.go +++ b/controller_test.go @@ -33,9 +33,9 @@ import ( "k8s.io/client-go/tools/cache" "k8s.io/client-go/tools/record" - samplecontroller "k8s.io/sample-controller/pkg/apis/samplecontroller/v1alpha1" - "k8s.io/sample-controller/pkg/generated/clientset/versioned/fake" - informers "k8s.io/sample-controller/pkg/generated/informers/externalversions" + samplecontroller "github.com/yangyongzhi/sym-operator/pkg/apis/migrate/v1" + "github.com/yangyongzhi/sym-operator/pkg/client/clientset/versioned/fake" + informers "github.com/yangyongzhi/sym-operator/pkg/client/informers/externalversions" ) var ( @@ -89,14 +89,14 @@ func (f *fixture) newController() (*Controller, informers.SharedInformerFactory, k8sI := kubeinformers.NewSharedInformerFactory(f.kubeclient, noResyncPeriodFunc()) c := NewController(f.kubeclient, f.client, - k8sI.Apps().V1().Deployments(), i.Samplecontroller().V1alpha1().Foos()) + k8sI.Apps().V1().Deployments(), i.Migrate().V1().Foos()) c.foosSynced = alwaysReady c.deploymentsSynced = alwaysReady c.recorder = &record.FakeRecorder{} for _, f := range f.fooLister { - i.Samplecontroller().V1alpha1().Foos().Informer().GetIndexer().Add(f) + i.Migrate().V1().Foos().Informer().GetIndexer().Add(f) } for _, d := range f.deploymentLister { diff --git a/go.mod b/go.mod index 5a5692c..9a2d9f2 100644 --- a/go.mod +++ b/go.mod @@ -1,6 +1,6 @@ // This is a generated file. Do not edit directly. -module k8s.io/sample-controller +module github.com/yangyongzhi/sym-operator go 1.12 diff --git a/go.sum b/go.sum index 167f24d..5b4fed1 100644 --- a/go.sum +++ b/go.sum @@ -106,6 +106,8 @@ k8s.io/klog v0.3.0 h1:0VPpR+sizsiivjIfIAQH/rl8tan6jvWkS7lU+0di3lE= k8s.io/klog v0.3.0/go.mod h1:Gq+BEi5rUBO/HRz0bTSXDUcqjScdoY3a9IHpCEIOOfk= k8s.io/kube-openapi v0.0.0-20190228160746-b3a7cee44a30 h1:TRb4wNWoBVrH9plmkp2q86FIDppkbrEXdXlxU3a3BMI= k8s.io/kube-openapi v0.0.0-20190228160746-b3a7cee44a30/go.mod h1:BXM9ceUBTj2QnfH2MK1odQs778ajze1RxcmP6S8RVVc= +github.com/YangYongZhi/sym-operator v0.0.0-20190425173525-f9c23632fb31 h1:FdGzSRXIeoPvlZjAkPE2jEcivZNLUbCJ3ncej+l5Rsc= +github.com/YangYongZhi/sym-operator v0.0.0-20190425173525-f9c23632fb31/go.mod h1:GHuOX/EqRZMKxNeVbZW7O0e9A6QsqDjruyOD0k49uVc= k8s.io/utils v0.0.0-20190221042446-c2654d5206da h1:ElyM7RPonbKnQqOcw7dG2IK5uvQQn3b/WPHqD5mBvP4= k8s.io/utils v0.0.0-20190221042446-c2654d5206da/go.mod h1:8k8uAuAQ0rXslZKaEWd0c3oVhZz7sSzSiPnVZayjIX0= modernc.org/cc v1.0.0/go.mod h1:1Sk4//wdnYJiUIxnW8ddKpaOJCF37yAdqYnkxUpaYxw= diff --git a/hack/boilerplate.go.txt b/hack/boilerplate.go.txt index b7c650d..b5de336 100644 --- a/hack/boilerplate.go.txt +++ b/hack/boilerplate.go.txt @@ -1,16 +1,5 @@ /* -Copyright The Kubernetes Authors. +Copyright The Symphony 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. */ diff --git a/hack/codegen.sh b/hack/codegen.sh old mode 100644 new mode 100755 index 0b543d8..e3087c7 --- a/hack/codegen.sh +++ b/hack/codegen.sh @@ -3,7 +3,7 @@ set -x GOPATH=$(go env GOPATH) -PACKAGE_NAME=k8s.io/sample-controller +PACKAGE_NAME=github.com/yangyongzhi/sym-operator REPO_ROOT="$GOPATH/src/$PACKAGE_NAME" DOCKER_REPO_ROOT="/go/src/$PACKAGE_NAME" DOCKER_CODEGEN_PKG="/go/src/k8s.io/code-generator" @@ -21,8 +21,8 @@ docker run --rm -ti -u $(id -u):$(id -g) \ -v "$REPO_ROOT":"$DOCKER_REPO_ROOT" \ -w "$DOCKER_REPO_ROOT" \ hub.tencentyun.com/xkcp0324/gengo:release-1.12 "$DOCKER_CODEGEN_PKG"/generate-groups.sh all \ - k8s.io/sample-controller/pkg/client \ - k8s.io/sample-controller/pkg/apis \ + $PACKAGE_NAME/pkg/client \ + $PACKAGE_NAME/pkg/apis \ "migrate:v1" \ --go-header-file "$DOCKER_REPO_ROOT/hack/boilerplate.go.txt" diff --git a/hack/update-codegen.sh b/hack/update-codegen.sh index 5562672..d2bd536 100644 --- a/hack/update-codegen.sh +++ b/hack/update-codegen.sh @@ -26,7 +26,7 @@ CODEGEN_PKG=${CODEGEN_PKG:-$(cd "${SCRIPT_ROOT}"; ls -d -1 ./vendor/k8s.io/code- # k8s.io/kubernetes. The output-base is needed for the generators to output into the vendor dir # instead of the $GOPATH directly. For normal projects this can be dropped. "${CODEGEN_PKG}"/generate-groups.sh "deepcopy,client,informer,lister" \ - k8s.io/sample-controller/pkg/generated k8s.io/sample-controller/pkg/apis \ + github.com/yangyongzhi/sym-operator/pkg/generated github.com/yangyongzhi/sym-operator/pkg/apis \ samplecontroller:v1alpha1 \ --output-base "$(dirname "${BASH_SOURCE[0]}")/../../.." \ --go-header-file "${SCRIPT_ROOT}"/hack/boilerplate.go.txt diff --git a/main.go b/main.go index c185803..7a1a986 100644 --- a/main.go +++ b/main.go @@ -27,9 +27,9 @@ import ( // Uncomment the following line to load the gcp plugin (only required to authenticate against GKE clusters). // _ "k8s.io/client-go/plugin/pkg/client/auth/gcp" - clientset "k8s.io/sample-controller/pkg/client/clientset/versioned" - informers "k8s.io/sample-controller/pkg/client/informers/externalversions" - "k8s.io/sample-controller/pkg/signals" + clientset "github.com/yangyongzhi/sym-operator/pkg/client/clientset/versioned" + informers "github.com/yangyongzhi/sym-operator/pkg/client/informers/externalversions" + "github.com/yangyongzhi/sym-operator/pkg/signals" ) var ( diff --git a/pkg/apis/migrate/v1/zz_generated.deepcopy.go b/pkg/apis/migrate/v1/zz_generated.deepcopy.go index 3a50687..c5ac972 100644 --- a/pkg/apis/migrate/v1/zz_generated.deepcopy.go +++ b/pkg/apis/migrate/v1/zz_generated.deepcopy.go @@ -1,19 +1,8 @@ // +build !ignore_autogenerated /* -Copyright The Kubernetes Authors. +Copyright The Symphony 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. */ // Code generated by deepcopy-gen. DO NOT EDIT. diff --git a/pkg/client/clientset/versioned/clientset.go b/pkg/client/clientset/versioned/clientset.go deleted file mode 100644 index 1c6fbfb..0000000 --- a/pkg/client/clientset/versioned/clientset.go +++ /dev/null @@ -1,98 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -package versioned - -import ( - discovery "k8s.io/client-go/discovery" - rest "k8s.io/client-go/rest" - flowcontrol "k8s.io/client-go/util/flowcontrol" - migratev1 "k8s.io/sample-controller/pkg/client/clientset/versioned/typed/migrate/v1" -) - -type Interface interface { - Discovery() discovery.DiscoveryInterface - MigrateV1() migratev1.MigrateV1Interface - // Deprecated: please explicitly pick a version if possible. - Migrate() migratev1.MigrateV1Interface -} - -// Clientset contains the clients for groups. Each group has exactly one -// version included in a Clientset. -type Clientset struct { - *discovery.DiscoveryClient - migrateV1 *migratev1.MigrateV1Client -} - -// MigrateV1 retrieves the MigrateV1Client -func (c *Clientset) MigrateV1() migratev1.MigrateV1Interface { - return c.migrateV1 -} - -// Deprecated: Migrate retrieves the default version of MigrateClient. -// Please explicitly pick a version. -func (c *Clientset) Migrate() migratev1.MigrateV1Interface { - return c.migrateV1 -} - -// Discovery retrieves the DiscoveryClient -func (c *Clientset) Discovery() discovery.DiscoveryInterface { - if c == nil { - return nil - } - return c.DiscoveryClient -} - -// NewForConfig creates a new Clientset for the given config. -func NewForConfig(c *rest.Config) (*Clientset, error) { - configShallowCopy := *c - if configShallowCopy.RateLimiter == nil && configShallowCopy.QPS > 0 { - configShallowCopy.RateLimiter = flowcontrol.NewTokenBucketRateLimiter(configShallowCopy.QPS, configShallowCopy.Burst) - } - var cs Clientset - var err error - cs.migrateV1, err = migratev1.NewForConfig(&configShallowCopy) - if err != nil { - return nil, err - } - - cs.DiscoveryClient, err = discovery.NewDiscoveryClientForConfig(&configShallowCopy) - if err != nil { - return nil, err - } - return &cs, nil -} - -// NewForConfigOrDie creates a new Clientset for the given config and -// panics if there is an error in the config. -func NewForConfigOrDie(c *rest.Config) *Clientset { - var cs Clientset - cs.migrateV1 = migratev1.NewForConfigOrDie(c) - - cs.DiscoveryClient = discovery.NewDiscoveryClientForConfigOrDie(c) - return &cs -} - -// New creates a new Clientset for the given RESTClient. -func New(c rest.Interface) *Clientset { - var cs Clientset - cs.migrateV1 = migratev1.New(c) - - cs.DiscoveryClient = discovery.NewDiscoveryClient(c) - return &cs -} diff --git a/pkg/client/clientset/versioned/doc.go b/pkg/client/clientset/versioned/doc.go deleted file mode 100644 index 41721ca..0000000 --- a/pkg/client/clientset/versioned/doc.go +++ /dev/null @@ -1,20 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -// This package has the automatically generated clientset. -package versioned diff --git a/pkg/client/clientset/versioned/fake/clientset_generated.go b/pkg/client/clientset/versioned/fake/clientset_generated.go deleted file mode 100644 index 6484f82..0000000 --- a/pkg/client/clientset/versioned/fake/clientset_generated.go +++ /dev/null @@ -1,82 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -package fake - -import ( - "k8s.io/apimachinery/pkg/runtime" - "k8s.io/apimachinery/pkg/watch" - "k8s.io/client-go/discovery" - fakediscovery "k8s.io/client-go/discovery/fake" - "k8s.io/client-go/testing" - clientset "k8s.io/sample-controller/pkg/client/clientset/versioned" - migratev1 "k8s.io/sample-controller/pkg/client/clientset/versioned/typed/migrate/v1" - fakemigratev1 "k8s.io/sample-controller/pkg/client/clientset/versioned/typed/migrate/v1/fake" -) - -// NewSimpleClientset returns a clientset that will respond with the provided objects. -// It's backed by a very simple object tracker that processes creates, updates and deletions as-is, -// without applying any validations and/or defaults. It shouldn't be considered a replacement -// for a real clientset and is mostly useful in simple unit tests. -func NewSimpleClientset(objects ...runtime.Object) *Clientset { - o := testing.NewObjectTracker(scheme, codecs.UniversalDecoder()) - for _, obj := range objects { - if err := o.Add(obj); err != nil { - panic(err) - } - } - - cs := &Clientset{} - cs.discovery = &fakediscovery.FakeDiscovery{Fake: &cs.Fake} - cs.AddReactor("*", "*", testing.ObjectReaction(o)) - cs.AddWatchReactor("*", func(action testing.Action) (handled bool, ret watch.Interface, err error) { - gvr := action.GetResource() - ns := action.GetNamespace() - watch, err := o.Watch(gvr, ns) - if err != nil { - return false, nil, err - } - return true, watch, nil - }) - - return cs -} - -// Clientset implements clientset.Interface. Meant to be embedded into a -// struct to get a default implementation. This makes faking out just the method -// you want to test easier. -type Clientset struct { - testing.Fake - discovery *fakediscovery.FakeDiscovery -} - -func (c *Clientset) Discovery() discovery.DiscoveryInterface { - return c.discovery -} - -var _ clientset.Interface = &Clientset{} - -// MigrateV1 retrieves the MigrateV1Client -func (c *Clientset) MigrateV1() migratev1.MigrateV1Interface { - return &fakemigratev1.FakeMigrateV1{Fake: &c.Fake} -} - -// Migrate retrieves the MigrateV1Client -func (c *Clientset) Migrate() migratev1.MigrateV1Interface { - return &fakemigratev1.FakeMigrateV1{Fake: &c.Fake} -} diff --git a/pkg/client/clientset/versioned/fake/doc.go b/pkg/client/clientset/versioned/fake/doc.go deleted file mode 100644 index 9b99e71..0000000 --- a/pkg/client/clientset/versioned/fake/doc.go +++ /dev/null @@ -1,20 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -// This package has the automatically generated fake clientset. -package fake diff --git a/pkg/client/clientset/versioned/fake/register.go b/pkg/client/clientset/versioned/fake/register.go deleted file mode 100644 index 9d01a91..0000000 --- a/pkg/client/clientset/versioned/fake/register.go +++ /dev/null @@ -1,56 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -package fake - -import ( - v1 "k8s.io/apimachinery/pkg/apis/meta/v1" - runtime "k8s.io/apimachinery/pkg/runtime" - schema "k8s.io/apimachinery/pkg/runtime/schema" - serializer "k8s.io/apimachinery/pkg/runtime/serializer" - utilruntime "k8s.io/apimachinery/pkg/util/runtime" - migratev1 "k8s.io/sample-controller/pkg/apis/migrate/v1" -) - -var scheme = runtime.NewScheme() -var codecs = serializer.NewCodecFactory(scheme) -var parameterCodec = runtime.NewParameterCodec(scheme) -var localSchemeBuilder = runtime.SchemeBuilder{ - migratev1.AddToScheme, -} - -// AddToScheme adds all types of this clientset into the given scheme. This allows composition -// of clientsets, like in: -// -// import ( -// "k8s.io/client-go/kubernetes" -// clientsetscheme "k8s.io/client-go/kubernetes/scheme" -// aggregatorclientsetscheme "k8s.io/kube-aggregator/pkg/client/clientset_generated/clientset/scheme" -// ) -// -// kclientset, _ := kubernetes.NewForConfig(c) -// _ = aggregatorclientsetscheme.AddToScheme(clientsetscheme.Scheme) -// -// After this, RawExtensions in Kubernetes types will serialize kube-aggregator types -// correctly. -var AddToScheme = localSchemeBuilder.AddToScheme - -func init() { - v1.AddToGroupVersion(scheme, schema.GroupVersion{Version: "v1"}) - utilruntime.Must(AddToScheme(scheme)) -} diff --git a/pkg/client/clientset/versioned/scheme/doc.go b/pkg/client/clientset/versioned/scheme/doc.go deleted file mode 100644 index 7dc3756..0000000 --- a/pkg/client/clientset/versioned/scheme/doc.go +++ /dev/null @@ -1,20 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -// This package contains the scheme of the automatically generated clientset. -package scheme diff --git a/pkg/client/clientset/versioned/scheme/register.go b/pkg/client/clientset/versioned/scheme/register.go deleted file mode 100644 index 1641b98..0000000 --- a/pkg/client/clientset/versioned/scheme/register.go +++ /dev/null @@ -1,56 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -package scheme - -import ( - v1 "k8s.io/apimachinery/pkg/apis/meta/v1" - runtime "k8s.io/apimachinery/pkg/runtime" - schema "k8s.io/apimachinery/pkg/runtime/schema" - serializer "k8s.io/apimachinery/pkg/runtime/serializer" - utilruntime "k8s.io/apimachinery/pkg/util/runtime" - migratev1 "k8s.io/sample-controller/pkg/apis/migrate/v1" -) - -var Scheme = runtime.NewScheme() -var Codecs = serializer.NewCodecFactory(Scheme) -var ParameterCodec = runtime.NewParameterCodec(Scheme) -var localSchemeBuilder = runtime.SchemeBuilder{ - migratev1.AddToScheme, -} - -// AddToScheme adds all types of this clientset into the given scheme. This allows composition -// of clientsets, like in: -// -// import ( -// "k8s.io/client-go/kubernetes" -// clientsetscheme "k8s.io/client-go/kubernetes/scheme" -// aggregatorclientsetscheme "k8s.io/kube-aggregator/pkg/client/clientset_generated/clientset/scheme" -// ) -// -// kclientset, _ := kubernetes.NewForConfig(c) -// _ = aggregatorclientsetscheme.AddToScheme(clientsetscheme.Scheme) -// -// After this, RawExtensions in Kubernetes types will serialize kube-aggregator types -// correctly. -var AddToScheme = localSchemeBuilder.AddToScheme - -func init() { - v1.AddToGroupVersion(Scheme, schema.GroupVersion{Version: "v1"}) - utilruntime.Must(AddToScheme(Scheme)) -} diff --git a/pkg/client/clientset/versioned/typed/migrate/v1/doc.go b/pkg/client/clientset/versioned/typed/migrate/v1/doc.go deleted file mode 100644 index 3af5d05..0000000 --- a/pkg/client/clientset/versioned/typed/migrate/v1/doc.go +++ /dev/null @@ -1,20 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -// This package has the automatically generated typed clients. -package v1 diff --git a/pkg/client/clientset/versioned/typed/migrate/v1/fake/doc.go b/pkg/client/clientset/versioned/typed/migrate/v1/fake/doc.go deleted file mode 100644 index 16f4439..0000000 --- a/pkg/client/clientset/versioned/typed/migrate/v1/fake/doc.go +++ /dev/null @@ -1,20 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -// Package fake has the automatically generated clients. -package fake diff --git a/pkg/client/clientset/versioned/typed/migrate/v1/fake/fake_foo.go b/pkg/client/clientset/versioned/typed/migrate/v1/fake/fake_foo.go deleted file mode 100644 index 557cd46..0000000 --- a/pkg/client/clientset/versioned/typed/migrate/v1/fake/fake_foo.go +++ /dev/null @@ -1,140 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -package fake - -import ( - v1 "k8s.io/apimachinery/pkg/apis/meta/v1" - labels "k8s.io/apimachinery/pkg/labels" - schema "k8s.io/apimachinery/pkg/runtime/schema" - types "k8s.io/apimachinery/pkg/types" - watch "k8s.io/apimachinery/pkg/watch" - testing "k8s.io/client-go/testing" - migratev1 "k8s.io/sample-controller/pkg/apis/migrate/v1" -) - -// FakeFoos implements FooInterface -type FakeFoos struct { - Fake *FakeMigrateV1 - ns string -} - -var foosResource = schema.GroupVersionResource{Group: "migrate.dmall.com", Version: "v1", Resource: "foos"} - -var foosKind = schema.GroupVersionKind{Group: "migrate.dmall.com", Version: "v1", Kind: "Foo"} - -// Get takes name of the foo, and returns the corresponding foo object, and an error if there is any. -func (c *FakeFoos) Get(name string, options v1.GetOptions) (result *migratev1.Foo, err error) { - obj, err := c.Fake. - Invokes(testing.NewGetAction(foosResource, c.ns, name), &migratev1.Foo{}) - - if obj == nil { - return nil, err - } - return obj.(*migratev1.Foo), err -} - -// List takes label and field selectors, and returns the list of Foos that match those selectors. -func (c *FakeFoos) List(opts v1.ListOptions) (result *migratev1.FooList, err error) { - obj, err := c.Fake. - Invokes(testing.NewListAction(foosResource, foosKind, c.ns, opts), &migratev1.FooList{}) - - if obj == nil { - return nil, err - } - - label, _, _ := testing.ExtractFromListOptions(opts) - if label == nil { - label = labels.Everything() - } - list := &migratev1.FooList{ListMeta: obj.(*migratev1.FooList).ListMeta} - for _, item := range obj.(*migratev1.FooList).Items { - if label.Matches(labels.Set(item.Labels)) { - list.Items = append(list.Items, item) - } - } - return list, err -} - -// Watch returns a watch.Interface that watches the requested foos. -func (c *FakeFoos) Watch(opts v1.ListOptions) (watch.Interface, error) { - return c.Fake. - InvokesWatch(testing.NewWatchAction(foosResource, c.ns, opts)) - -} - -// Create takes the representation of a foo and creates it. Returns the server's representation of the foo, and an error, if there is any. -func (c *FakeFoos) Create(foo *migratev1.Foo) (result *migratev1.Foo, err error) { - obj, err := c.Fake. - Invokes(testing.NewCreateAction(foosResource, c.ns, foo), &migratev1.Foo{}) - - if obj == nil { - return nil, err - } - return obj.(*migratev1.Foo), err -} - -// Update takes the representation of a foo and updates it. Returns the server's representation of the foo, and an error, if there is any. -func (c *FakeFoos) Update(foo *migratev1.Foo) (result *migratev1.Foo, err error) { - obj, err := c.Fake. - Invokes(testing.NewUpdateAction(foosResource, c.ns, foo), &migratev1.Foo{}) - - if obj == nil { - return nil, err - } - return obj.(*migratev1.Foo), err -} - -// UpdateStatus was generated because the type contains a Status member. -// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). -func (c *FakeFoos) UpdateStatus(foo *migratev1.Foo) (*migratev1.Foo, error) { - obj, err := c.Fake. - Invokes(testing.NewUpdateSubresourceAction(foosResource, "status", c.ns, foo), &migratev1.Foo{}) - - if obj == nil { - return nil, err - } - return obj.(*migratev1.Foo), err -} - -// Delete takes name of the foo and deletes it. Returns an error if one occurs. -func (c *FakeFoos) Delete(name string, options *v1.DeleteOptions) error { - _, err := c.Fake. - Invokes(testing.NewDeleteAction(foosResource, c.ns, name), &migratev1.Foo{}) - - return err -} - -// DeleteCollection deletes a collection of objects. -func (c *FakeFoos) DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error { - action := testing.NewDeleteCollectionAction(foosResource, c.ns, listOptions) - - _, err := c.Fake.Invokes(action, &migratev1.FooList{}) - return err -} - -// Patch applies the patch and returns the patched foo. -func (c *FakeFoos) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *migratev1.Foo, err error) { - obj, err := c.Fake. - Invokes(testing.NewPatchSubresourceAction(foosResource, c.ns, name, data, subresources...), &migratev1.Foo{}) - - if obj == nil { - return nil, err - } - return obj.(*migratev1.Foo), err -} diff --git a/pkg/client/clientset/versioned/typed/migrate/v1/fake/fake_migrate.go b/pkg/client/clientset/versioned/typed/migrate/v1/fake/fake_migrate.go deleted file mode 100644 index a91edd0..0000000 --- a/pkg/client/clientset/versioned/typed/migrate/v1/fake/fake_migrate.go +++ /dev/null @@ -1,140 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -package fake - -import ( - v1 "k8s.io/apimachinery/pkg/apis/meta/v1" - labels "k8s.io/apimachinery/pkg/labels" - schema "k8s.io/apimachinery/pkg/runtime/schema" - types "k8s.io/apimachinery/pkg/types" - watch "k8s.io/apimachinery/pkg/watch" - testing "k8s.io/client-go/testing" - migratev1 "k8s.io/sample-controller/pkg/apis/migrate/v1" -) - -// FakeMigrates implements MigrateInterface -type FakeMigrates struct { - Fake *FakeMigrateV1 - ns string -} - -var migratesResource = schema.GroupVersionResource{Group: "migrate.dmall.com", Version: "v1", Resource: "migrates"} - -var migratesKind = schema.GroupVersionKind{Group: "migrate.dmall.com", Version: "v1", Kind: "Migrate"} - -// Get takes name of the migrate, and returns the corresponding migrate object, and an error if there is any. -func (c *FakeMigrates) Get(name string, options v1.GetOptions) (result *migratev1.Migrate, err error) { - obj, err := c.Fake. - Invokes(testing.NewGetAction(migratesResource, c.ns, name), &migratev1.Migrate{}) - - if obj == nil { - return nil, err - } - return obj.(*migratev1.Migrate), err -} - -// List takes label and field selectors, and returns the list of Migrates that match those selectors. -func (c *FakeMigrates) List(opts v1.ListOptions) (result *migratev1.MigrateList, err error) { - obj, err := c.Fake. - Invokes(testing.NewListAction(migratesResource, migratesKind, c.ns, opts), &migratev1.MigrateList{}) - - if obj == nil { - return nil, err - } - - label, _, _ := testing.ExtractFromListOptions(opts) - if label == nil { - label = labels.Everything() - } - list := &migratev1.MigrateList{ListMeta: obj.(*migratev1.MigrateList).ListMeta} - for _, item := range obj.(*migratev1.MigrateList).Items { - if label.Matches(labels.Set(item.Labels)) { - list.Items = append(list.Items, item) - } - } - return list, err -} - -// Watch returns a watch.Interface that watches the requested migrates. -func (c *FakeMigrates) Watch(opts v1.ListOptions) (watch.Interface, error) { - return c.Fake. - InvokesWatch(testing.NewWatchAction(migratesResource, c.ns, opts)) - -} - -// Create takes the representation of a migrate and creates it. Returns the server's representation of the migrate, and an error, if there is any. -func (c *FakeMigrates) Create(migrate *migratev1.Migrate) (result *migratev1.Migrate, err error) { - obj, err := c.Fake. - Invokes(testing.NewCreateAction(migratesResource, c.ns, migrate), &migratev1.Migrate{}) - - if obj == nil { - return nil, err - } - return obj.(*migratev1.Migrate), err -} - -// Update takes the representation of a migrate and updates it. Returns the server's representation of the migrate, and an error, if there is any. -func (c *FakeMigrates) Update(migrate *migratev1.Migrate) (result *migratev1.Migrate, err error) { - obj, err := c.Fake. - Invokes(testing.NewUpdateAction(migratesResource, c.ns, migrate), &migratev1.Migrate{}) - - if obj == nil { - return nil, err - } - return obj.(*migratev1.Migrate), err -} - -// UpdateStatus was generated because the type contains a Status member. -// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). -func (c *FakeMigrates) UpdateStatus(migrate *migratev1.Migrate) (*migratev1.Migrate, error) { - obj, err := c.Fake. - Invokes(testing.NewUpdateSubresourceAction(migratesResource, "status", c.ns, migrate), &migratev1.Migrate{}) - - if obj == nil { - return nil, err - } - return obj.(*migratev1.Migrate), err -} - -// Delete takes name of the migrate and deletes it. Returns an error if one occurs. -func (c *FakeMigrates) Delete(name string, options *v1.DeleteOptions) error { - _, err := c.Fake. - Invokes(testing.NewDeleteAction(migratesResource, c.ns, name), &migratev1.Migrate{}) - - return err -} - -// DeleteCollection deletes a collection of objects. -func (c *FakeMigrates) DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error { - action := testing.NewDeleteCollectionAction(migratesResource, c.ns, listOptions) - - _, err := c.Fake.Invokes(action, &migratev1.MigrateList{}) - return err -} - -// Patch applies the patch and returns the patched migrate. -func (c *FakeMigrates) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *migratev1.Migrate, err error) { - obj, err := c.Fake. - Invokes(testing.NewPatchSubresourceAction(migratesResource, c.ns, name, data, subresources...), &migratev1.Migrate{}) - - if obj == nil { - return nil, err - } - return obj.(*migratev1.Migrate), err -} diff --git a/pkg/client/clientset/versioned/typed/migrate/v1/fake/fake_migrate_client.go b/pkg/client/clientset/versioned/typed/migrate/v1/fake/fake_migrate_client.go deleted file mode 100644 index 039f825..0000000 --- a/pkg/client/clientset/versioned/typed/migrate/v1/fake/fake_migrate_client.go +++ /dev/null @@ -1,44 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -package fake - -import ( - rest "k8s.io/client-go/rest" - testing "k8s.io/client-go/testing" - v1 "k8s.io/sample-controller/pkg/client/clientset/versioned/typed/migrate/v1" -) - -type FakeMigrateV1 struct { - *testing.Fake -} - -func (c *FakeMigrateV1) Foos(namespace string) v1.FooInterface { - return &FakeFoos{c, namespace} -} - -func (c *FakeMigrateV1) Migrates(namespace string) v1.MigrateInterface { - return &FakeMigrates{c, namespace} -} - -// RESTClient returns a RESTClient that is used to communicate -// with API server by this client implementation. -func (c *FakeMigrateV1) RESTClient() rest.Interface { - var ret *rest.RESTClient - return ret -} diff --git a/pkg/client/clientset/versioned/typed/migrate/v1/foo.go b/pkg/client/clientset/versioned/typed/migrate/v1/foo.go deleted file mode 100644 index c97ee1f..0000000 --- a/pkg/client/clientset/versioned/typed/migrate/v1/foo.go +++ /dev/null @@ -1,174 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -package v1 - -import ( - metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" - types "k8s.io/apimachinery/pkg/types" - watch "k8s.io/apimachinery/pkg/watch" - rest "k8s.io/client-go/rest" - v1 "k8s.io/sample-controller/pkg/apis/migrate/v1" - scheme "k8s.io/sample-controller/pkg/client/clientset/versioned/scheme" -) - -// FoosGetter has a method to return a FooInterface. -// A group's client should implement this interface. -type FoosGetter interface { - Foos(namespace string) FooInterface -} - -// FooInterface has methods to work with Foo resources. -type FooInterface interface { - Create(*v1.Foo) (*v1.Foo, error) - Update(*v1.Foo) (*v1.Foo, error) - UpdateStatus(*v1.Foo) (*v1.Foo, error) - Delete(name string, options *metav1.DeleteOptions) error - DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error - Get(name string, options metav1.GetOptions) (*v1.Foo, error) - List(opts metav1.ListOptions) (*v1.FooList, error) - Watch(opts metav1.ListOptions) (watch.Interface, error) - Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.Foo, err error) - FooExpansion -} - -// foos implements FooInterface -type foos struct { - client rest.Interface - ns string -} - -// newFoos returns a Foos -func newFoos(c *MigrateV1Client, namespace string) *foos { - return &foos{ - client: c.RESTClient(), - ns: namespace, - } -} - -// Get takes name of the foo, and returns the corresponding foo object, and an error if there is any. -func (c *foos) Get(name string, options metav1.GetOptions) (result *v1.Foo, err error) { - result = &v1.Foo{} - err = c.client.Get(). - Namespace(c.ns). - Resource("foos"). - Name(name). - VersionedParams(&options, scheme.ParameterCodec). - Do(). - Into(result) - return -} - -// List takes label and field selectors, and returns the list of Foos that match those selectors. -func (c *foos) List(opts metav1.ListOptions) (result *v1.FooList, err error) { - result = &v1.FooList{} - err = c.client.Get(). - Namespace(c.ns). - Resource("foos"). - VersionedParams(&opts, scheme.ParameterCodec). - Do(). - Into(result) - return -} - -// Watch returns a watch.Interface that watches the requested foos. -func (c *foos) Watch(opts metav1.ListOptions) (watch.Interface, error) { - opts.Watch = true - return c.client.Get(). - Namespace(c.ns). - Resource("foos"). - VersionedParams(&opts, scheme.ParameterCodec). - Watch() -} - -// Create takes the representation of a foo and creates it. Returns the server's representation of the foo, and an error, if there is any. -func (c *foos) Create(foo *v1.Foo) (result *v1.Foo, err error) { - result = &v1.Foo{} - err = c.client.Post(). - Namespace(c.ns). - Resource("foos"). - Body(foo). - Do(). - Into(result) - return -} - -// Update takes the representation of a foo and updates it. Returns the server's representation of the foo, and an error, if there is any. -func (c *foos) Update(foo *v1.Foo) (result *v1.Foo, err error) { - result = &v1.Foo{} - err = c.client.Put(). - Namespace(c.ns). - Resource("foos"). - Name(foo.Name). - Body(foo). - Do(). - Into(result) - return -} - -// UpdateStatus was generated because the type contains a Status member. -// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). - -func (c *foos) UpdateStatus(foo *v1.Foo) (result *v1.Foo, err error) { - result = &v1.Foo{} - err = c.client.Put(). - Namespace(c.ns). - Resource("foos"). - Name(foo.Name). - SubResource("status"). - Body(foo). - Do(). - Into(result) - return -} - -// Delete takes name of the foo and deletes it. Returns an error if one occurs. -func (c *foos) Delete(name string, options *metav1.DeleteOptions) error { - return c.client.Delete(). - Namespace(c.ns). - Resource("foos"). - Name(name). - Body(options). - Do(). - Error() -} - -// DeleteCollection deletes a collection of objects. -func (c *foos) DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error { - return c.client.Delete(). - Namespace(c.ns). - Resource("foos"). - VersionedParams(&listOptions, scheme.ParameterCodec). - Body(options). - Do(). - Error() -} - -// Patch applies the patch and returns the patched foo. -func (c *foos) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.Foo, err error) { - result = &v1.Foo{} - err = c.client.Patch(pt). - Namespace(c.ns). - Resource("foos"). - SubResource(subresources...). - Name(name). - Body(data). - Do(). - Into(result) - return -} diff --git a/pkg/client/clientset/versioned/typed/migrate/v1/generated_expansion.go b/pkg/client/clientset/versioned/typed/migrate/v1/generated_expansion.go deleted file mode 100644 index 40aa1ac..0000000 --- a/pkg/client/clientset/versioned/typed/migrate/v1/generated_expansion.go +++ /dev/null @@ -1,23 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -package v1 - -type FooExpansion interface{} - -type MigrateExpansion interface{} diff --git a/pkg/client/clientset/versioned/typed/migrate/v1/migrate.go b/pkg/client/clientset/versioned/typed/migrate/v1/migrate.go deleted file mode 100644 index 75d75dc..0000000 --- a/pkg/client/clientset/versioned/typed/migrate/v1/migrate.go +++ /dev/null @@ -1,174 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -package v1 - -import ( - metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" - types "k8s.io/apimachinery/pkg/types" - watch "k8s.io/apimachinery/pkg/watch" - rest "k8s.io/client-go/rest" - v1 "k8s.io/sample-controller/pkg/apis/migrate/v1" - scheme "k8s.io/sample-controller/pkg/client/clientset/versioned/scheme" -) - -// MigratesGetter has a method to return a MigrateInterface. -// A group's client should implement this interface. -type MigratesGetter interface { - Migrates(namespace string) MigrateInterface -} - -// MigrateInterface has methods to work with Migrate resources. -type MigrateInterface interface { - Create(*v1.Migrate) (*v1.Migrate, error) - Update(*v1.Migrate) (*v1.Migrate, error) - UpdateStatus(*v1.Migrate) (*v1.Migrate, error) - Delete(name string, options *metav1.DeleteOptions) error - DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error - Get(name string, options metav1.GetOptions) (*v1.Migrate, error) - List(opts metav1.ListOptions) (*v1.MigrateList, error) - Watch(opts metav1.ListOptions) (watch.Interface, error) - Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.Migrate, err error) - MigrateExpansion -} - -// migrates implements MigrateInterface -type migrates struct { - client rest.Interface - ns string -} - -// newMigrates returns a Migrates -func newMigrates(c *MigrateV1Client, namespace string) *migrates { - return &migrates{ - client: c.RESTClient(), - ns: namespace, - } -} - -// Get takes name of the migrate, and returns the corresponding migrate object, and an error if there is any. -func (c *migrates) Get(name string, options metav1.GetOptions) (result *v1.Migrate, err error) { - result = &v1.Migrate{} - err = c.client.Get(). - Namespace(c.ns). - Resource("migrates"). - Name(name). - VersionedParams(&options, scheme.ParameterCodec). - Do(). - Into(result) - return -} - -// List takes label and field selectors, and returns the list of Migrates that match those selectors. -func (c *migrates) List(opts metav1.ListOptions) (result *v1.MigrateList, err error) { - result = &v1.MigrateList{} - err = c.client.Get(). - Namespace(c.ns). - Resource("migrates"). - VersionedParams(&opts, scheme.ParameterCodec). - Do(). - Into(result) - return -} - -// Watch returns a watch.Interface that watches the requested migrates. -func (c *migrates) Watch(opts metav1.ListOptions) (watch.Interface, error) { - opts.Watch = true - return c.client.Get(). - Namespace(c.ns). - Resource("migrates"). - VersionedParams(&opts, scheme.ParameterCodec). - Watch() -} - -// Create takes the representation of a migrate and creates it. Returns the server's representation of the migrate, and an error, if there is any. -func (c *migrates) Create(migrate *v1.Migrate) (result *v1.Migrate, err error) { - result = &v1.Migrate{} - err = c.client.Post(). - Namespace(c.ns). - Resource("migrates"). - Body(migrate). - Do(). - Into(result) - return -} - -// Update takes the representation of a migrate and updates it. Returns the server's representation of the migrate, and an error, if there is any. -func (c *migrates) Update(migrate *v1.Migrate) (result *v1.Migrate, err error) { - result = &v1.Migrate{} - err = c.client.Put(). - Namespace(c.ns). - Resource("migrates"). - Name(migrate.Name). - Body(migrate). - Do(). - Into(result) - return -} - -// UpdateStatus was generated because the type contains a Status member. -// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). - -func (c *migrates) UpdateStatus(migrate *v1.Migrate) (result *v1.Migrate, err error) { - result = &v1.Migrate{} - err = c.client.Put(). - Namespace(c.ns). - Resource("migrates"). - Name(migrate.Name). - SubResource("status"). - Body(migrate). - Do(). - Into(result) - return -} - -// Delete takes name of the migrate and deletes it. Returns an error if one occurs. -func (c *migrates) Delete(name string, options *metav1.DeleteOptions) error { - return c.client.Delete(). - Namespace(c.ns). - Resource("migrates"). - Name(name). - Body(options). - Do(). - Error() -} - -// DeleteCollection deletes a collection of objects. -func (c *migrates) DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error { - return c.client.Delete(). - Namespace(c.ns). - Resource("migrates"). - VersionedParams(&listOptions, scheme.ParameterCodec). - Body(options). - Do(). - Error() -} - -// Patch applies the patch and returns the patched migrate. -func (c *migrates) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.Migrate, err error) { - result = &v1.Migrate{} - err = c.client.Patch(pt). - Namespace(c.ns). - Resource("migrates"). - SubResource(subresources...). - Name(name). - Body(data). - Do(). - Into(result) - return -} diff --git a/pkg/client/clientset/versioned/typed/migrate/v1/migrate_client.go b/pkg/client/clientset/versioned/typed/migrate/v1/migrate_client.go deleted file mode 100644 index c682ad9..0000000 --- a/pkg/client/clientset/versioned/typed/migrate/v1/migrate_client.go +++ /dev/null @@ -1,95 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -package v1 - -import ( - serializer "k8s.io/apimachinery/pkg/runtime/serializer" - rest "k8s.io/client-go/rest" - v1 "k8s.io/sample-controller/pkg/apis/migrate/v1" - "k8s.io/sample-controller/pkg/client/clientset/versioned/scheme" -) - -type MigrateV1Interface interface { - RESTClient() rest.Interface - FoosGetter - MigratesGetter -} - -// MigrateV1Client is used to interact with features provided by the migrate.dmall.com group. -type MigrateV1Client struct { - restClient rest.Interface -} - -func (c *MigrateV1Client) Foos(namespace string) FooInterface { - return newFoos(c, namespace) -} - -func (c *MigrateV1Client) Migrates(namespace string) MigrateInterface { - return newMigrates(c, namespace) -} - -// NewForConfig creates a new MigrateV1Client for the given config. -func NewForConfig(c *rest.Config) (*MigrateV1Client, error) { - config := *c - if err := setConfigDefaults(&config); err != nil { - return nil, err - } - client, err := rest.RESTClientFor(&config) - if err != nil { - return nil, err - } - return &MigrateV1Client{client}, nil -} - -// NewForConfigOrDie creates a new MigrateV1Client for the given config and -// panics if there is an error in the config. -func NewForConfigOrDie(c *rest.Config) *MigrateV1Client { - client, err := NewForConfig(c) - if err != nil { - panic(err) - } - return client -} - -// New creates a new MigrateV1Client for the given RESTClient. -func New(c rest.Interface) *MigrateV1Client { - return &MigrateV1Client{c} -} - -func setConfigDefaults(config *rest.Config) error { - gv := v1.SchemeGroupVersion - config.GroupVersion = &gv - config.APIPath = "/apis" - config.NegotiatedSerializer = serializer.DirectCodecFactory{CodecFactory: scheme.Codecs} - - if config.UserAgent == "" { - config.UserAgent = rest.DefaultKubernetesUserAgent() - } - - return nil -} - -// RESTClient returns a RESTClient that is used to communicate -// with API server by this client implementation. -func (c *MigrateV1Client) RESTClient() rest.Interface { - if c == nil { - return nil - } - return c.restClient -} diff --git a/pkg/client/informers/externalversions/factory.go b/pkg/client/informers/externalversions/factory.go deleted file mode 100644 index 9ff1ceb..0000000 --- a/pkg/client/informers/externalversions/factory.go +++ /dev/null @@ -1,180 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by informer-gen. DO NOT EDIT. - -package externalversions - -import ( - reflect "reflect" - sync "sync" - time "time" - - v1 "k8s.io/apimachinery/pkg/apis/meta/v1" - runtime "k8s.io/apimachinery/pkg/runtime" - schema "k8s.io/apimachinery/pkg/runtime/schema" - cache "k8s.io/client-go/tools/cache" - versioned "k8s.io/sample-controller/pkg/client/clientset/versioned" - internalinterfaces "k8s.io/sample-controller/pkg/client/informers/externalversions/internalinterfaces" - migrate "k8s.io/sample-controller/pkg/client/informers/externalversions/migrate" -) - -// SharedInformerOption defines the functional option type for SharedInformerFactory. -type SharedInformerOption func(*sharedInformerFactory) *sharedInformerFactory - -type sharedInformerFactory struct { - client versioned.Interface - namespace string - tweakListOptions internalinterfaces.TweakListOptionsFunc - lock sync.Mutex - defaultResync time.Duration - customResync map[reflect.Type]time.Duration - - informers map[reflect.Type]cache.SharedIndexInformer - // startedInformers is used for tracking which informers have been started. - // This allows Start() to be called multiple times safely. - startedInformers map[reflect.Type]bool -} - -// WithCustomResyncConfig sets a custom resync period for the specified informer types. -func WithCustomResyncConfig(resyncConfig map[v1.Object]time.Duration) SharedInformerOption { - return func(factory *sharedInformerFactory) *sharedInformerFactory { - for k, v := range resyncConfig { - factory.customResync[reflect.TypeOf(k)] = v - } - return factory - } -} - -// WithTweakListOptions sets a custom filter on all listers of the configured SharedInformerFactory. -func WithTweakListOptions(tweakListOptions internalinterfaces.TweakListOptionsFunc) SharedInformerOption { - return func(factory *sharedInformerFactory) *sharedInformerFactory { - factory.tweakListOptions = tweakListOptions - return factory - } -} - -// WithNamespace limits the SharedInformerFactory to the specified namespace. -func WithNamespace(namespace string) SharedInformerOption { - return func(factory *sharedInformerFactory) *sharedInformerFactory { - factory.namespace = namespace - return factory - } -} - -// NewSharedInformerFactory constructs a new instance of sharedInformerFactory for all namespaces. -func NewSharedInformerFactory(client versioned.Interface, defaultResync time.Duration) SharedInformerFactory { - return NewSharedInformerFactoryWithOptions(client, defaultResync) -} - -// NewFilteredSharedInformerFactory constructs a new instance of sharedInformerFactory. -// Listers obtained via this SharedInformerFactory will be subject to the same filters -// as specified here. -// Deprecated: Please use NewSharedInformerFactoryWithOptions instead -func NewFilteredSharedInformerFactory(client versioned.Interface, defaultResync time.Duration, namespace string, tweakListOptions internalinterfaces.TweakListOptionsFunc) SharedInformerFactory { - return NewSharedInformerFactoryWithOptions(client, defaultResync, WithNamespace(namespace), WithTweakListOptions(tweakListOptions)) -} - -// NewSharedInformerFactoryWithOptions constructs a new instance of a SharedInformerFactory with additional options. -func NewSharedInformerFactoryWithOptions(client versioned.Interface, defaultResync time.Duration, options ...SharedInformerOption) SharedInformerFactory { - factory := &sharedInformerFactory{ - client: client, - namespace: v1.NamespaceAll, - defaultResync: defaultResync, - informers: make(map[reflect.Type]cache.SharedIndexInformer), - startedInformers: make(map[reflect.Type]bool), - customResync: make(map[reflect.Type]time.Duration), - } - - // Apply all options - for _, opt := range options { - factory = opt(factory) - } - - return factory -} - -// Start initializes all requested informers. -func (f *sharedInformerFactory) Start(stopCh <-chan struct{}) { - f.lock.Lock() - defer f.lock.Unlock() - - for informerType, informer := range f.informers { - if !f.startedInformers[informerType] { - go informer.Run(stopCh) - f.startedInformers[informerType] = true - } - } -} - -// WaitForCacheSync waits for all started informers' cache were synced. -func (f *sharedInformerFactory) WaitForCacheSync(stopCh <-chan struct{}) map[reflect.Type]bool { - informers := func() map[reflect.Type]cache.SharedIndexInformer { - f.lock.Lock() - defer f.lock.Unlock() - - informers := map[reflect.Type]cache.SharedIndexInformer{} - for informerType, informer := range f.informers { - if f.startedInformers[informerType] { - informers[informerType] = informer - } - } - return informers - }() - - res := map[reflect.Type]bool{} - for informType, informer := range informers { - res[informType] = cache.WaitForCacheSync(stopCh, informer.HasSynced) - } - return res -} - -// InternalInformerFor returns the SharedIndexInformer for obj using an internal -// client. -func (f *sharedInformerFactory) InformerFor(obj runtime.Object, newFunc internalinterfaces.NewInformerFunc) cache.SharedIndexInformer { - f.lock.Lock() - defer f.lock.Unlock() - - informerType := reflect.TypeOf(obj) - informer, exists := f.informers[informerType] - if exists { - return informer - } - - resyncPeriod, exists := f.customResync[informerType] - if !exists { - resyncPeriod = f.defaultResync - } - - informer = newFunc(f.client, resyncPeriod) - f.informers[informerType] = informer - - return informer -} - -// SharedInformerFactory provides shared informers for resources in all known -// API group versions. -type SharedInformerFactory interface { - internalinterfaces.SharedInformerFactory - ForResource(resource schema.GroupVersionResource) (GenericInformer, error) - WaitForCacheSync(stopCh <-chan struct{}) map[reflect.Type]bool - - Migrate() migrate.Interface -} - -func (f *sharedInformerFactory) Migrate() migrate.Interface { - return migrate.New(f, f.namespace, f.tweakListOptions) -} diff --git a/pkg/client/informers/externalversions/generic.go b/pkg/client/informers/externalversions/generic.go deleted file mode 100644 index ae14935..0000000 --- a/pkg/client/informers/externalversions/generic.go +++ /dev/null @@ -1,64 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by informer-gen. DO NOT EDIT. - -package externalversions - -import ( - "fmt" - - schema "k8s.io/apimachinery/pkg/runtime/schema" - cache "k8s.io/client-go/tools/cache" - v1 "k8s.io/sample-controller/pkg/apis/migrate/v1" -) - -// GenericInformer is type of SharedIndexInformer which will locate and delegate to other -// sharedInformers based on type -type GenericInformer interface { - Informer() cache.SharedIndexInformer - Lister() cache.GenericLister -} - -type genericInformer struct { - informer cache.SharedIndexInformer - resource schema.GroupResource -} - -// Informer returns the SharedIndexInformer. -func (f *genericInformer) Informer() cache.SharedIndexInformer { - return f.informer -} - -// Lister returns the GenericLister. -func (f *genericInformer) Lister() cache.GenericLister { - return cache.NewGenericLister(f.Informer().GetIndexer(), f.resource) -} - -// ForResource gives generic access to a shared informer of the matching type -// TODO extend this to unknown resources with a client pool -func (f *sharedInformerFactory) ForResource(resource schema.GroupVersionResource) (GenericInformer, error) { - switch resource { - // Group=migrate.dmall.com, Version=v1 - case v1.SchemeGroupVersion.WithResource("foos"): - return &genericInformer{resource: resource.GroupResource(), informer: f.Migrate().V1().Foos().Informer()}, nil - case v1.SchemeGroupVersion.WithResource("migrates"): - return &genericInformer{resource: resource.GroupResource(), informer: f.Migrate().V1().Migrates().Informer()}, nil - - } - - return nil, fmt.Errorf("no informer found for %v", resource) -} diff --git a/pkg/client/informers/externalversions/internalinterfaces/factory_interfaces.go b/pkg/client/informers/externalversions/internalinterfaces/factory_interfaces.go deleted file mode 100644 index 2bdd081..0000000 --- a/pkg/client/informers/externalversions/internalinterfaces/factory_interfaces.go +++ /dev/null @@ -1,38 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by informer-gen. DO NOT EDIT. - -package internalinterfaces - -import ( - time "time" - - v1 "k8s.io/apimachinery/pkg/apis/meta/v1" - runtime "k8s.io/apimachinery/pkg/runtime" - cache "k8s.io/client-go/tools/cache" - versioned "k8s.io/sample-controller/pkg/client/clientset/versioned" -) - -type NewInformerFunc func(versioned.Interface, time.Duration) cache.SharedIndexInformer - -// SharedInformerFactory a small interface to allow for adding an informer without an import cycle -type SharedInformerFactory interface { - Start(stopCh <-chan struct{}) - InformerFor(obj runtime.Object, newFunc NewInformerFunc) cache.SharedIndexInformer -} - -type TweakListOptionsFunc func(*v1.ListOptions) diff --git a/pkg/client/informers/externalversions/migrate/interface.go b/pkg/client/informers/externalversions/migrate/interface.go deleted file mode 100644 index 4eec885..0000000 --- a/pkg/client/informers/externalversions/migrate/interface.go +++ /dev/null @@ -1,46 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by informer-gen. DO NOT EDIT. - -package migrate - -import ( - internalinterfaces "k8s.io/sample-controller/pkg/client/informers/externalversions/internalinterfaces" - v1 "k8s.io/sample-controller/pkg/client/informers/externalversions/migrate/v1" -) - -// Interface provides access to each of this group's versions. -type Interface interface { - // V1 provides access to shared informers for resources in V1. - V1() v1.Interface -} - -type group struct { - factory internalinterfaces.SharedInformerFactory - namespace string - tweakListOptions internalinterfaces.TweakListOptionsFunc -} - -// New returns a new Interface. -func New(f internalinterfaces.SharedInformerFactory, namespace string, tweakListOptions internalinterfaces.TweakListOptionsFunc) Interface { - return &group{factory: f, namespace: namespace, tweakListOptions: tweakListOptions} -} - -// V1 returns a new v1.Interface. -func (g *group) V1() v1.Interface { - return v1.New(g.factory, g.namespace, g.tweakListOptions) -} diff --git a/pkg/client/informers/externalversions/migrate/v1/foo.go b/pkg/client/informers/externalversions/migrate/v1/foo.go deleted file mode 100644 index 97cd205..0000000 --- a/pkg/client/informers/externalversions/migrate/v1/foo.go +++ /dev/null @@ -1,89 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by informer-gen. DO NOT EDIT. - -package v1 - -import ( - time "time" - - metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" - runtime "k8s.io/apimachinery/pkg/runtime" - watch "k8s.io/apimachinery/pkg/watch" - cache "k8s.io/client-go/tools/cache" - migratev1 "k8s.io/sample-controller/pkg/apis/migrate/v1" - versioned "k8s.io/sample-controller/pkg/client/clientset/versioned" - internalinterfaces "k8s.io/sample-controller/pkg/client/informers/externalversions/internalinterfaces" - v1 "k8s.io/sample-controller/pkg/client/listers/migrate/v1" -) - -// FooInformer provides access to a shared informer and lister for -// Foos. -type FooInformer interface { - Informer() cache.SharedIndexInformer - Lister() v1.FooLister -} - -type fooInformer struct { - factory internalinterfaces.SharedInformerFactory - tweakListOptions internalinterfaces.TweakListOptionsFunc - namespace string -} - -// NewFooInformer constructs a new informer for Foo type. -// Always prefer using an informer factory to get a shared informer instead of getting an independent -// one. This reduces memory footprint and number of connections to the server. -func NewFooInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers) cache.SharedIndexInformer { - return NewFilteredFooInformer(client, namespace, resyncPeriod, indexers, nil) -} - -// NewFilteredFooInformer constructs a new informer for Foo type. -// Always prefer using an informer factory to get a shared informer instead of getting an independent -// one. This reduces memory footprint and number of connections to the server. -func NewFilteredFooInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { - return cache.NewSharedIndexInformer( - &cache.ListWatch{ - ListFunc: func(options metav1.ListOptions) (runtime.Object, error) { - if tweakListOptions != nil { - tweakListOptions(&options) - } - return client.MigrateV1().Foos(namespace).List(options) - }, - WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) { - if tweakListOptions != nil { - tweakListOptions(&options) - } - return client.MigrateV1().Foos(namespace).Watch(options) - }, - }, - &migratev1.Foo{}, - resyncPeriod, - indexers, - ) -} - -func (f *fooInformer) defaultInformer(client versioned.Interface, resyncPeriod time.Duration) cache.SharedIndexInformer { - return NewFilteredFooInformer(client, f.namespace, resyncPeriod, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}, f.tweakListOptions) -} - -func (f *fooInformer) Informer() cache.SharedIndexInformer { - return f.factory.InformerFor(&migratev1.Foo{}, f.defaultInformer) -} - -func (f *fooInformer) Lister() v1.FooLister { - return v1.NewFooLister(f.Informer().GetIndexer()) -} diff --git a/pkg/client/informers/externalversions/migrate/v1/interface.go b/pkg/client/informers/externalversions/migrate/v1/interface.go deleted file mode 100644 index 9b38bda..0000000 --- a/pkg/client/informers/externalversions/migrate/v1/interface.go +++ /dev/null @@ -1,52 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by informer-gen. DO NOT EDIT. - -package v1 - -import ( - internalinterfaces "k8s.io/sample-controller/pkg/client/informers/externalversions/internalinterfaces" -) - -// Interface provides access to all the informers in this group version. -type Interface interface { - // Foos returns a FooInformer. - Foos() FooInformer - // Migrates returns a MigrateInformer. - Migrates() MigrateInformer -} - -type version struct { - factory internalinterfaces.SharedInformerFactory - namespace string - tweakListOptions internalinterfaces.TweakListOptionsFunc -} - -// New returns a new Interface. -func New(f internalinterfaces.SharedInformerFactory, namespace string, tweakListOptions internalinterfaces.TweakListOptionsFunc) Interface { - return &version{factory: f, namespace: namespace, tweakListOptions: tweakListOptions} -} - -// Foos returns a FooInformer. -func (v *version) Foos() FooInformer { - return &fooInformer{factory: v.factory, namespace: v.namespace, tweakListOptions: v.tweakListOptions} -} - -// Migrates returns a MigrateInformer. -func (v *version) Migrates() MigrateInformer { - return &migrateInformer{factory: v.factory, namespace: v.namespace, tweakListOptions: v.tweakListOptions} -} diff --git a/pkg/client/informers/externalversions/migrate/v1/migrate.go b/pkg/client/informers/externalversions/migrate/v1/migrate.go deleted file mode 100644 index 5eb1d20..0000000 --- a/pkg/client/informers/externalversions/migrate/v1/migrate.go +++ /dev/null @@ -1,89 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by informer-gen. DO NOT EDIT. - -package v1 - -import ( - time "time" - - metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" - runtime "k8s.io/apimachinery/pkg/runtime" - watch "k8s.io/apimachinery/pkg/watch" - cache "k8s.io/client-go/tools/cache" - migratev1 "k8s.io/sample-controller/pkg/apis/migrate/v1" - versioned "k8s.io/sample-controller/pkg/client/clientset/versioned" - internalinterfaces "k8s.io/sample-controller/pkg/client/informers/externalversions/internalinterfaces" - v1 "k8s.io/sample-controller/pkg/client/listers/migrate/v1" -) - -// MigrateInformer provides access to a shared informer and lister for -// Migrates. -type MigrateInformer interface { - Informer() cache.SharedIndexInformer - Lister() v1.MigrateLister -} - -type migrateInformer struct { - factory internalinterfaces.SharedInformerFactory - tweakListOptions internalinterfaces.TweakListOptionsFunc - namespace string -} - -// NewMigrateInformer constructs a new informer for Migrate type. -// Always prefer using an informer factory to get a shared informer instead of getting an independent -// one. This reduces memory footprint and number of connections to the server. -func NewMigrateInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers) cache.SharedIndexInformer { - return NewFilteredMigrateInformer(client, namespace, resyncPeriod, indexers, nil) -} - -// NewFilteredMigrateInformer constructs a new informer for Migrate type. -// Always prefer using an informer factory to get a shared informer instead of getting an independent -// one. This reduces memory footprint and number of connections to the server. -func NewFilteredMigrateInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { - return cache.NewSharedIndexInformer( - &cache.ListWatch{ - ListFunc: func(options metav1.ListOptions) (runtime.Object, error) { - if tweakListOptions != nil { - tweakListOptions(&options) - } - return client.MigrateV1().Migrates(namespace).List(options) - }, - WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) { - if tweakListOptions != nil { - tweakListOptions(&options) - } - return client.MigrateV1().Migrates(namespace).Watch(options) - }, - }, - &migratev1.Migrate{}, - resyncPeriod, - indexers, - ) -} - -func (f *migrateInformer) defaultInformer(client versioned.Interface, resyncPeriod time.Duration) cache.SharedIndexInformer { - return NewFilteredMigrateInformer(client, f.namespace, resyncPeriod, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}, f.tweakListOptions) -} - -func (f *migrateInformer) Informer() cache.SharedIndexInformer { - return f.factory.InformerFor(&migratev1.Migrate{}, f.defaultInformer) -} - -func (f *migrateInformer) Lister() v1.MigrateLister { - return v1.NewMigrateLister(f.Informer().GetIndexer()) -} diff --git a/pkg/client/listers/migrate/v1/expansion_generated.go b/pkg/client/listers/migrate/v1/expansion_generated.go deleted file mode 100644 index 49e14f7..0000000 --- a/pkg/client/listers/migrate/v1/expansion_generated.go +++ /dev/null @@ -1,35 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by lister-gen. DO NOT EDIT. - -package v1 - -// FooListerExpansion allows custom methods to be added to -// FooLister. -type FooListerExpansion interface{} - -// FooNamespaceListerExpansion allows custom methods to be added to -// FooNamespaceLister. -type FooNamespaceListerExpansion interface{} - -// MigrateListerExpansion allows custom methods to be added to -// MigrateLister. -type MigrateListerExpansion interface{} - -// MigrateNamespaceListerExpansion allows custom methods to be added to -// MigrateNamespaceLister. -type MigrateNamespaceListerExpansion interface{} diff --git a/pkg/client/listers/migrate/v1/foo.go b/pkg/client/listers/migrate/v1/foo.go deleted file mode 100644 index 798909c..0000000 --- a/pkg/client/listers/migrate/v1/foo.go +++ /dev/null @@ -1,94 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by lister-gen. DO NOT EDIT. - -package v1 - -import ( - "k8s.io/apimachinery/pkg/api/errors" - "k8s.io/apimachinery/pkg/labels" - "k8s.io/client-go/tools/cache" - v1 "k8s.io/sample-controller/pkg/apis/migrate/v1" -) - -// FooLister helps list Foos. -type FooLister interface { - // List lists all Foos in the indexer. - List(selector labels.Selector) (ret []*v1.Foo, err error) - // Foos returns an object that can list and get Foos. - Foos(namespace string) FooNamespaceLister - FooListerExpansion -} - -// fooLister implements the FooLister interface. -type fooLister struct { - indexer cache.Indexer -} - -// NewFooLister returns a new FooLister. -func NewFooLister(indexer cache.Indexer) FooLister { - return &fooLister{indexer: indexer} -} - -// List lists all Foos in the indexer. -func (s *fooLister) List(selector labels.Selector) (ret []*v1.Foo, err error) { - err = cache.ListAll(s.indexer, selector, func(m interface{}) { - ret = append(ret, m.(*v1.Foo)) - }) - return ret, err -} - -// Foos returns an object that can list and get Foos. -func (s *fooLister) Foos(namespace string) FooNamespaceLister { - return fooNamespaceLister{indexer: s.indexer, namespace: namespace} -} - -// FooNamespaceLister helps list and get Foos. -type FooNamespaceLister interface { - // List lists all Foos in the indexer for a given namespace. - List(selector labels.Selector) (ret []*v1.Foo, err error) - // Get retrieves the Foo from the indexer for a given namespace and name. - Get(name string) (*v1.Foo, error) - FooNamespaceListerExpansion -} - -// fooNamespaceLister implements the FooNamespaceLister -// interface. -type fooNamespaceLister struct { - indexer cache.Indexer - namespace string -} - -// List lists all Foos in the indexer for a given namespace. -func (s fooNamespaceLister) List(selector labels.Selector) (ret []*v1.Foo, err error) { - err = cache.ListAllByNamespace(s.indexer, s.namespace, selector, func(m interface{}) { - ret = append(ret, m.(*v1.Foo)) - }) - return ret, err -} - -// Get retrieves the Foo from the indexer for a given namespace and name. -func (s fooNamespaceLister) Get(name string) (*v1.Foo, error) { - obj, exists, err := s.indexer.GetByKey(s.namespace + "/" + name) - if err != nil { - return nil, err - } - if !exists { - return nil, errors.NewNotFound(v1.Resource("foo"), name) - } - return obj.(*v1.Foo), nil -} diff --git a/pkg/client/listers/migrate/v1/migrate.go b/pkg/client/listers/migrate/v1/migrate.go deleted file mode 100644 index 6342f69..0000000 --- a/pkg/client/listers/migrate/v1/migrate.go +++ /dev/null @@ -1,94 +0,0 @@ -/* -Copyright 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. -*/ - -// Code generated by lister-gen. DO NOT EDIT. - -package v1 - -import ( - "k8s.io/apimachinery/pkg/api/errors" - "k8s.io/apimachinery/pkg/labels" - "k8s.io/client-go/tools/cache" - v1 "k8s.io/sample-controller/pkg/apis/migrate/v1" -) - -// MigrateLister helps list Migrates. -type MigrateLister interface { - // List lists all Migrates in the indexer. - List(selector labels.Selector) (ret []*v1.Migrate, err error) - // Migrates returns an object that can list and get Migrates. - Migrates(namespace string) MigrateNamespaceLister - MigrateListerExpansion -} - -// migrateLister implements the MigrateLister interface. -type migrateLister struct { - indexer cache.Indexer -} - -// NewMigrateLister returns a new MigrateLister. -func NewMigrateLister(indexer cache.Indexer) MigrateLister { - return &migrateLister{indexer: indexer} -} - -// List lists all Migrates in the indexer. -func (s *migrateLister) List(selector labels.Selector) (ret []*v1.Migrate, err error) { - err = cache.ListAll(s.indexer, selector, func(m interface{}) { - ret = append(ret, m.(*v1.Migrate)) - }) - return ret, err -} - -// Migrates returns an object that can list and get Migrates. -func (s *migrateLister) Migrates(namespace string) MigrateNamespaceLister { - return migrateNamespaceLister{indexer: s.indexer, namespace: namespace} -} - -// MigrateNamespaceLister helps list and get Migrates. -type MigrateNamespaceLister interface { - // List lists all Migrates in the indexer for a given namespace. - List(selector labels.Selector) (ret []*v1.Migrate, err error) - // Get retrieves the Migrate from the indexer for a given namespace and name. - Get(name string) (*v1.Migrate, error) - MigrateNamespaceListerExpansion -} - -// migrateNamespaceLister implements the MigrateNamespaceLister -// interface. -type migrateNamespaceLister struct { - indexer cache.Indexer - namespace string -} - -// List lists all Migrates in the indexer for a given namespace. -func (s migrateNamespaceLister) List(selector labels.Selector) (ret []*v1.Migrate, err error) { - err = cache.ListAllByNamespace(s.indexer, s.namespace, selector, func(m interface{}) { - ret = append(ret, m.(*v1.Migrate)) - }) - return ret, err -} - -// Get retrieves the Migrate from the indexer for a given namespace and name. -func (s migrateNamespaceLister) Get(name string) (*v1.Migrate, error) { - obj, exists, err := s.indexer.GetByKey(s.namespace + "/" + name) - if err != nil { - return nil, err - } - if !exists { - return nil, errors.NewNotFound(v1.Resource("migrate"), name) - } - return obj.(*v1.Migrate), nil -}