Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
K
k3s
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Registry
Registry
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
Jacklull
k3s
Commits
9aeb7b07
Unverified
Commit
9aeb7b07
authored
Dec 17, 2018
by
Kubernetes Prow Robot
Committed by
GitHub
Dec 17, 2018
Browse files
Options
Browse Files
Download
Plain Diff
Merge pull request #71795 from zjj2wry/version_priority
Switch sample apiserver internalversion informer to external
parents
b278f847
a9c35d3b
Hide whitespace changes
Inline
Side-by-side
Showing
47 changed files
with
34 additions
and
2287 deletions
+34
-2287
BUILD
staging/src/k8s.io/sample-apiserver/BUILD
+0
-3
update-codegen.sh
staging/src/k8s.io/sample-apiserver/hack/update-codegen.sh
+7
-1
BUILD
...io/sample-apiserver/pkg/admission/plugin/banflunder/BUILD
+5
-5
admission.go
...le-apiserver/pkg/admission/plugin/banflunder/admission.go
+5
-5
admission_test.go
...iserver/pkg/admission/plugin/banflunder/admission_test.go
+6
-6
BUILD
...io/sample-apiserver/pkg/admission/wardleinitializer/BUILD
+3
-3
interfaces.go
...e-apiserver/pkg/admission/wardleinitializer/interfaces.go
+1
-1
wardleinitializer.go
...rver/pkg/admission/wardleinitializer/wardleinitializer.go
+1
-1
wardleinitializer_test.go
...pkg/admission/wardleinitializer/wardleinitializer_test.go
+2
-2
BUILD
...mple-apiserver/pkg/client/clientset/internalversion/BUILD
+0
-37
clientset.go
...iserver/pkg/client/clientset/internalversion/clientset.go
+0
-90
doc.go
...ple-apiserver/pkg/client/clientset/internalversion/doc.go
+0
-20
BUILD
...apiserver/pkg/client/clientset/internalversion/fake/BUILD
+0
-42
clientset_generated.go
...ent/clientset/internalversion/fake/clientset_generated.go
+0
-77
doc.go
...piserver/pkg/client/clientset/internalversion/fake/doc.go
+0
-20
register.go
...ver/pkg/client/clientset/internalversion/fake/register.go
+0
-56
BUILD
...iserver/pkg/client/clientset/internalversion/scheme/BUILD
+0
-33
doc.go
...server/pkg/client/clientset/internalversion/scheme/doc.go
+0
-20
register.go
...r/pkg/client/clientset/internalversion/scheme/register.go
+0
-41
BUILD
...entset/internalversion/typed/wardle/internalversion/BUILD
+0
-40
doc.go
...ntset/internalversion/typed/wardle/internalversion/doc.go
+0
-20
BUILD
...t/internalversion/typed/wardle/internalversion/fake/BUILD
+0
-39
doc.go
.../internalversion/typed/wardle/internalversion/fake/doc.go
+0
-20
fake_fischer.go
...version/typed/wardle/internalversion/fake/fake_fischer.go
+0
-120
fake_flunder.go
...version/typed/wardle/internalversion/fake/fake_flunder.go
+0
-140
fake_wardle_client.go
...n/typed/wardle/internalversion/fake/fake_wardle_client.go
+0
-44
fischer.go
...t/internalversion/typed/wardle/internalversion/fischer.go
+0
-164
flunder.go
...t/internalversion/typed/wardle/internalversion/flunder.go
+0
-191
generated_expansion.go
...rsion/typed/wardle/internalversion/generated_expansion.go
+0
-23
wardle_client.go
...rnalversion/typed/wardle/internalversion/wardle_client.go
+0
-101
BUILD
...mple-apiserver/pkg/client/informers/internalversion/BUILD
+0
-40
factory.go
...apiserver/pkg/client/informers/internalversion/factory.go
+0
-180
generic.go
...apiserver/pkg/client/informers/internalversion/generic.go
+0
-64
BUILD
...client/informers/internalversion/internalinterfaces/BUILD
+0
-29
factory_interfaces.go
.../internalversion/internalinterfaces/factory_interfaces.go
+0
-40
BUILD
...iserver/pkg/client/informers/internalversion/wardle/BUILD
+0
-30
interface.go
.../pkg/client/informers/internalversion/wardle/interface.go
+0
-46
BUILD
...nt/informers/internalversion/wardle/internalversion/BUILD
+0
-37
fischer.go
...formers/internalversion/wardle/internalversion/fischer.go
+0
-88
flunder.go
...formers/internalversion/wardle/internalversion/flunder.go
+0
-89
interface.go
...rmers/internalversion/wardle/internalversion/interface.go
+0
-52
BUILD
...apiserver/pkg/client/listers/wardle/internalversion/BUILD
+0
-33
expansion_generated.go
...ent/listers/wardle/internalversion/expansion_generated.go
+0
-31
fischer.go
...rver/pkg/client/listers/wardle/internalversion/fischer.go
+0
-65
flunder.go
...rver/pkg/client/listers/wardle/internalversion/flunder.go
+0
-94
BUILD
staging/src/k8s.io/sample-apiserver/pkg/cmd/server/BUILD
+2
-2
start.go
staging/src/k8s.io/sample-apiserver/pkg/cmd/server/start.go
+2
-2
No files found.
staging/src/k8s.io/sample-apiserver/BUILD
View file @
9aeb7b07
...
@@ -39,11 +39,8 @@ filegroup(
...
@@ -39,11 +39,8 @@ filegroup(
"//staging/src/k8s.io/sample-apiserver/pkg/admission/wardleinitializer:all-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/admission/wardleinitializer:all-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/apis/wardle:all-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/apis/wardle:all-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/apiserver:all-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/apiserver:all-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion:all-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/versioned:all-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/versioned:all-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/client/informers/externalversions:all-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/client/informers/externalversions:all-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/client/informers/internalversion:all-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/client/listers/wardle/internalversion:all-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/client/listers/wardle/v1alpha1:all-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/client/listers/wardle/v1alpha1:all-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/client/listers/wardle/v1beta1:all-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/client/listers/wardle/v1beta1:all-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/cmd/server:all-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/cmd/server:all-srcs",
...
...
staging/src/k8s.io/sample-apiserver/hack/update-codegen.sh
View file @
9aeb7b07
...
@@ -25,7 +25,13 @@ CODEGEN_PKG=${CODEGEN_PKG:-$(cd ${SCRIPT_ROOT}; ls -d -1 ./vendor/k8s.io/code-ge
...
@@ -25,7 +25,13 @@ CODEGEN_PKG=${CODEGEN_PKG:-$(cd ${SCRIPT_ROOT}; ls -d -1 ./vendor/k8s.io/code-ge
# --output-base because this script should also be able to run inside the vendor dir of
# --output-base because this script should also be able to run inside the vendor dir of
# k8s.io/kubernetes. The output-base is needed for the generators to output into the vendor dir
# 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.
# instead of the $GOPATH directly. For normal projects this can be dropped.
${
CODEGEN_PKG
}
/generate-internal-groups.sh all
\
${
CODEGEN_PKG
}
/generate-groups.sh all
\
k8s.io/sample-apiserver/pkg/client k8s.io/sample-apiserver/pkg/apis
\
"wardle:v1alpha1,v1beta1"
\
--output-base
"
$(
dirname
${
BASH_SOURCE
})
/../../.."
\
--go-header-file
${
SCRIPT_ROOT
}
/hack/boilerplate.go.txt
${
CODEGEN_PKG
}
/generate-internal-groups.sh
"deepcopy,defaulter,conversion"
\
k8s.io/sample-apiserver/pkg/client k8s.io/sample-apiserver/pkg/apis k8s.io/sample-apiserver/pkg/apis
\
k8s.io/sample-apiserver/pkg/client k8s.io/sample-apiserver/pkg/apis k8s.io/sample-apiserver/pkg/apis
\
"wardle:v1alpha1,v1beta1"
\
"wardle:v1alpha1,v1beta1"
\
--output-base
"
$(
dirname
${
BASH_SOURCE
})
/../../.."
\
--output-base
"
$(
dirname
${
BASH_SOURCE
})
/../../.."
\
...
...
staging/src/k8s.io/sample-apiserver/pkg/admission/plugin/banflunder/BUILD
View file @
9aeb7b07
...
@@ -18,8 +18,8 @@ go_library(
...
@@ -18,8 +18,8 @@ go_library(
"//staging/src/k8s.io/apiserver/pkg/admission:go_default_library",
"//staging/src/k8s.io/apiserver/pkg/admission:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/admission/wardleinitializer:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/admission/wardleinitializer:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/apis/wardle:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/apis/wardle:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/informers/
internalversion
:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/informers/
externalversions
:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/listers/wardle/
internalversion
:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/listers/wardle/
v1alpha1
:go_default_library",
],
],
)
)
...
@@ -34,9 +34,9 @@ go_test(
...
@@ -34,9 +34,9 @@ go_test(
"//staging/src/k8s.io/apiserver/pkg/admission:go_default_library",
"//staging/src/k8s.io/apiserver/pkg/admission:go_default_library",
"//staging/src/k8s.io/client-go/testing:go_default_library",
"//staging/src/k8s.io/client-go/testing:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/admission/wardleinitializer:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/admission/wardleinitializer:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/apis/wardle:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/apis/wardle
/v1alpha1
:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/
internalversion
/fake:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/
versioned
/fake:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/informers/
internalversion
:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/informers/
externalversions
:go_default_library",
],
],
)
)
...
...
staging/src/k8s.io/sample-apiserver/pkg/admission/plugin/banflunder/admission.go
View file @
9aeb7b07
...
@@ -26,8 +26,8 @@ import (
...
@@ -26,8 +26,8 @@ import (
"k8s.io/apiserver/pkg/admission"
"k8s.io/apiserver/pkg/admission"
"k8s.io/sample-apiserver/pkg/admission/wardleinitializer"
"k8s.io/sample-apiserver/pkg/admission/wardleinitializer"
"k8s.io/sample-apiserver/pkg/apis/wardle"
"k8s.io/sample-apiserver/pkg/apis/wardle"
informers
"k8s.io/sample-apiserver/pkg/client/informers/
internalversion
"
informers
"k8s.io/sample-apiserver/pkg/client/informers/
externalversions
"
listers
"k8s.io/sample-apiserver/pkg/client/listers/wardle/
internalversion
"
listers
"k8s.io/sample-apiserver/pkg/client/listers/wardle/
v1alpha1
"
)
)
// Register registers a plugin
// Register registers a plugin
...
@@ -85,11 +85,11 @@ func (d *DisallowFlunder) Admit(a admission.Attributes) error {
...
@@ -85,11 +85,11 @@ func (d *DisallowFlunder) Admit(a admission.Attributes) error {
// SetInternalWardleInformerFactory gets Lister from SharedInformerFactory.
// SetInternalWardleInformerFactory gets Lister from SharedInformerFactory.
// The lister knows how to lists Fischers.
// The lister knows how to lists Fischers.
func
(
d
*
DisallowFlunder
)
SetInternalWardleInformerFactory
(
f
informers
.
SharedInformerFactory
)
{
func
(
d
*
DisallowFlunder
)
SetInternalWardleInformerFactory
(
f
informers
.
SharedInformerFactory
)
{
d
.
lister
=
f
.
Wardle
()
.
InternalVersion
()
.
Fischers
()
.
Lister
()
d
.
lister
=
f
.
Wardle
()
.
V1alpha1
()
.
Fischers
()
.
Lister
()
d
.
SetReadyFunc
(
f
.
Wardle
()
.
InternalVersion
()
.
Fischers
()
.
Informer
()
.
HasSynced
)
d
.
SetReadyFunc
(
f
.
Wardle
()
.
V1alpha1
()
.
Fischers
()
.
Informer
()
.
HasSynced
)
}
}
// Valida
ValidateInitializationte
checks whether the plugin was correctly initialized.
// Valida
teInitialization
checks whether the plugin was correctly initialized.
func
(
d
*
DisallowFlunder
)
ValidateInitialization
()
error
{
func
(
d
*
DisallowFlunder
)
ValidateInitialization
()
error
{
if
d
.
lister
==
nil
{
if
d
.
lister
==
nil
{
return
fmt
.
Errorf
(
"missing fischer lister"
)
return
fmt
.
Errorf
(
"missing fischer lister"
)
...
...
staging/src/k8s.io/sample-apiserver/pkg/admission/plugin/banflunder/admission_test.go
View file @
9aeb7b07
...
@@ -27,9 +27,9 @@ import (
...
@@ -27,9 +27,9 @@ import (
clienttesting
"k8s.io/client-go/testing"
clienttesting
"k8s.io/client-go/testing"
"k8s.io/sample-apiserver/pkg/admission/plugin/banflunder"
"k8s.io/sample-apiserver/pkg/admission/plugin/banflunder"
"k8s.io/sample-apiserver/pkg/admission/wardleinitializer"
"k8s.io/sample-apiserver/pkg/admission/wardleinitializer"
"k8s.io/sample-apiserver/pkg/apis/wardle
"
wardle
"k8s.io/sample-apiserver/pkg/apis/wardle/v1alpha1
"
"k8s.io/sample-apiserver/pkg/client/clientset/
internalversion
/fake"
"k8s.io/sample-apiserver/pkg/client/clientset/
versioned
/fake"
informers
"k8s.io/sample-apiserver/pkg/client/informers/
internalversion
"
informers
"k8s.io/sample-apiserver/pkg/client/informers/
externalversions
"
)
)
// TestBanfluderAdmissionPlugin tests various test cases against
// TestBanfluderAdmissionPlugin tests various test cases against
...
@@ -56,7 +56,7 @@ func TestBanflunderAdmissionPlugin(t *testing.T) {
...
@@ -56,7 +56,7 @@ func TestBanflunderAdmissionPlugin(t *testing.T) {
Namespace
:
""
,
Namespace
:
""
,
},
},
},
},
admissionInputKind
:
wardle
.
Kind
(
"Flunder"
)
.
WithVersion
(
"version"
),
admissionInputKind
:
wardle
.
SchemeGroupVersion
.
WithKind
(
"Flunder"
)
.
GroupKind
(
)
.
WithVersion
(
"version"
),
admissionInputResource
:
wardle
.
Resource
(
"flunders"
)
.
WithVersion
(
"version"
),
admissionInputResource
:
wardle
.
Resource
(
"flunders"
)
.
WithVersion
(
"version"
),
admissionMustFail
:
true
,
admissionMustFail
:
true
,
},
},
...
@@ -74,7 +74,7 @@ func TestBanflunderAdmissionPlugin(t *testing.T) {
...
@@ -74,7 +74,7 @@ func TestBanflunderAdmissionPlugin(t *testing.T) {
Namespace
:
""
,
Namespace
:
""
,
},
},
},
},
admissionInputKind
:
wardle
.
Kind
(
"Flunder"
)
.
WithVersion
(
"version"
),
admissionInputKind
:
wardle
.
SchemeGroupVersion
.
WithKind
(
"Flunder"
)
.
GroupKind
(
)
.
WithVersion
(
"version"
),
admissionInputResource
:
wardle
.
Resource
(
"flunders"
)
.
WithVersion
(
"version"
),
admissionInputResource
:
wardle
.
Resource
(
"flunders"
)
.
WithVersion
(
"version"
),
admissionMustFail
:
false
,
admissionMustFail
:
false
,
},
},
...
@@ -93,7 +93,7 @@ func TestBanflunderAdmissionPlugin(t *testing.T) {
...
@@ -93,7 +93,7 @@ func TestBanflunderAdmissionPlugin(t *testing.T) {
Namespace
:
""
,
Namespace
:
""
,
},
},
},
},
admissionInputKind
:
wardle
.
Kind
(
"NotFlunder"
)
.
WithVersion
(
"version"
),
admissionInputKind
:
wardle
.
SchemeGroupVersion
.
WithKind
(
"NotFlunder"
)
.
GroupKind
(
)
.
WithVersion
(
"version"
),
admissionInputResource
:
wardle
.
Resource
(
"notflunders"
)
.
WithVersion
(
"version"
),
admissionInputResource
:
wardle
.
Resource
(
"notflunders"
)
.
WithVersion
(
"version"
),
admissionMustFail
:
false
,
admissionMustFail
:
false
,
},
},
...
...
staging/src/k8s.io/sample-apiserver/pkg/admission/wardleinitializer/BUILD
View file @
9aeb7b07
...
@@ -16,7 +16,7 @@ go_library(
...
@@ -16,7 +16,7 @@ go_library(
importpath = "k8s.io/sample-apiserver/pkg/admission/wardleinitializer",
importpath = "k8s.io/sample-apiserver/pkg/admission/wardleinitializer",
deps = [
deps = [
"//staging/src/k8s.io/apiserver/pkg/admission:go_default_library",
"//staging/src/k8s.io/apiserver/pkg/admission:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/informers/
internalversion
:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/informers/
externalversions
:go_default_library",
],
],
)
)
...
@@ -26,8 +26,8 @@ go_test(
...
@@ -26,8 +26,8 @@ go_test(
embed = [":go_default_library"],
embed = [":go_default_library"],
deps = [
deps = [
"//staging/src/k8s.io/apiserver/pkg/admission:go_default_library",
"//staging/src/k8s.io/apiserver/pkg/admission:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/
internalversion
/fake:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/
versioned
/fake:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/informers/
internalversion
:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/informers/
externalversions
:go_default_library",
],
],
)
)
...
...
staging/src/k8s.io/sample-apiserver/pkg/admission/wardleinitializer/interfaces.go
View file @
9aeb7b07
...
@@ -18,7 +18,7 @@ package wardleinitializer
...
@@ -18,7 +18,7 @@ package wardleinitializer
import
(
import
(
"k8s.io/apiserver/pkg/admission"
"k8s.io/apiserver/pkg/admission"
informers
"k8s.io/sample-apiserver/pkg/client/informers/
internalversion
"
informers
"k8s.io/sample-apiserver/pkg/client/informers/
externalversions
"
)
)
// WantsInternalWardleInformerFactory defines a function which sets InformerFactory for admission plugins that need it
// WantsInternalWardleInformerFactory defines a function which sets InformerFactory for admission plugins that need it
...
...
staging/src/k8s.io/sample-apiserver/pkg/admission/wardleinitializer/wardleinitializer.go
View file @
9aeb7b07
...
@@ -18,7 +18,7 @@ package wardleinitializer
...
@@ -18,7 +18,7 @@ package wardleinitializer
import
(
import
(
"k8s.io/apiserver/pkg/admission"
"k8s.io/apiserver/pkg/admission"
informers
"k8s.io/sample-apiserver/pkg/client/informers/
internalversion
"
informers
"k8s.io/sample-apiserver/pkg/client/informers/
externalversions
"
)
)
type
pluginInitializer
struct
{
type
pluginInitializer
struct
{
...
...
staging/src/k8s.io/sample-apiserver/pkg/admission/wardleinitializer/wardleinitializer_test.go
View file @
9aeb7b07
...
@@ -22,8 +22,8 @@ import (
...
@@ -22,8 +22,8 @@ import (
"k8s.io/apiserver/pkg/admission"
"k8s.io/apiserver/pkg/admission"
"k8s.io/sample-apiserver/pkg/admission/wardleinitializer"
"k8s.io/sample-apiserver/pkg/admission/wardleinitializer"
"k8s.io/sample-apiserver/pkg/client/clientset/
internalversion
/fake"
"k8s.io/sample-apiserver/pkg/client/clientset/
versioned
/fake"
informers
"k8s.io/sample-apiserver/pkg/client/informers/
internalversion
"
informers
"k8s.io/sample-apiserver/pkg/client/informers/
externalversions
"
)
)
// TestWantsInternalWardleInformerFactory ensures that the informer factory is injected
// TestWantsInternalWardleInformerFactory ensures that the informer factory is injected
...
...
staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/BUILD
deleted
100644 → 0
View file @
b278f847
load("@io_bazel_rules_go//go:def.bzl", "go_library")
go_library(
name = "go_default_library",
srcs = [
"clientset.go",
"doc.go",
],
importmap = "k8s.io/kubernetes/vendor/k8s.io/sample-apiserver/pkg/client/clientset/internalversion",
importpath = "k8s.io/sample-apiserver/pkg/client/clientset/internalversion",
visibility = ["//visibility:public"],
deps = [
"//staging/src/k8s.io/client-go/discovery:go_default_library",
"//staging/src/k8s.io/client-go/rest:go_default_library",
"//staging/src/k8s.io/client-go/util/flowcontrol:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion:go_default_library",
],
)
filegroup(
name = "package-srcs",
srcs = glob(["**"]),
tags = ["automanaged"],
visibility = ["//visibility:private"],
)
filegroup(
name = "all-srcs",
srcs = [
":package-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/fake:all-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/scheme:all-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion:all-srcs",
],
tags = ["automanaged"],
visibility = ["//visibility:public"],
)
staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/clientset.go
deleted
100644 → 0
View file @
b278f847
/*
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
internalversion
import
(
discovery
"k8s.io/client-go/discovery"
rest
"k8s.io/client-go/rest"
flowcontrol
"k8s.io/client-go/util/flowcontrol"
wardleinternalversion
"k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion"
)
type
Interface
interface
{
Discovery
()
discovery
.
DiscoveryInterface
Wardle
()
wardleinternalversion
.
WardleInterface
}
// Clientset contains the clients for groups. Each group has exactly one
// version included in a Clientset.
type
Clientset
struct
{
*
discovery
.
DiscoveryClient
wardle
*
wardleinternalversion
.
WardleClient
}
// Wardle retrieves the WardleClient
func
(
c
*
Clientset
)
Wardle
()
wardleinternalversion
.
WardleInterface
{
return
c
.
wardle
}
// 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
.
wardle
,
err
=
wardleinternalversion
.
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
.
wardle
=
wardleinternalversion
.
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
.
wardle
=
wardleinternalversion
.
New
(
c
)
cs
.
DiscoveryClient
=
discovery
.
NewDiscoveryClient
(
c
)
return
&
cs
}
staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/doc.go
deleted
100644 → 0
View file @
b278f847
/*
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
internalversion
staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/fake/BUILD
deleted
100644 → 0
View file @
b278f847
load("@io_bazel_rules_go//go:def.bzl", "go_library")
go_library(
name = "go_default_library",
srcs = [
"clientset_generated.go",
"doc.go",
"register.go",
],
importmap = "k8s.io/kubernetes/vendor/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/fake",
importpath = "k8s.io/sample-apiserver/pkg/client/clientset/internalversion/fake",
visibility = ["//visibility:public"],
deps = [
"//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library",
"//staging/src/k8s.io/apimachinery/pkg/runtime:go_default_library",
"//staging/src/k8s.io/apimachinery/pkg/runtime/schema:go_default_library",
"//staging/src/k8s.io/apimachinery/pkg/runtime/serializer:go_default_library",
"//staging/src/k8s.io/apimachinery/pkg/util/runtime:go_default_library",
"//staging/src/k8s.io/apimachinery/pkg/watch:go_default_library",
"//staging/src/k8s.io/client-go/discovery:go_default_library",
"//staging/src/k8s.io/client-go/discovery/fake:go_default_library",
"//staging/src/k8s.io/client-go/testing:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/apis/wardle:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion/fake: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"],
)
staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/fake/clientset_generated.go
deleted
100644 → 0
View file @
b278f847
/*
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-apiserver/pkg/client/clientset/internalversion"
wardleinternalversion
"k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion"
fakewardleinternalversion
"k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion/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
{}
// Wardle retrieves the WardleClient
func
(
c
*
Clientset
)
Wardle
()
wardleinternalversion
.
WardleInterface
{
return
&
fakewardleinternalversion
.
FakeWardle
{
Fake
:
&
c
.
Fake
}
}
staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/fake/doc.go
deleted
100644 → 0
View file @
b278f847
/*
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
staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/fake/register.go
deleted
100644 → 0
View file @
b278f847
/*
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"
wardleinternalversion
"k8s.io/sample-apiserver/pkg/apis/wardle"
)
var
scheme
=
runtime
.
NewScheme
()
var
codecs
=
serializer
.
NewCodecFactory
(
scheme
)
var
parameterCodec
=
runtime
.
NewParameterCodec
(
scheme
)
var
localSchemeBuilder
=
runtime
.
SchemeBuilder
{
wardleinternalversion
.
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
))
}
staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/scheme/BUILD
deleted
100644 → 0
View file @
b278f847
load("@io_bazel_rules_go//go:def.bzl", "go_library")
go_library(
name = "go_default_library",
srcs = [
"doc.go",
"register.go",
],
importmap = "k8s.io/kubernetes/vendor/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/scheme",
importpath = "k8s.io/sample-apiserver/pkg/client/clientset/internalversion/scheme",
visibility = ["//visibility:public"],
deps = [
"//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library",
"//staging/src/k8s.io/apimachinery/pkg/runtime:go_default_library",
"//staging/src/k8s.io/apimachinery/pkg/runtime/schema:go_default_library",
"//staging/src/k8s.io/apimachinery/pkg/runtime/serializer:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/apis/wardle/install: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"],
)
staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/scheme/doc.go
deleted
100644 → 0
View file @
b278f847
/*
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
staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/scheme/register.go
deleted
100644 → 0
View file @
b278f847
/*
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"
wardle
"k8s.io/sample-apiserver/pkg/apis/wardle/install"
)
var
Scheme
=
runtime
.
NewScheme
()
var
Codecs
=
serializer
.
NewCodecFactory
(
Scheme
)
var
ParameterCodec
=
runtime
.
NewParameterCodec
(
Scheme
)
func
init
()
{
v1
.
AddToGroupVersion
(
Scheme
,
schema
.
GroupVersion
{
Version
:
"v1"
})
Install
(
Scheme
)
}
// Install registers the API group and adds types to a scheme
func
Install
(
scheme
*
runtime
.
Scheme
)
{
wardle
.
Install
(
scheme
)
}
staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion/BUILD
deleted
100644 → 0
View file @
b278f847
load("@io_bazel_rules_go//go:def.bzl", "go_library")
go_library(
name = "go_default_library",
srcs = [
"doc.go",
"fischer.go",
"flunder.go",
"generated_expansion.go",
"wardle_client.go",
],
importmap = "k8s.io/kubernetes/vendor/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion",
importpath = "k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion",
visibility = ["//visibility:public"],
deps = [
"//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library",
"//staging/src/k8s.io/apimachinery/pkg/types:go_default_library",
"//staging/src/k8s.io/apimachinery/pkg/watch:go_default_library",
"//staging/src/k8s.io/client-go/rest:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/apis/wardle:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/scheme:go_default_library",
],
)
filegroup(
name = "package-srcs",
srcs = glob(["**"]),
tags = ["automanaged"],
visibility = ["//visibility:private"],
)
filegroup(
name = "all-srcs",
srcs = [
":package-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion/fake:all-srcs",
],
tags = ["automanaged"],
visibility = ["//visibility:public"],
)
staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion/doc.go
deleted
100644 → 0
View file @
b278f847
/*
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
internalversion
staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion/fake/BUILD
deleted
100644 → 0
View file @
b278f847
load("@io_bazel_rules_go//go:def.bzl", "go_library")
go_library(
name = "go_default_library",
srcs = [
"doc.go",
"fake_fischer.go",
"fake_flunder.go",
"fake_wardle_client.go",
],
importmap = "k8s.io/kubernetes/vendor/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion/fake",
importpath = "k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion/fake",
visibility = ["//visibility:public"],
deps = [
"//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library",
"//staging/src/k8s.io/apimachinery/pkg/labels:go_default_library",
"//staging/src/k8s.io/apimachinery/pkg/runtime/schema:go_default_library",
"//staging/src/k8s.io/apimachinery/pkg/types:go_default_library",
"//staging/src/k8s.io/apimachinery/pkg/watch:go_default_library",
"//staging/src/k8s.io/client-go/rest:go_default_library",
"//staging/src/k8s.io/client-go/testing:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/apis/wardle:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion: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"],
)
staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion/fake/doc.go
deleted
100644 → 0
View file @
b278f847
/*
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
staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion/fake/fake_fischer.go
deleted
100644 → 0
View file @
b278f847
/*
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"
wardle
"k8s.io/sample-apiserver/pkg/apis/wardle"
)
// FakeFischers implements FischerInterface
type
FakeFischers
struct
{
Fake
*
FakeWardle
}
var
fischersResource
=
schema
.
GroupVersionResource
{
Group
:
"wardle.k8s.io"
,
Version
:
""
,
Resource
:
"fischers"
}
var
fischersKind
=
schema
.
GroupVersionKind
{
Group
:
"wardle.k8s.io"
,
Version
:
""
,
Kind
:
"Fischer"
}
// Get takes name of the fischer, and returns the corresponding fischer object, and an error if there is any.
func
(
c
*
FakeFischers
)
Get
(
name
string
,
options
v1
.
GetOptions
)
(
result
*
wardle
.
Fischer
,
err
error
)
{
obj
,
err
:=
c
.
Fake
.
Invokes
(
testing
.
NewRootGetAction
(
fischersResource
,
name
),
&
wardle
.
Fischer
{})
if
obj
==
nil
{
return
nil
,
err
}
return
obj
.
(
*
wardle
.
Fischer
),
err
}
// List takes label and field selectors, and returns the list of Fischers that match those selectors.
func
(
c
*
FakeFischers
)
List
(
opts
v1
.
ListOptions
)
(
result
*
wardle
.
FischerList
,
err
error
)
{
obj
,
err
:=
c
.
Fake
.
Invokes
(
testing
.
NewRootListAction
(
fischersResource
,
fischersKind
,
opts
),
&
wardle
.
FischerList
{})
if
obj
==
nil
{
return
nil
,
err
}
label
,
_
,
_
:=
testing
.
ExtractFromListOptions
(
opts
)
if
label
==
nil
{
label
=
labels
.
Everything
()
}
list
:=
&
wardle
.
FischerList
{
ListMeta
:
obj
.
(
*
wardle
.
FischerList
)
.
ListMeta
}
for
_
,
item
:=
range
obj
.
(
*
wardle
.
FischerList
)
.
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 fischers.
func
(
c
*
FakeFischers
)
Watch
(
opts
v1
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
Fake
.
InvokesWatch
(
testing
.
NewRootWatchAction
(
fischersResource
,
opts
))
}
// Create takes the representation of a fischer and creates it. Returns the server's representation of the fischer, and an error, if there is any.
func
(
c
*
FakeFischers
)
Create
(
fischer
*
wardle
.
Fischer
)
(
result
*
wardle
.
Fischer
,
err
error
)
{
obj
,
err
:=
c
.
Fake
.
Invokes
(
testing
.
NewRootCreateAction
(
fischersResource
,
fischer
),
&
wardle
.
Fischer
{})
if
obj
==
nil
{
return
nil
,
err
}
return
obj
.
(
*
wardle
.
Fischer
),
err
}
// Update takes the representation of a fischer and updates it. Returns the server's representation of the fischer, and an error, if there is any.
func
(
c
*
FakeFischers
)
Update
(
fischer
*
wardle
.
Fischer
)
(
result
*
wardle
.
Fischer
,
err
error
)
{
obj
,
err
:=
c
.
Fake
.
Invokes
(
testing
.
NewRootUpdateAction
(
fischersResource
,
fischer
),
&
wardle
.
Fischer
{})
if
obj
==
nil
{
return
nil
,
err
}
return
obj
.
(
*
wardle
.
Fischer
),
err
}
// Delete takes name of the fischer and deletes it. Returns an error if one occurs.
func
(
c
*
FakeFischers
)
Delete
(
name
string
,
options
*
v1
.
DeleteOptions
)
error
{
_
,
err
:=
c
.
Fake
.
Invokes
(
testing
.
NewRootDeleteAction
(
fischersResource
,
name
),
&
wardle
.
Fischer
{})
return
err
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
FakeFischers
)
DeleteCollection
(
options
*
v1
.
DeleteOptions
,
listOptions
v1
.
ListOptions
)
error
{
action
:=
testing
.
NewRootDeleteCollectionAction
(
fischersResource
,
listOptions
)
_
,
err
:=
c
.
Fake
.
Invokes
(
action
,
&
wardle
.
FischerList
{})
return
err
}
// Patch applies the patch and returns the patched fischer.
func
(
c
*
FakeFischers
)
Patch
(
name
string
,
pt
types
.
PatchType
,
data
[]
byte
,
subresources
...
string
)
(
result
*
wardle
.
Fischer
,
err
error
)
{
obj
,
err
:=
c
.
Fake
.
Invokes
(
testing
.
NewRootPatchSubresourceAction
(
fischersResource
,
name
,
pt
,
data
,
subresources
...
),
&
wardle
.
Fischer
{})
if
obj
==
nil
{
return
nil
,
err
}
return
obj
.
(
*
wardle
.
Fischer
),
err
}
staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion/fake/fake_flunder.go
deleted
100644 → 0
View file @
b278f847
/*
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"
wardle
"k8s.io/sample-apiserver/pkg/apis/wardle"
)
// FakeFlunders implements FlunderInterface
type
FakeFlunders
struct
{
Fake
*
FakeWardle
ns
string
}
var
flundersResource
=
schema
.
GroupVersionResource
{
Group
:
"wardle.k8s.io"
,
Version
:
""
,
Resource
:
"flunders"
}
var
flundersKind
=
schema
.
GroupVersionKind
{
Group
:
"wardle.k8s.io"
,
Version
:
""
,
Kind
:
"Flunder"
}
// Get takes name of the flunder, and returns the corresponding flunder object, and an error if there is any.
func
(
c
*
FakeFlunders
)
Get
(
name
string
,
options
v1
.
GetOptions
)
(
result
*
wardle
.
Flunder
,
err
error
)
{
obj
,
err
:=
c
.
Fake
.
Invokes
(
testing
.
NewGetAction
(
flundersResource
,
c
.
ns
,
name
),
&
wardle
.
Flunder
{})
if
obj
==
nil
{
return
nil
,
err
}
return
obj
.
(
*
wardle
.
Flunder
),
err
}
// List takes label and field selectors, and returns the list of Flunders that match those selectors.
func
(
c
*
FakeFlunders
)
List
(
opts
v1
.
ListOptions
)
(
result
*
wardle
.
FlunderList
,
err
error
)
{
obj
,
err
:=
c
.
Fake
.
Invokes
(
testing
.
NewListAction
(
flundersResource
,
flundersKind
,
c
.
ns
,
opts
),
&
wardle
.
FlunderList
{})
if
obj
==
nil
{
return
nil
,
err
}
label
,
_
,
_
:=
testing
.
ExtractFromListOptions
(
opts
)
if
label
==
nil
{
label
=
labels
.
Everything
()
}
list
:=
&
wardle
.
FlunderList
{
ListMeta
:
obj
.
(
*
wardle
.
FlunderList
)
.
ListMeta
}
for
_
,
item
:=
range
obj
.
(
*
wardle
.
FlunderList
)
.
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 flunders.
func
(
c
*
FakeFlunders
)
Watch
(
opts
v1
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
Fake
.
InvokesWatch
(
testing
.
NewWatchAction
(
flundersResource
,
c
.
ns
,
opts
))
}
// Create takes the representation of a flunder and creates it. Returns the server's representation of the flunder, and an error, if there is any.
func
(
c
*
FakeFlunders
)
Create
(
flunder
*
wardle
.
Flunder
)
(
result
*
wardle
.
Flunder
,
err
error
)
{
obj
,
err
:=
c
.
Fake
.
Invokes
(
testing
.
NewCreateAction
(
flundersResource
,
c
.
ns
,
flunder
),
&
wardle
.
Flunder
{})
if
obj
==
nil
{
return
nil
,
err
}
return
obj
.
(
*
wardle
.
Flunder
),
err
}
// Update takes the representation of a flunder and updates it. Returns the server's representation of the flunder, and an error, if there is any.
func
(
c
*
FakeFlunders
)
Update
(
flunder
*
wardle
.
Flunder
)
(
result
*
wardle
.
Flunder
,
err
error
)
{
obj
,
err
:=
c
.
Fake
.
Invokes
(
testing
.
NewUpdateAction
(
flundersResource
,
c
.
ns
,
flunder
),
&
wardle
.
Flunder
{})
if
obj
==
nil
{
return
nil
,
err
}
return
obj
.
(
*
wardle
.
Flunder
),
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
*
FakeFlunders
)
UpdateStatus
(
flunder
*
wardle
.
Flunder
)
(
*
wardle
.
Flunder
,
error
)
{
obj
,
err
:=
c
.
Fake
.
Invokes
(
testing
.
NewUpdateSubresourceAction
(
flundersResource
,
"status"
,
c
.
ns
,
flunder
),
&
wardle
.
Flunder
{})
if
obj
==
nil
{
return
nil
,
err
}
return
obj
.
(
*
wardle
.
Flunder
),
err
}
// Delete takes name of the flunder and deletes it. Returns an error if one occurs.
func
(
c
*
FakeFlunders
)
Delete
(
name
string
,
options
*
v1
.
DeleteOptions
)
error
{
_
,
err
:=
c
.
Fake
.
Invokes
(
testing
.
NewDeleteAction
(
flundersResource
,
c
.
ns
,
name
),
&
wardle
.
Flunder
{})
return
err
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
FakeFlunders
)
DeleteCollection
(
options
*
v1
.
DeleteOptions
,
listOptions
v1
.
ListOptions
)
error
{
action
:=
testing
.
NewDeleteCollectionAction
(
flundersResource
,
c
.
ns
,
listOptions
)
_
,
err
:=
c
.
Fake
.
Invokes
(
action
,
&
wardle
.
FlunderList
{})
return
err
}
// Patch applies the patch and returns the patched flunder.
func
(
c
*
FakeFlunders
)
Patch
(
name
string
,
pt
types
.
PatchType
,
data
[]
byte
,
subresources
...
string
)
(
result
*
wardle
.
Flunder
,
err
error
)
{
obj
,
err
:=
c
.
Fake
.
Invokes
(
testing
.
NewPatchSubresourceAction
(
flundersResource
,
c
.
ns
,
name
,
pt
,
data
,
subresources
...
),
&
wardle
.
Flunder
{})
if
obj
==
nil
{
return
nil
,
err
}
return
obj
.
(
*
wardle
.
Flunder
),
err
}
staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion/fake/fake_wardle_client.go
deleted
100644 → 0
View file @
b278f847
/*
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"
internalversion
"k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion"
)
type
FakeWardle
struct
{
*
testing
.
Fake
}
func
(
c
*
FakeWardle
)
Fischers
()
internalversion
.
FischerInterface
{
return
&
FakeFischers
{
c
}
}
func
(
c
*
FakeWardle
)
Flunders
(
namespace
string
)
internalversion
.
FlunderInterface
{
return
&
FakeFlunders
{
c
,
namespace
}
}
// RESTClient returns a RESTClient that is used to communicate
// with API server by this client implementation.
func
(
c
*
FakeWardle
)
RESTClient
()
rest
.
Interface
{
var
ret
*
rest
.
RESTClient
return
ret
}
staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion/fischer.go
deleted
100644 → 0
View file @
b278f847
/*
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
internalversion
import
(
"time"
v1
"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"
wardle
"k8s.io/sample-apiserver/pkg/apis/wardle"
scheme
"k8s.io/sample-apiserver/pkg/client/clientset/internalversion/scheme"
)
// FischersGetter has a method to return a FischerInterface.
// A group's client should implement this interface.
type
FischersGetter
interface
{
Fischers
()
FischerInterface
}
// FischerInterface has methods to work with Fischer resources.
type
FischerInterface
interface
{
Create
(
*
wardle
.
Fischer
)
(
*
wardle
.
Fischer
,
error
)
Update
(
*
wardle
.
Fischer
)
(
*
wardle
.
Fischer
,
error
)
Delete
(
name
string
,
options
*
v1
.
DeleteOptions
)
error
DeleteCollection
(
options
*
v1
.
DeleteOptions
,
listOptions
v1
.
ListOptions
)
error
Get
(
name
string
,
options
v1
.
GetOptions
)
(
*
wardle
.
Fischer
,
error
)
List
(
opts
v1
.
ListOptions
)
(
*
wardle
.
FischerList
,
error
)
Watch
(
opts
v1
.
ListOptions
)
(
watch
.
Interface
,
error
)
Patch
(
name
string
,
pt
types
.
PatchType
,
data
[]
byte
,
subresources
...
string
)
(
result
*
wardle
.
Fischer
,
err
error
)
FischerExpansion
}
// fischers implements FischerInterface
type
fischers
struct
{
client
rest
.
Interface
}
// newFischers returns a Fischers
func
newFischers
(
c
*
WardleClient
)
*
fischers
{
return
&
fischers
{
client
:
c
.
RESTClient
(),
}
}
// Get takes name of the fischer, and returns the corresponding fischer object, and an error if there is any.
func
(
c
*
fischers
)
Get
(
name
string
,
options
v1
.
GetOptions
)
(
result
*
wardle
.
Fischer
,
err
error
)
{
result
=
&
wardle
.
Fischer
{}
err
=
c
.
client
.
Get
()
.
Resource
(
"fischers"
)
.
Name
(
name
)
.
VersionedParams
(
&
options
,
scheme
.
ParameterCodec
)
.
Do
()
.
Into
(
result
)
return
}
// List takes label and field selectors, and returns the list of Fischers that match those selectors.
func
(
c
*
fischers
)
List
(
opts
v1
.
ListOptions
)
(
result
*
wardle
.
FischerList
,
err
error
)
{
var
timeout
time
.
Duration
if
opts
.
TimeoutSeconds
!=
nil
{
timeout
=
time
.
Duration
(
*
opts
.
TimeoutSeconds
)
*
time
.
Second
}
result
=
&
wardle
.
FischerList
{}
err
=
c
.
client
.
Get
()
.
Resource
(
"fischers"
)
.
VersionedParams
(
&
opts
,
scheme
.
ParameterCodec
)
.
Timeout
(
timeout
)
.
Do
()
.
Into
(
result
)
return
}
// Watch returns a watch.Interface that watches the requested fischers.
func
(
c
*
fischers
)
Watch
(
opts
v1
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
var
timeout
time
.
Duration
if
opts
.
TimeoutSeconds
!=
nil
{
timeout
=
time
.
Duration
(
*
opts
.
TimeoutSeconds
)
*
time
.
Second
}
opts
.
Watch
=
true
return
c
.
client
.
Get
()
.
Resource
(
"fischers"
)
.
VersionedParams
(
&
opts
,
scheme
.
ParameterCodec
)
.
Timeout
(
timeout
)
.
Watch
()
}
// Create takes the representation of a fischer and creates it. Returns the server's representation of the fischer, and an error, if there is any.
func
(
c
*
fischers
)
Create
(
fischer
*
wardle
.
Fischer
)
(
result
*
wardle
.
Fischer
,
err
error
)
{
result
=
&
wardle
.
Fischer
{}
err
=
c
.
client
.
Post
()
.
Resource
(
"fischers"
)
.
Body
(
fischer
)
.
Do
()
.
Into
(
result
)
return
}
// Update takes the representation of a fischer and updates it. Returns the server's representation of the fischer, and an error, if there is any.
func
(
c
*
fischers
)
Update
(
fischer
*
wardle
.
Fischer
)
(
result
*
wardle
.
Fischer
,
err
error
)
{
result
=
&
wardle
.
Fischer
{}
err
=
c
.
client
.
Put
()
.
Resource
(
"fischers"
)
.
Name
(
fischer
.
Name
)
.
Body
(
fischer
)
.
Do
()
.
Into
(
result
)
return
}
// Delete takes name of the fischer and deletes it. Returns an error if one occurs.
func
(
c
*
fischers
)
Delete
(
name
string
,
options
*
v1
.
DeleteOptions
)
error
{
return
c
.
client
.
Delete
()
.
Resource
(
"fischers"
)
.
Name
(
name
)
.
Body
(
options
)
.
Do
()
.
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
fischers
)
DeleteCollection
(
options
*
v1
.
DeleteOptions
,
listOptions
v1
.
ListOptions
)
error
{
var
timeout
time
.
Duration
if
listOptions
.
TimeoutSeconds
!=
nil
{
timeout
=
time
.
Duration
(
*
listOptions
.
TimeoutSeconds
)
*
time
.
Second
}
return
c
.
client
.
Delete
()
.
Resource
(
"fischers"
)
.
VersionedParams
(
&
listOptions
,
scheme
.
ParameterCodec
)
.
Timeout
(
timeout
)
.
Body
(
options
)
.
Do
()
.
Error
()
}
// Patch applies the patch and returns the patched fischer.
func
(
c
*
fischers
)
Patch
(
name
string
,
pt
types
.
PatchType
,
data
[]
byte
,
subresources
...
string
)
(
result
*
wardle
.
Fischer
,
err
error
)
{
result
=
&
wardle
.
Fischer
{}
err
=
c
.
client
.
Patch
(
pt
)
.
Resource
(
"fischers"
)
.
SubResource
(
subresources
...
)
.
Name
(
name
)
.
Body
(
data
)
.
Do
()
.
Into
(
result
)
return
}
staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion/flunder.go
deleted
100644 → 0
View file @
b278f847
/*
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
internalversion
import
(
"time"
v1
"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"
wardle
"k8s.io/sample-apiserver/pkg/apis/wardle"
scheme
"k8s.io/sample-apiserver/pkg/client/clientset/internalversion/scheme"
)
// FlundersGetter has a method to return a FlunderInterface.
// A group's client should implement this interface.
type
FlundersGetter
interface
{
Flunders
(
namespace
string
)
FlunderInterface
}
// FlunderInterface has methods to work with Flunder resources.
type
FlunderInterface
interface
{
Create
(
*
wardle
.
Flunder
)
(
*
wardle
.
Flunder
,
error
)
Update
(
*
wardle
.
Flunder
)
(
*
wardle
.
Flunder
,
error
)
UpdateStatus
(
*
wardle
.
Flunder
)
(
*
wardle
.
Flunder
,
error
)
Delete
(
name
string
,
options
*
v1
.
DeleteOptions
)
error
DeleteCollection
(
options
*
v1
.
DeleteOptions
,
listOptions
v1
.
ListOptions
)
error
Get
(
name
string
,
options
v1
.
GetOptions
)
(
*
wardle
.
Flunder
,
error
)
List
(
opts
v1
.
ListOptions
)
(
*
wardle
.
FlunderList
,
error
)
Watch
(
opts
v1
.
ListOptions
)
(
watch
.
Interface
,
error
)
Patch
(
name
string
,
pt
types
.
PatchType
,
data
[]
byte
,
subresources
...
string
)
(
result
*
wardle
.
Flunder
,
err
error
)
FlunderExpansion
}
// flunders implements FlunderInterface
type
flunders
struct
{
client
rest
.
Interface
ns
string
}
// newFlunders returns a Flunders
func
newFlunders
(
c
*
WardleClient
,
namespace
string
)
*
flunders
{
return
&
flunders
{
client
:
c
.
RESTClient
(),
ns
:
namespace
,
}
}
// Get takes name of the flunder, and returns the corresponding flunder object, and an error if there is any.
func
(
c
*
flunders
)
Get
(
name
string
,
options
v1
.
GetOptions
)
(
result
*
wardle
.
Flunder
,
err
error
)
{
result
=
&
wardle
.
Flunder
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
Resource
(
"flunders"
)
.
Name
(
name
)
.
VersionedParams
(
&
options
,
scheme
.
ParameterCodec
)
.
Do
()
.
Into
(
result
)
return
}
// List takes label and field selectors, and returns the list of Flunders that match those selectors.
func
(
c
*
flunders
)
List
(
opts
v1
.
ListOptions
)
(
result
*
wardle
.
FlunderList
,
err
error
)
{
var
timeout
time
.
Duration
if
opts
.
TimeoutSeconds
!=
nil
{
timeout
=
time
.
Duration
(
*
opts
.
TimeoutSeconds
)
*
time
.
Second
}
result
=
&
wardle
.
FlunderList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
Resource
(
"flunders"
)
.
VersionedParams
(
&
opts
,
scheme
.
ParameterCodec
)
.
Timeout
(
timeout
)
.
Do
()
.
Into
(
result
)
return
}
// Watch returns a watch.Interface that watches the requested flunders.
func
(
c
*
flunders
)
Watch
(
opts
v1
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
var
timeout
time
.
Duration
if
opts
.
TimeoutSeconds
!=
nil
{
timeout
=
time
.
Duration
(
*
opts
.
TimeoutSeconds
)
*
time
.
Second
}
opts
.
Watch
=
true
return
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
Resource
(
"flunders"
)
.
VersionedParams
(
&
opts
,
scheme
.
ParameterCodec
)
.
Timeout
(
timeout
)
.
Watch
()
}
// Create takes the representation of a flunder and creates it. Returns the server's representation of the flunder, and an error, if there is any.
func
(
c
*
flunders
)
Create
(
flunder
*
wardle
.
Flunder
)
(
result
*
wardle
.
Flunder
,
err
error
)
{
result
=
&
wardle
.
Flunder
{}
err
=
c
.
client
.
Post
()
.
Namespace
(
c
.
ns
)
.
Resource
(
"flunders"
)
.
Body
(
flunder
)
.
Do
()
.
Into
(
result
)
return
}
// Update takes the representation of a flunder and updates it. Returns the server's representation of the flunder, and an error, if there is any.
func
(
c
*
flunders
)
Update
(
flunder
*
wardle
.
Flunder
)
(
result
*
wardle
.
Flunder
,
err
error
)
{
result
=
&
wardle
.
Flunder
{}
err
=
c
.
client
.
Put
()
.
Namespace
(
c
.
ns
)
.
Resource
(
"flunders"
)
.
Name
(
flunder
.
Name
)
.
Body
(
flunder
)
.
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
*
flunders
)
UpdateStatus
(
flunder
*
wardle
.
Flunder
)
(
result
*
wardle
.
Flunder
,
err
error
)
{
result
=
&
wardle
.
Flunder
{}
err
=
c
.
client
.
Put
()
.
Namespace
(
c
.
ns
)
.
Resource
(
"flunders"
)
.
Name
(
flunder
.
Name
)
.
SubResource
(
"status"
)
.
Body
(
flunder
)
.
Do
()
.
Into
(
result
)
return
}
// Delete takes name of the flunder and deletes it. Returns an error if one occurs.
func
(
c
*
flunders
)
Delete
(
name
string
,
options
*
v1
.
DeleteOptions
)
error
{
return
c
.
client
.
Delete
()
.
Namespace
(
c
.
ns
)
.
Resource
(
"flunders"
)
.
Name
(
name
)
.
Body
(
options
)
.
Do
()
.
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
flunders
)
DeleteCollection
(
options
*
v1
.
DeleteOptions
,
listOptions
v1
.
ListOptions
)
error
{
var
timeout
time
.
Duration
if
listOptions
.
TimeoutSeconds
!=
nil
{
timeout
=
time
.
Duration
(
*
listOptions
.
TimeoutSeconds
)
*
time
.
Second
}
return
c
.
client
.
Delete
()
.
Namespace
(
c
.
ns
)
.
Resource
(
"flunders"
)
.
VersionedParams
(
&
listOptions
,
scheme
.
ParameterCodec
)
.
Timeout
(
timeout
)
.
Body
(
options
)
.
Do
()
.
Error
()
}
// Patch applies the patch and returns the patched flunder.
func
(
c
*
flunders
)
Patch
(
name
string
,
pt
types
.
PatchType
,
data
[]
byte
,
subresources
...
string
)
(
result
*
wardle
.
Flunder
,
err
error
)
{
result
=
&
wardle
.
Flunder
{}
err
=
c
.
client
.
Patch
(
pt
)
.
Namespace
(
c
.
ns
)
.
Resource
(
"flunders"
)
.
SubResource
(
subresources
...
)
.
Name
(
name
)
.
Body
(
data
)
.
Do
()
.
Into
(
result
)
return
}
staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion/generated_expansion.go
deleted
100644 → 0
View file @
b278f847
/*
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
internalversion
type
FischerExpansion
interface
{}
type
FlunderExpansion
interface
{}
staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion/typed/wardle/internalversion/wardle_client.go
deleted
100644 → 0
View file @
b278f847
/*
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
internalversion
import
(
rest
"k8s.io/client-go/rest"
"k8s.io/sample-apiserver/pkg/client/clientset/internalversion/scheme"
)
type
WardleInterface
interface
{
RESTClient
()
rest
.
Interface
FischersGetter
FlundersGetter
}
// WardleClient is used to interact with features provided by the wardle.k8s.io group.
type
WardleClient
struct
{
restClient
rest
.
Interface
}
func
(
c
*
WardleClient
)
Fischers
()
FischerInterface
{
return
newFischers
(
c
)
}
func
(
c
*
WardleClient
)
Flunders
(
namespace
string
)
FlunderInterface
{
return
newFlunders
(
c
,
namespace
)
}
// NewForConfig creates a new WardleClient for the given config.
func
NewForConfig
(
c
*
rest
.
Config
)
(
*
WardleClient
,
error
)
{
config
:=
*
c
if
err
:=
setConfigDefaults
(
&
config
);
err
!=
nil
{
return
nil
,
err
}
client
,
err
:=
rest
.
RESTClientFor
(
&
config
)
if
err
!=
nil
{
return
nil
,
err
}
return
&
WardleClient
{
client
},
nil
}
// NewForConfigOrDie creates a new WardleClient for the given config and
// panics if there is an error in the config.
func
NewForConfigOrDie
(
c
*
rest
.
Config
)
*
WardleClient
{
client
,
err
:=
NewForConfig
(
c
)
if
err
!=
nil
{
panic
(
err
)
}
return
client
}
// New creates a new WardleClient for the given RESTClient.
func
New
(
c
rest
.
Interface
)
*
WardleClient
{
return
&
WardleClient
{
c
}
}
func
setConfigDefaults
(
config
*
rest
.
Config
)
error
{
config
.
APIPath
=
"/apis"
if
config
.
UserAgent
==
""
{
config
.
UserAgent
=
rest
.
DefaultKubernetesUserAgent
()
}
if
config
.
GroupVersion
==
nil
||
config
.
GroupVersion
.
Group
!=
scheme
.
Scheme
.
PrioritizedVersionsForGroup
(
"wardle.k8s.io"
)[
0
]
.
Group
{
gv
:=
scheme
.
Scheme
.
PrioritizedVersionsForGroup
(
"wardle.k8s.io"
)[
0
]
config
.
GroupVersion
=
&
gv
}
config
.
NegotiatedSerializer
=
scheme
.
Codecs
if
config
.
QPS
==
0
{
config
.
QPS
=
5
}
if
config
.
Burst
==
0
{
config
.
Burst
=
10
}
return
nil
}
// RESTClient returns a RESTClient that is used to communicate
// with API server by this client implementation.
func
(
c
*
WardleClient
)
RESTClient
()
rest
.
Interface
{
if
c
==
nil
{
return
nil
}
return
c
.
restClient
}
staging/src/k8s.io/sample-apiserver/pkg/client/informers/internalversion/BUILD
deleted
100644 → 0
View file @
b278f847
load("@io_bazel_rules_go//go:def.bzl", "go_library")
go_library(
name = "go_default_library",
srcs = [
"factory.go",
"generic.go",
],
importmap = "k8s.io/kubernetes/vendor/k8s.io/sample-apiserver/pkg/client/informers/internalversion",
importpath = "k8s.io/sample-apiserver/pkg/client/informers/internalversion",
visibility = ["//visibility:public"],
deps = [
"//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library",
"//staging/src/k8s.io/apimachinery/pkg/runtime:go_default_library",
"//staging/src/k8s.io/apimachinery/pkg/runtime/schema:go_default_library",
"//staging/src/k8s.io/client-go/tools/cache:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/apis/wardle:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/informers/internalversion/internalinterfaces:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/informers/internalversion/wardle:go_default_library",
],
)
filegroup(
name = "package-srcs",
srcs = glob(["**"]),
tags = ["automanaged"],
visibility = ["//visibility:private"],
)
filegroup(
name = "all-srcs",
srcs = [
":package-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/client/informers/internalversion/internalinterfaces:all-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/client/informers/internalversion/wardle:all-srcs",
],
tags = ["automanaged"],
visibility = ["//visibility:public"],
)
staging/src/k8s.io/sample-apiserver/pkg/client/informers/internalversion/factory.go
deleted
100644 → 0
View file @
b278f847
/*
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
internalversion
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"
internalversion
"k8s.io/sample-apiserver/pkg/client/clientset/internalversion"
internalinterfaces
"k8s.io/sample-apiserver/pkg/client/informers/internalversion/internalinterfaces"
wardle
"k8s.io/sample-apiserver/pkg/client/informers/internalversion/wardle"
)
// SharedInformerOption defines the functional option type for SharedInformerFactory.
type
SharedInformerOption
func
(
*
sharedInformerFactory
)
*
sharedInformerFactory
type
sharedInformerFactory
struct
{
client
internalversion
.
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
internalversion
.
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
internalversion
.
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
internalversion
.
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
Wardle
()
wardle
.
Interface
}
func
(
f
*
sharedInformerFactory
)
Wardle
()
wardle
.
Interface
{
return
wardle
.
New
(
f
,
f
.
namespace
,
f
.
tweakListOptions
)
}
staging/src/k8s.io/sample-apiserver/pkg/client/informers/internalversion/generic.go
deleted
100644 → 0
View file @
b278f847
/*
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
internalversion
import
(
"fmt"
schema
"k8s.io/apimachinery/pkg/runtime/schema"
cache
"k8s.io/client-go/tools/cache"
wardle
"k8s.io/sample-apiserver/pkg/apis/wardle"
)
// 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=wardle.k8s.io, Version=internalVersion
case
wardle
.
SchemeGroupVersion
.
WithResource
(
"fischers"
)
:
return
&
genericInformer
{
resource
:
resource
.
GroupResource
(),
informer
:
f
.
Wardle
()
.
InternalVersion
()
.
Fischers
()
.
Informer
()},
nil
case
wardle
.
SchemeGroupVersion
.
WithResource
(
"flunders"
)
:
return
&
genericInformer
{
resource
:
resource
.
GroupResource
(),
informer
:
f
.
Wardle
()
.
InternalVersion
()
.
Flunders
()
.
Informer
()},
nil
}
return
nil
,
fmt
.
Errorf
(
"no informer found for %v"
,
resource
)
}
staging/src/k8s.io/sample-apiserver/pkg/client/informers/internalversion/internalinterfaces/BUILD
deleted
100644 → 0
View file @
b278f847
load("@io_bazel_rules_go//go:def.bzl", "go_library")
go_library(
name = "go_default_library",
srcs = ["factory_interfaces.go"],
importmap = "k8s.io/kubernetes/vendor/k8s.io/sample-apiserver/pkg/client/informers/internalversion/internalinterfaces",
importpath = "k8s.io/sample-apiserver/pkg/client/informers/internalversion/internalinterfaces",
visibility = ["//visibility:public"],
deps = [
"//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library",
"//staging/src/k8s.io/apimachinery/pkg/runtime:go_default_library",
"//staging/src/k8s.io/client-go/tools/cache:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion: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"],
)
staging/src/k8s.io/sample-apiserver/pkg/client/informers/internalversion/internalinterfaces/factory_interfaces.go
deleted
100644 → 0
View file @
b278f847
/*
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"
internalversion
"k8s.io/sample-apiserver/pkg/client/clientset/internalversion"
)
// NewInformerFunc takes internalversion.Interface and time.Duration to return a SharedIndexInformer.
type
NewInformerFunc
func
(
internalversion
.
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
}
// TweakListOptionsFunc is a function that transforms a v1.ListOptions.
type
TweakListOptionsFunc
func
(
*
v1
.
ListOptions
)
staging/src/k8s.io/sample-apiserver/pkg/client/informers/internalversion/wardle/BUILD
deleted
100644 → 0
View file @
b278f847
load("@io_bazel_rules_go//go:def.bzl", "go_library")
go_library(
name = "go_default_library",
srcs = ["interface.go"],
importmap = "k8s.io/kubernetes/vendor/k8s.io/sample-apiserver/pkg/client/informers/internalversion/wardle",
importpath = "k8s.io/sample-apiserver/pkg/client/informers/internalversion/wardle",
visibility = ["//visibility:public"],
deps = [
"//staging/src/k8s.io/sample-apiserver/pkg/client/informers/internalversion/internalinterfaces:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/informers/internalversion/wardle/internalversion:go_default_library",
],
)
filegroup(
name = "package-srcs",
srcs = glob(["**"]),
tags = ["automanaged"],
visibility = ["//visibility:private"],
)
filegroup(
name = "all-srcs",
srcs = [
":package-srcs",
"//staging/src/k8s.io/sample-apiserver/pkg/client/informers/internalversion/wardle/internalversion:all-srcs",
],
tags = ["automanaged"],
visibility = ["//visibility:public"],
)
staging/src/k8s.io/sample-apiserver/pkg/client/informers/internalversion/wardle/interface.go
deleted
100644 → 0
View file @
b278f847
/*
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
wardle
import
(
internalinterfaces
"k8s.io/sample-apiserver/pkg/client/informers/internalversion/internalinterfaces"
internalversion
"k8s.io/sample-apiserver/pkg/client/informers/internalversion/wardle/internalversion"
)
// Interface provides access to each of this group's versions.
type
Interface
interface
{
// InternalVersion provides access to shared informers for resources in InternalVersion.
InternalVersion
()
internalversion
.
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
}
}
// InternalVersion returns a new internalversion.Interface.
func
(
g
*
group
)
InternalVersion
()
internalversion
.
Interface
{
return
internalversion
.
New
(
g
.
factory
,
g
.
namespace
,
g
.
tweakListOptions
)
}
staging/src/k8s.io/sample-apiserver/pkg/client/informers/internalversion/wardle/internalversion/BUILD
deleted
100644 → 0
View file @
b278f847
load("@io_bazel_rules_go//go:def.bzl", "go_library")
go_library(
name = "go_default_library",
srcs = [
"fischer.go",
"flunder.go",
"interface.go",
],
importmap = "k8s.io/kubernetes/vendor/k8s.io/sample-apiserver/pkg/client/informers/internalversion/wardle/internalversion",
importpath = "k8s.io/sample-apiserver/pkg/client/informers/internalversion/wardle/internalversion",
visibility = ["//visibility:public"],
deps = [
"//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library",
"//staging/src/k8s.io/apimachinery/pkg/runtime:go_default_library",
"//staging/src/k8s.io/apimachinery/pkg/watch:go_default_library",
"//staging/src/k8s.io/client-go/tools/cache:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/apis/wardle:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/internalversion:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/informers/internalversion/internalinterfaces:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/listers/wardle/internalversion: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"],
)
staging/src/k8s.io/sample-apiserver/pkg/client/informers/internalversion/wardle/internalversion/fischer.go
deleted
100644 → 0
View file @
b278f847
/*
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
internalversion
import
(
time
"time"
v1
"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"
wardle
"k8s.io/sample-apiserver/pkg/apis/wardle"
clientsetinternalversion
"k8s.io/sample-apiserver/pkg/client/clientset/internalversion"
internalinterfaces
"k8s.io/sample-apiserver/pkg/client/informers/internalversion/internalinterfaces"
internalversion
"k8s.io/sample-apiserver/pkg/client/listers/wardle/internalversion"
)
// FischerInformer provides access to a shared informer and lister for
// Fischers.
type
FischerInformer
interface
{
Informer
()
cache
.
SharedIndexInformer
Lister
()
internalversion
.
FischerLister
}
type
fischerInformer
struct
{
factory
internalinterfaces
.
SharedInformerFactory
tweakListOptions
internalinterfaces
.
TweakListOptionsFunc
}
// NewFischerInformer constructs a new informer for Fischer 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
NewFischerInformer
(
client
clientsetinternalversion
.
Interface
,
resyncPeriod
time
.
Duration
,
indexers
cache
.
Indexers
)
cache
.
SharedIndexInformer
{
return
NewFilteredFischerInformer
(
client
,
resyncPeriod
,
indexers
,
nil
)
}
// NewFilteredFischerInformer constructs a new informer for Fischer 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
NewFilteredFischerInformer
(
client
clientsetinternalversion
.
Interface
,
resyncPeriod
time
.
Duration
,
indexers
cache
.
Indexers
,
tweakListOptions
internalinterfaces
.
TweakListOptionsFunc
)
cache
.
SharedIndexInformer
{
return
cache
.
NewSharedIndexInformer
(
&
cache
.
ListWatch
{
ListFunc
:
func
(
options
v1
.
ListOptions
)
(
runtime
.
Object
,
error
)
{
if
tweakListOptions
!=
nil
{
tweakListOptions
(
&
options
)
}
return
client
.
Wardle
()
.
Fischers
()
.
List
(
options
)
},
WatchFunc
:
func
(
options
v1
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
if
tweakListOptions
!=
nil
{
tweakListOptions
(
&
options
)
}
return
client
.
Wardle
()
.
Fischers
()
.
Watch
(
options
)
},
},
&
wardle
.
Fischer
{},
resyncPeriod
,
indexers
,
)
}
func
(
f
*
fischerInformer
)
defaultInformer
(
client
clientsetinternalversion
.
Interface
,
resyncPeriod
time
.
Duration
)
cache
.
SharedIndexInformer
{
return
NewFilteredFischerInformer
(
client
,
resyncPeriod
,
cache
.
Indexers
{
cache
.
NamespaceIndex
:
cache
.
MetaNamespaceIndexFunc
},
f
.
tweakListOptions
)
}
func
(
f
*
fischerInformer
)
Informer
()
cache
.
SharedIndexInformer
{
return
f
.
factory
.
InformerFor
(
&
wardle
.
Fischer
{},
f
.
defaultInformer
)
}
func
(
f
*
fischerInformer
)
Lister
()
internalversion
.
FischerLister
{
return
internalversion
.
NewFischerLister
(
f
.
Informer
()
.
GetIndexer
())
}
staging/src/k8s.io/sample-apiserver/pkg/client/informers/internalversion/wardle/internalversion/flunder.go
deleted
100644 → 0
View file @
b278f847
/*
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
internalversion
import
(
time
"time"
v1
"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"
wardle
"k8s.io/sample-apiserver/pkg/apis/wardle"
clientsetinternalversion
"k8s.io/sample-apiserver/pkg/client/clientset/internalversion"
internalinterfaces
"k8s.io/sample-apiserver/pkg/client/informers/internalversion/internalinterfaces"
internalversion
"k8s.io/sample-apiserver/pkg/client/listers/wardle/internalversion"
)
// FlunderInformer provides access to a shared informer and lister for
// Flunders.
type
FlunderInformer
interface
{
Informer
()
cache
.
SharedIndexInformer
Lister
()
internalversion
.
FlunderLister
}
type
flunderInformer
struct
{
factory
internalinterfaces
.
SharedInformerFactory
tweakListOptions
internalinterfaces
.
TweakListOptionsFunc
namespace
string
}
// NewFlunderInformer constructs a new informer for Flunder 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
NewFlunderInformer
(
client
clientsetinternalversion
.
Interface
,
namespace
string
,
resyncPeriod
time
.
Duration
,
indexers
cache
.
Indexers
)
cache
.
SharedIndexInformer
{
return
NewFilteredFlunderInformer
(
client
,
namespace
,
resyncPeriod
,
indexers
,
nil
)
}
// NewFilteredFlunderInformer constructs a new informer for Flunder 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
NewFilteredFlunderInformer
(
client
clientsetinternalversion
.
Interface
,
namespace
string
,
resyncPeriod
time
.
Duration
,
indexers
cache
.
Indexers
,
tweakListOptions
internalinterfaces
.
TweakListOptionsFunc
)
cache
.
SharedIndexInformer
{
return
cache
.
NewSharedIndexInformer
(
&
cache
.
ListWatch
{
ListFunc
:
func
(
options
v1
.
ListOptions
)
(
runtime
.
Object
,
error
)
{
if
tweakListOptions
!=
nil
{
tweakListOptions
(
&
options
)
}
return
client
.
Wardle
()
.
Flunders
(
namespace
)
.
List
(
options
)
},
WatchFunc
:
func
(
options
v1
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
if
tweakListOptions
!=
nil
{
tweakListOptions
(
&
options
)
}
return
client
.
Wardle
()
.
Flunders
(
namespace
)
.
Watch
(
options
)
},
},
&
wardle
.
Flunder
{},
resyncPeriod
,
indexers
,
)
}
func
(
f
*
flunderInformer
)
defaultInformer
(
client
clientsetinternalversion
.
Interface
,
resyncPeriod
time
.
Duration
)
cache
.
SharedIndexInformer
{
return
NewFilteredFlunderInformer
(
client
,
f
.
namespace
,
resyncPeriod
,
cache
.
Indexers
{
cache
.
NamespaceIndex
:
cache
.
MetaNamespaceIndexFunc
},
f
.
tweakListOptions
)
}
func
(
f
*
flunderInformer
)
Informer
()
cache
.
SharedIndexInformer
{
return
f
.
factory
.
InformerFor
(
&
wardle
.
Flunder
{},
f
.
defaultInformer
)
}
func
(
f
*
flunderInformer
)
Lister
()
internalversion
.
FlunderLister
{
return
internalversion
.
NewFlunderLister
(
f
.
Informer
()
.
GetIndexer
())
}
staging/src/k8s.io/sample-apiserver/pkg/client/informers/internalversion/wardle/internalversion/interface.go
deleted
100644 → 0
View file @
b278f847
/*
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
internalversion
import
(
internalinterfaces
"k8s.io/sample-apiserver/pkg/client/informers/internalversion/internalinterfaces"
)
// Interface provides access to all the informers in this group version.
type
Interface
interface
{
// Fischers returns a FischerInformer.
Fischers
()
FischerInformer
// Flunders returns a FlunderInformer.
Flunders
()
FlunderInformer
}
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
}
}
// Fischers returns a FischerInformer.
func
(
v
*
version
)
Fischers
()
FischerInformer
{
return
&
fischerInformer
{
factory
:
v
.
factory
,
tweakListOptions
:
v
.
tweakListOptions
}
}
// Flunders returns a FlunderInformer.
func
(
v
*
version
)
Flunders
()
FlunderInformer
{
return
&
flunderInformer
{
factory
:
v
.
factory
,
namespace
:
v
.
namespace
,
tweakListOptions
:
v
.
tweakListOptions
}
}
staging/src/k8s.io/sample-apiserver/pkg/client/listers/wardle/internalversion/BUILD
deleted
100644 → 0
View file @
b278f847
load("@io_bazel_rules_go//go:def.bzl", "go_library")
go_library(
name = "go_default_library",
srcs = [
"expansion_generated.go",
"fischer.go",
"flunder.go",
],
importmap = "k8s.io/kubernetes/vendor/k8s.io/sample-apiserver/pkg/client/listers/wardle/internalversion",
importpath = "k8s.io/sample-apiserver/pkg/client/listers/wardle/internalversion",
visibility = ["//visibility:public"],
deps = [
"//staging/src/k8s.io/apimachinery/pkg/api/errors:go_default_library",
"//staging/src/k8s.io/apimachinery/pkg/labels:go_default_library",
"//staging/src/k8s.io/client-go/tools/cache:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/apis/wardle: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"],
)
staging/src/k8s.io/sample-apiserver/pkg/client/listers/wardle/internalversion/expansion_generated.go
deleted
100644 → 0
View file @
b278f847
/*
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
internalversion
// FischerListerExpansion allows custom methods to be added to
// FischerLister.
type
FischerListerExpansion
interface
{}
// FlunderListerExpansion allows custom methods to be added to
// FlunderLister.
type
FlunderListerExpansion
interface
{}
// FlunderNamespaceListerExpansion allows custom methods to be added to
// FlunderNamespaceLister.
type
FlunderNamespaceListerExpansion
interface
{}
staging/src/k8s.io/sample-apiserver/pkg/client/listers/wardle/internalversion/fischer.go
deleted
100644 → 0
View file @
b278f847
/*
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
internalversion
import
(
"k8s.io/apimachinery/pkg/api/errors"
"k8s.io/apimachinery/pkg/labels"
"k8s.io/client-go/tools/cache"
wardle
"k8s.io/sample-apiserver/pkg/apis/wardle"
)
// FischerLister helps list Fischers.
type
FischerLister
interface
{
// List lists all Fischers in the indexer.
List
(
selector
labels
.
Selector
)
(
ret
[]
*
wardle
.
Fischer
,
err
error
)
// Get retrieves the Fischer from the index for a given name.
Get
(
name
string
)
(
*
wardle
.
Fischer
,
error
)
FischerListerExpansion
}
// fischerLister implements the FischerLister interface.
type
fischerLister
struct
{
indexer
cache
.
Indexer
}
// NewFischerLister returns a new FischerLister.
func
NewFischerLister
(
indexer
cache
.
Indexer
)
FischerLister
{
return
&
fischerLister
{
indexer
:
indexer
}
}
// List lists all Fischers in the indexer.
func
(
s
*
fischerLister
)
List
(
selector
labels
.
Selector
)
(
ret
[]
*
wardle
.
Fischer
,
err
error
)
{
err
=
cache
.
ListAll
(
s
.
indexer
,
selector
,
func
(
m
interface
{})
{
ret
=
append
(
ret
,
m
.
(
*
wardle
.
Fischer
))
})
return
ret
,
err
}
// Get retrieves the Fischer from the index for a given name.
func
(
s
*
fischerLister
)
Get
(
name
string
)
(
*
wardle
.
Fischer
,
error
)
{
obj
,
exists
,
err
:=
s
.
indexer
.
GetByKey
(
name
)
if
err
!=
nil
{
return
nil
,
err
}
if
!
exists
{
return
nil
,
errors
.
NewNotFound
(
wardle
.
Resource
(
"fischer"
),
name
)
}
return
obj
.
(
*
wardle
.
Fischer
),
nil
}
staging/src/k8s.io/sample-apiserver/pkg/client/listers/wardle/internalversion/flunder.go
deleted
100644 → 0
View file @
b278f847
/*
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
internalversion
import
(
"k8s.io/apimachinery/pkg/api/errors"
"k8s.io/apimachinery/pkg/labels"
"k8s.io/client-go/tools/cache"
wardle
"k8s.io/sample-apiserver/pkg/apis/wardle"
)
// FlunderLister helps list Flunders.
type
FlunderLister
interface
{
// List lists all Flunders in the indexer.
List
(
selector
labels
.
Selector
)
(
ret
[]
*
wardle
.
Flunder
,
err
error
)
// Flunders returns an object that can list and get Flunders.
Flunders
(
namespace
string
)
FlunderNamespaceLister
FlunderListerExpansion
}
// flunderLister implements the FlunderLister interface.
type
flunderLister
struct
{
indexer
cache
.
Indexer
}
// NewFlunderLister returns a new FlunderLister.
func
NewFlunderLister
(
indexer
cache
.
Indexer
)
FlunderLister
{
return
&
flunderLister
{
indexer
:
indexer
}
}
// List lists all Flunders in the indexer.
func
(
s
*
flunderLister
)
List
(
selector
labels
.
Selector
)
(
ret
[]
*
wardle
.
Flunder
,
err
error
)
{
err
=
cache
.
ListAll
(
s
.
indexer
,
selector
,
func
(
m
interface
{})
{
ret
=
append
(
ret
,
m
.
(
*
wardle
.
Flunder
))
})
return
ret
,
err
}
// Flunders returns an object that can list and get Flunders.
func
(
s
*
flunderLister
)
Flunders
(
namespace
string
)
FlunderNamespaceLister
{
return
flunderNamespaceLister
{
indexer
:
s
.
indexer
,
namespace
:
namespace
}
}
// FlunderNamespaceLister helps list and get Flunders.
type
FlunderNamespaceLister
interface
{
// List lists all Flunders in the indexer for a given namespace.
List
(
selector
labels
.
Selector
)
(
ret
[]
*
wardle
.
Flunder
,
err
error
)
// Get retrieves the Flunder from the indexer for a given namespace and name.
Get
(
name
string
)
(
*
wardle
.
Flunder
,
error
)
FlunderNamespaceListerExpansion
}
// flunderNamespaceLister implements the FlunderNamespaceLister
// interface.
type
flunderNamespaceLister
struct
{
indexer
cache
.
Indexer
namespace
string
}
// List lists all Flunders in the indexer for a given namespace.
func
(
s
flunderNamespaceLister
)
List
(
selector
labels
.
Selector
)
(
ret
[]
*
wardle
.
Flunder
,
err
error
)
{
err
=
cache
.
ListAllByNamespace
(
s
.
indexer
,
s
.
namespace
,
selector
,
func
(
m
interface
{})
{
ret
=
append
(
ret
,
m
.
(
*
wardle
.
Flunder
))
})
return
ret
,
err
}
// Get retrieves the Flunder from the indexer for a given namespace and name.
func
(
s
flunderNamespaceLister
)
Get
(
name
string
)
(
*
wardle
.
Flunder
,
error
)
{
obj
,
exists
,
err
:=
s
.
indexer
.
GetByKey
(
s
.
namespace
+
"/"
+
name
)
if
err
!=
nil
{
return
nil
,
err
}
if
!
exists
{
return
nil
,
errors
.
NewNotFound
(
wardle
.
Resource
(
"flunder"
),
name
)
}
return
obj
.
(
*
wardle
.
Flunder
),
nil
}
staging/src/k8s.io/sample-apiserver/pkg/cmd/server/BUILD
View file @
9aeb7b07
...
@@ -19,8 +19,8 @@ go_library(
...
@@ -19,8 +19,8 @@ go_library(
"//staging/src/k8s.io/sample-apiserver/pkg/admission/wardleinitializer:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/admission/wardleinitializer:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/apis/wardle/v1alpha1:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/apis/wardle/v1alpha1:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/apiserver:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/apiserver:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/
internalversion
:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/clientset/
versioned
:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/informers/
internalversion
:go_default_library",
"//staging/src/k8s.io/sample-apiserver/pkg/client/informers/
externalversions
:go_default_library",
"//vendor/github.com/spf13/cobra:go_default_library",
"//vendor/github.com/spf13/cobra:go_default_library",
],
],
)
)
...
...
staging/src/k8s.io/sample-apiserver/pkg/cmd/server/start.go
View file @
9aeb7b07
...
@@ -31,8 +31,8 @@ import (
...
@@ -31,8 +31,8 @@ import (
"k8s.io/sample-apiserver/pkg/admission/wardleinitializer"
"k8s.io/sample-apiserver/pkg/admission/wardleinitializer"
"k8s.io/sample-apiserver/pkg/apis/wardle/v1alpha1"
"k8s.io/sample-apiserver/pkg/apis/wardle/v1alpha1"
"k8s.io/sample-apiserver/pkg/apiserver"
"k8s.io/sample-apiserver/pkg/apiserver"
clientset
"k8s.io/sample-apiserver/pkg/client/clientset/
internalversion
"
clientset
"k8s.io/sample-apiserver/pkg/client/clientset/
versioned
"
informers
"k8s.io/sample-apiserver/pkg/client/informers/
internalversion
"
informers
"k8s.io/sample-apiserver/pkg/client/informers/
externalversions
"
)
)
const
defaultEtcdPathPrefix
=
"/registry/wardle.kubernetes.io"
const
defaultEtcdPathPrefix
=
"/registry/wardle.kubernetes.io"
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment