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
019583ad
Commit
019583ad
authored
Oct 30, 2017
by
Nikhita Raghunath
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
typed client: add generated files
parent
355279c8
Hide whitespace changes
Inline
Side-by-side
Showing
36 changed files
with
1786 additions
and
55 deletions
+1786
-55
BUILD
...c/k8s.io/apiextensions-apiserver/examples/client-go/BUILD
+5
-33
BUILD
...ensions-apiserver/examples/client-go/pkg/apis/cr/v1/BUILD
+0
-17
zz_generated.deepcopy.go
...xamples/client-go/pkg/apis/cr/v1/zz_generated.deepcopy.go
+151
-0
BUILD
...r/examples/client-go/pkg/client/clientset/versioned/BUILD
+37
-0
clientset.go
...les/client-go/pkg/client/clientset/versioned/clientset.go
+98
-0
doc.go
.../examples/client-go/pkg/client/clientset/versioned/doc.go
+18
-0
BUILD
...mples/client-go/pkg/client/clientset/versioned/fake/BUILD
+40
-0
clientset_generated.go
...kg/client/clientset/versioned/fake/clientset_generated.go
+71
-0
doc.go
...ples/client-go/pkg/client/clientset/versioned/fake/doc.go
+18
-0
register.go
...client-go/pkg/client/clientset/versioned/fake/register.go
+53
-0
BUILD
...les/client-go/pkg/client/clientset/versioned/scheme/BUILD
+32
-0
doc.go
...es/client-go/pkg/client/clientset/versioned/scheme/doc.go
+18
-0
register.go
...ient-go/pkg/client/clientset/versioned/scheme/register.go
+53
-0
BUILD
...lient-go/pkg/client/clientset/versioned/typed/cr/v1/BUILD
+39
-0
cr_client.go
...o/pkg/client/clientset/versioned/typed/cr/v1/cr_client.go
+88
-0
doc.go
...ient-go/pkg/client/clientset/versioned/typed/cr/v1/doc.go
+18
-0
example.go
...-go/pkg/client/clientset/versioned/typed/cr/v1/example.go
+155
-0
BUILD
...-go/pkg/client/clientset/versioned/typed/cr/v1/fake/BUILD
+37
-0
doc.go
...go/pkg/client/clientset/versioned/typed/cr/v1/fake/doc.go
+18
-0
fake_cr_client.go
...nt/clientset/versioned/typed/cr/v1/fake/fake_cr_client.go
+38
-0
fake_example.go
...ient/clientset/versioned/typed/cr/v1/fake/fake_example.go
+126
-0
generated_expansion.go
...nt/clientset/versioned/typed/cr/v1/generated_expansion.go
+19
-0
BUILD
...les/client-go/pkg/client/informers/externalversions/BUILD
+38
-0
BUILD
.../client-go/pkg/client/informers/externalversions/cr/BUILD
+29
-0
interface.go
...-go/pkg/client/informers/externalversions/cr/interface.go
+44
-0
BUILD
...ient-go/pkg/client/informers/externalversions/cr/v1/BUILD
+35
-0
example.go
...go/pkg/client/informers/externalversions/cr/v1/example.go
+73
-0
interface.go
.../pkg/client/informers/externalversions/cr/v1/interface.go
+43
-0
factory.go
...lient-go/pkg/client/informers/externalversions/factory.go
+118
-0
generic.go
...lient-go/pkg/client/informers/externalversions/generic.go
+61
-0
BUILD
...lient/informers/externalversions/internalinterfaces/BUILD
+27
-0
factory_interfaces.go
...externalversions/internalinterfaces/factory_interfaces.go
+34
-0
BUILD
...iserver/examples/client-go/pkg/client/listers/cr/v1/BUILD
+31
-0
example.go
...er/examples/client-go/pkg/client/listers/cr/v1/example.go
+94
-0
expansion_generated.go
...client-go/pkg/client/listers/cr/v1/expansion_generated.go
+27
-0
BUILD
...src/k8s.io/apiextensions-apiserver/test/integration/BUILD
+0
-5
No files found.
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/BUILD
View file @
019583ad
package(default_visibility = ["//visibility:public"])
load(
"@io_bazel_rules_go//go:def.bzl",
"go_binary",
"go_library",
)
go_library(
name = "go_default_library",
srcs = ["main.go"],
importpath = "k8s.io/apiextensions-apiserver/examples/client-go",
deps = [
"//vendor/k8s.io/api/core/v1:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/apis/cr/v1:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/client:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/controller:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/api/errors:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library",
"//vendor/k8s.io/client-go/tools/clientcmd:go_default_library",
],
)
go_binary(
name = "client-go",
importpath = "k8s.io/apiextensions-apiserver/examples/client-go",
library = ":go_default_library",
)
filegroup(
filegroup(
name = "package-srcs",
name = "package-srcs",
srcs = glob(["**"]),
srcs = glob(["**"]),
...
@@ -39,9 +9,11 @@ filegroup(
...
@@ -39,9 +9,11 @@ filegroup(
name = "all-srcs",
name = "all-srcs",
srcs = [
srcs = [
":package-srcs",
":package-srcs",
"//staging/src/k8s.io/apiextensions-apiserver/examples/client-go/apis/cr/v1:all-srcs",
"//staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/apis/cr:all-srcs",
"//staging/src/k8s.io/apiextensions-apiserver/examples/client-go/client:all-srcs",
"//staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned:all-srcs",
"//staging/src/k8s.io/apiextensions-apiserver/examples/client-go/controller:all-srcs",
"//staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions:all-srcs",
"//staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/listers/cr/v1:all-srcs",
],
],
tags = ["automanaged"],
tags = ["automanaged"],
visibility = ["//visibility:public"],
)
)
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/apis/cr/v1/BUILD
View file @
019583ad
...
@@ -3,23 +3,6 @@ package(default_visibility = ["//visibility:public"])
...
@@ -3,23 +3,6 @@ package(default_visibility = ["//visibility:public"])
load(
load(
"@io_bazel_rules_go//go:def.bzl",
"@io_bazel_rules_go//go:def.bzl",
"go_library",
"go_library",
"go_test",
)
go_test(
name = "go_default_test",
srcs = ["roundtrip_test.go"],
importpath = "k8s.io/apiextensions-apiserver/examples/client-go/pkg/apis/cr/v1",
library = ":go_default_library",
deps = [
"//vendor/github.com/google/gofuzz:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/api/testing/fuzzer:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/api/testing/roundtrip:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/apis/meta/fuzzer:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/runtime:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/runtime/serializer:go_default_library",
],
)
)
go_library(
go_library(
...
...
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/apis/cr/v1/zz_generated.deepcopy.go
0 → 100644
View file @
019583ad
// +build !ignore_autogenerated
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
// This file was autogenerated by deepcopy-gen. Do not edit it manually!
package
v1
import
(
conversion
"k8s.io/apimachinery/pkg/conversion"
runtime
"k8s.io/apimachinery/pkg/runtime"
reflect
"reflect"
)
func
init
()
{
SchemeBuilder
.
Register
(
RegisterDeepCopies
)
}
// RegisterDeepCopies adds deep-copy functions to the given scheme. Public
// to allow building arbitrary schemes.
//
// Deprecated: deepcopy registration will go away when static deepcopy is fully implemented.
func
RegisterDeepCopies
(
scheme
*
runtime
.
Scheme
)
error
{
return
scheme
.
AddGeneratedDeepCopyFuncs
(
conversion
.
GeneratedDeepCopyFunc
{
Fn
:
func
(
in
interface
{},
out
interface
{},
c
*
conversion
.
Cloner
)
error
{
in
.
(
*
Example
)
.
DeepCopyInto
(
out
.
(
*
Example
))
return
nil
},
InType
:
reflect
.
TypeOf
(
&
Example
{})},
conversion
.
GeneratedDeepCopyFunc
{
Fn
:
func
(
in
interface
{},
out
interface
{},
c
*
conversion
.
Cloner
)
error
{
in
.
(
*
ExampleList
)
.
DeepCopyInto
(
out
.
(
*
ExampleList
))
return
nil
},
InType
:
reflect
.
TypeOf
(
&
ExampleList
{})},
conversion
.
GeneratedDeepCopyFunc
{
Fn
:
func
(
in
interface
{},
out
interface
{},
c
*
conversion
.
Cloner
)
error
{
in
.
(
*
ExampleSpec
)
.
DeepCopyInto
(
out
.
(
*
ExampleSpec
))
return
nil
},
InType
:
reflect
.
TypeOf
(
&
ExampleSpec
{})},
conversion
.
GeneratedDeepCopyFunc
{
Fn
:
func
(
in
interface
{},
out
interface
{},
c
*
conversion
.
Cloner
)
error
{
in
.
(
*
ExampleStatus
)
.
DeepCopyInto
(
out
.
(
*
ExampleStatus
))
return
nil
},
InType
:
reflect
.
TypeOf
(
&
ExampleStatus
{})},
)
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func
(
in
*
Example
)
DeepCopyInto
(
out
*
Example
)
{
*
out
=
*
in
out
.
TypeMeta
=
in
.
TypeMeta
in
.
ObjectMeta
.
DeepCopyInto
(
&
out
.
ObjectMeta
)
out
.
Spec
=
in
.
Spec
out
.
Status
=
in
.
Status
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Example.
func
(
in
*
Example
)
DeepCopy
()
*
Example
{
if
in
==
nil
{
return
nil
}
out
:=
new
(
Example
)
in
.
DeepCopyInto
(
out
)
return
out
}
// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func
(
in
*
Example
)
DeepCopyObject
()
runtime
.
Object
{
if
c
:=
in
.
DeepCopy
();
c
!=
nil
{
return
c
}
else
{
return
nil
}
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func
(
in
*
ExampleList
)
DeepCopyInto
(
out
*
ExampleList
)
{
*
out
=
*
in
out
.
TypeMeta
=
in
.
TypeMeta
out
.
ListMeta
=
in
.
ListMeta
if
in
.
Items
!=
nil
{
in
,
out
:=
&
in
.
Items
,
&
out
.
Items
*
out
=
make
([]
Example
,
len
(
*
in
))
for
i
:=
range
*
in
{
(
*
in
)[
i
]
.
DeepCopyInto
(
&
(
*
out
)[
i
])
}
}
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExampleList.
func
(
in
*
ExampleList
)
DeepCopy
()
*
ExampleList
{
if
in
==
nil
{
return
nil
}
out
:=
new
(
ExampleList
)
in
.
DeepCopyInto
(
out
)
return
out
}
// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func
(
in
*
ExampleList
)
DeepCopyObject
()
runtime
.
Object
{
if
c
:=
in
.
DeepCopy
();
c
!=
nil
{
return
c
}
else
{
return
nil
}
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func
(
in
*
ExampleSpec
)
DeepCopyInto
(
out
*
ExampleSpec
)
{
*
out
=
*
in
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExampleSpec.
func
(
in
*
ExampleSpec
)
DeepCopy
()
*
ExampleSpec
{
if
in
==
nil
{
return
nil
}
out
:=
new
(
ExampleSpec
)
in
.
DeepCopyInto
(
out
)
return
out
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func
(
in
*
ExampleStatus
)
DeepCopyInto
(
out
*
ExampleStatus
)
{
*
out
=
*
in
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExampleStatus.
func
(
in
*
ExampleStatus
)
DeepCopy
()
*
ExampleStatus
{
if
in
==
nil
{
return
nil
}
out
:=
new
(
ExampleStatus
)
in
.
DeepCopyInto
(
out
)
return
out
}
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/BUILD
0 → 100644
View file @
019583ad
load("@io_bazel_rules_go//go:def.bzl", "go_library")
go_library(
name = "go_default_library",
srcs = [
"clientset.go",
"doc.go",
],
importpath = "k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned",
visibility = ["//visibility:public"],
deps = [
"//vendor/github.com/golang/glog:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1:go_default_library",
"//vendor/k8s.io/client-go/discovery:go_default_library",
"//vendor/k8s.io/client-go/rest:go_default_library",
"//vendor/k8s.io/client-go/util/flowcontrol: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/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/fake:all-srcs",
"//staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/scheme:all-srcs",
"//staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1:all-srcs",
],
tags = ["automanaged"],
visibility = ["//visibility:public"],
)
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/clientset.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package
versioned
import
(
glog
"github.com/golang/glog"
crv1
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1"
discovery
"k8s.io/client-go/discovery"
rest
"k8s.io/client-go/rest"
flowcontrol
"k8s.io/client-go/util/flowcontrol"
)
type
Interface
interface
{
Discovery
()
discovery
.
DiscoveryInterface
CrV1
()
crv1
.
CrV1Interface
// Deprecated: please explicitly pick a version if possible.
Cr
()
crv1
.
CrV1Interface
}
// Clientset contains the clients for groups. Each group has exactly one
// version included in a Clientset.
type
Clientset
struct
{
*
discovery
.
DiscoveryClient
crV1
*
crv1
.
CrV1Client
}
// CrV1 retrieves the CrV1Client
func
(
c
*
Clientset
)
CrV1
()
crv1
.
CrV1Interface
{
return
c
.
crV1
}
// Deprecated: Cr retrieves the default version of CrClient.
// Please explicitly pick a version.
func
(
c
*
Clientset
)
Cr
()
crv1
.
CrV1Interface
{
return
c
.
crV1
}
// 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
.
crV1
,
err
=
crv1
.
NewForConfig
(
&
configShallowCopy
)
if
err
!=
nil
{
return
nil
,
err
}
cs
.
DiscoveryClient
,
err
=
discovery
.
NewDiscoveryClientForConfig
(
&
configShallowCopy
)
if
err
!=
nil
{
glog
.
Errorf
(
"failed to create the DiscoveryClient: %v"
,
err
)
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
.
crV1
=
crv1
.
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
.
crV1
=
crv1
.
New
(
c
)
cs
.
DiscoveryClient
=
discovery
.
NewDiscoveryClient
(
c
)
return
&
cs
}
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/doc.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
// This package has the automatically generated clientset.
package
versioned
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/fake/BUILD
0 → 100644
View file @
019583ad
load("@io_bazel_rules_go//go:def.bzl", "go_library")
go_library(
name = "go_default_library",
srcs = [
"clientset_generated.go",
"doc.go",
"register.go",
],
importpath = "k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/fake",
visibility = ["//visibility:public"],
deps = [
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/apis/cr/v1:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/fake:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/runtime:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/runtime/schema:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/runtime/serializer:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/watch:go_default_library",
"//vendor/k8s.io/client-go/discovery:go_default_library",
"//vendor/k8s.io/client-go/discovery/fake:go_default_library",
"//vendor/k8s.io/client-go/testing:go_default_library",
],
)
filegroup(
name = "package-srcs",
srcs = glob(["**"]),
tags = ["automanaged"],
visibility = ["//visibility:private"],
)
filegroup(
name = "all-srcs",
srcs = [":package-srcs"],
tags = ["automanaged"],
visibility = ["//visibility:public"],
)
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/fake/clientset_generated.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package
fake
import
(
clientset
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned"
crv1
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1"
fakecrv1
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/fake"
"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"
)
// 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
)
}
}
fakePtr
:=
testing
.
Fake
{}
fakePtr
.
AddReactor
(
"*"
,
"*"
,
testing
.
ObjectReaction
(
o
))
fakePtr
.
AddWatchReactor
(
"*"
,
testing
.
DefaultWatchReactor
(
watch
.
NewFake
(),
nil
))
return
&
Clientset
{
fakePtr
,
&
fakediscovery
.
FakeDiscovery
{
Fake
:
&
fakePtr
}}
}
// 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
{}
// CrV1 retrieves the CrV1Client
func
(
c
*
Clientset
)
CrV1
()
crv1
.
CrV1Interface
{
return
&
fakecrv1
.
FakeCrV1
{
Fake
:
&
c
.
Fake
}
}
// Cr retrieves the CrV1Client
func
(
c
*
Clientset
)
Cr
()
crv1
.
CrV1Interface
{
return
&
fakecrv1
.
FakeCrV1
{
Fake
:
&
c
.
Fake
}
}
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/fake/doc.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
// This package has the automatically generated fake clientset.
package
fake
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/fake/register.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package
fake
import
(
crv1
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/apis/cr/v1"
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"
)
var
scheme
=
runtime
.
NewScheme
()
var
codecs
=
serializer
.
NewCodecFactory
(
scheme
)
var
parameterCodec
=
runtime
.
NewParameterCodec
(
scheme
)
func
init
()
{
v1
.
AddToGroupVersion
(
scheme
,
schema
.
GroupVersion
{
Version
:
"v1"
})
AddToScheme
(
scheme
)
}
// 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/kuberentes/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.
func
AddToScheme
(
scheme
*
runtime
.
Scheme
)
{
crv1
.
AddToScheme
(
scheme
)
}
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/scheme/BUILD
0 → 100644
View file @
019583ad
load("@io_bazel_rules_go//go:def.bzl", "go_library")
go_library(
name = "go_default_library",
srcs = [
"doc.go",
"register.go",
],
importpath = "k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/scheme",
visibility = ["//visibility:public"],
deps = [
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/apis/cr/v1:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/runtime:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/runtime/schema:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/runtime/serializer: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/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/scheme/doc.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
// This package contains the scheme of the automatically generated clientset.
package
scheme
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/scheme/register.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package
scheme
import
(
crv1
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/apis/cr/v1"
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"
)
var
Scheme
=
runtime
.
NewScheme
()
var
Codecs
=
serializer
.
NewCodecFactory
(
Scheme
)
var
ParameterCodec
=
runtime
.
NewParameterCodec
(
Scheme
)
func
init
()
{
v1
.
AddToGroupVersion
(
Scheme
,
schema
.
GroupVersion
{
Version
:
"v1"
})
AddToScheme
(
Scheme
)
}
// 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/kuberentes/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.
func
AddToScheme
(
scheme
*
runtime
.
Scheme
)
{
crv1
.
AddToScheme
(
scheme
)
}
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/BUILD
0 → 100644
View file @
019583ad
load("@io_bazel_rules_go//go:def.bzl", "go_library")
go_library(
name = "go_default_library",
srcs = [
"cr_client.go",
"doc.go",
"example.go",
"generated_expansion.go",
],
importpath = "k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1",
visibility = ["//visibility:public"],
deps = [
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/apis/cr/v1:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/scheme:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/runtime/serializer:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/types:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/watch:go_default_library",
"//vendor/k8s.io/client-go/rest: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/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/fake:all-srcs",
],
tags = ["automanaged"],
visibility = ["//visibility:public"],
)
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/cr_client.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package
v1
import
(
v1
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/apis/cr/v1"
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/scheme"
serializer
"k8s.io/apimachinery/pkg/runtime/serializer"
rest
"k8s.io/client-go/rest"
)
type
CrV1Interface
interface
{
RESTClient
()
rest
.
Interface
ExamplesGetter
}
// CrV1Client is used to interact with features provided by the cr.client-go.k8s.io group.
type
CrV1Client
struct
{
restClient
rest
.
Interface
}
func
(
c
*
CrV1Client
)
Examples
(
namespace
string
)
ExampleInterface
{
return
newExamples
(
c
,
namespace
)
}
// NewForConfig creates a new CrV1Client for the given config.
func
NewForConfig
(
c
*
rest
.
Config
)
(
*
CrV1Client
,
error
)
{
config
:=
*
c
if
err
:=
setConfigDefaults
(
&
config
);
err
!=
nil
{
return
nil
,
err
}
client
,
err
:=
rest
.
RESTClientFor
(
&
config
)
if
err
!=
nil
{
return
nil
,
err
}
return
&
CrV1Client
{
client
},
nil
}
// NewForConfigOrDie creates a new CrV1Client for the given config and
// panics if there is an error in the config.
func
NewForConfigOrDie
(
c
*
rest
.
Config
)
*
CrV1Client
{
client
,
err
:=
NewForConfig
(
c
)
if
err
!=
nil
{
panic
(
err
)
}
return
client
}
// New creates a new CrV1Client for the given RESTClient.
func
New
(
c
rest
.
Interface
)
*
CrV1Client
{
return
&
CrV1Client
{
c
}
}
func
setConfigDefaults
(
config
*
rest
.
Config
)
error
{
gv
:=
v1
.
SchemeGroupVersion
config
.
GroupVersion
=
&
gv
config
.
APIPath
=
"/apis"
config
.
NegotiatedSerializer
=
serializer
.
DirectCodecFactory
{
CodecFactory
:
scheme
.
Codecs
}
if
config
.
UserAgent
==
""
{
config
.
UserAgent
=
rest
.
DefaultKubernetesUserAgent
()
}
return
nil
}
// RESTClient returns a RESTClient that is used to communicate
// with API server by this client implementation.
func
(
c
*
CrV1Client
)
RESTClient
()
rest
.
Interface
{
if
c
==
nil
{
return
nil
}
return
c
.
restClient
}
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/doc.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
// This package has the automatically generated typed clients.
package
v1
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/example.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package
v1
import
(
v1
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/apis/cr/v1"
scheme
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/scheme"
meta_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"
)
// ExamplesGetter has a method to return a ExampleInterface.
// A group's client should implement this interface.
type
ExamplesGetter
interface
{
Examples
(
namespace
string
)
ExampleInterface
}
// ExampleInterface has methods to work with Example resources.
type
ExampleInterface
interface
{
Create
(
*
v1
.
Example
)
(
*
v1
.
Example
,
error
)
Update
(
*
v1
.
Example
)
(
*
v1
.
Example
,
error
)
Delete
(
name
string
,
options
*
meta_v1
.
DeleteOptions
)
error
DeleteCollection
(
options
*
meta_v1
.
DeleteOptions
,
listOptions
meta_v1
.
ListOptions
)
error
Get
(
name
string
,
options
meta_v1
.
GetOptions
)
(
*
v1
.
Example
,
error
)
List
(
opts
meta_v1
.
ListOptions
)
(
*
v1
.
ExampleList
,
error
)
Watch
(
opts
meta_v1
.
ListOptions
)
(
watch
.
Interface
,
error
)
Patch
(
name
string
,
pt
types
.
PatchType
,
data
[]
byte
,
subresources
...
string
)
(
result
*
v1
.
Example
,
err
error
)
ExampleExpansion
}
// examples implements ExampleInterface
type
examples
struct
{
client
rest
.
Interface
ns
string
}
// newExamples returns a Examples
func
newExamples
(
c
*
CrV1Client
,
namespace
string
)
*
examples
{
return
&
examples
{
client
:
c
.
RESTClient
(),
ns
:
namespace
,
}
}
// Get takes name of the example, and returns the corresponding example object, and an error if there is any.
func
(
c
*
examples
)
Get
(
name
string
,
options
meta_v1
.
GetOptions
)
(
result
*
v1
.
Example
,
err
error
)
{
result
=
&
v1
.
Example
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
Resource
(
"examples"
)
.
Name
(
name
)
.
VersionedParams
(
&
options
,
scheme
.
ParameterCodec
)
.
Do
()
.
Into
(
result
)
return
}
// List takes label and field selectors, and returns the list of Examples that match those selectors.
func
(
c
*
examples
)
List
(
opts
meta_v1
.
ListOptions
)
(
result
*
v1
.
ExampleList
,
err
error
)
{
result
=
&
v1
.
ExampleList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
Resource
(
"examples"
)
.
VersionedParams
(
&
opts
,
scheme
.
ParameterCodec
)
.
Do
()
.
Into
(
result
)
return
}
// Watch returns a watch.Interface that watches the requested examples.
func
(
c
*
examples
)
Watch
(
opts
meta_v1
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
opts
.
Watch
=
true
return
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
Resource
(
"examples"
)
.
VersionedParams
(
&
opts
,
scheme
.
ParameterCodec
)
.
Watch
()
}
// Create takes the representation of a example and creates it. Returns the server's representation of the example, and an error, if there is any.
func
(
c
*
examples
)
Create
(
example
*
v1
.
Example
)
(
result
*
v1
.
Example
,
err
error
)
{
result
=
&
v1
.
Example
{}
err
=
c
.
client
.
Post
()
.
Namespace
(
c
.
ns
)
.
Resource
(
"examples"
)
.
Body
(
example
)
.
Do
()
.
Into
(
result
)
return
}
// Update takes the representation of a example and updates it. Returns the server's representation of the example, and an error, if there is any.
func
(
c
*
examples
)
Update
(
example
*
v1
.
Example
)
(
result
*
v1
.
Example
,
err
error
)
{
result
=
&
v1
.
Example
{}
err
=
c
.
client
.
Put
()
.
Namespace
(
c
.
ns
)
.
Resource
(
"examples"
)
.
Name
(
example
.
Name
)
.
Body
(
example
)
.
Do
()
.
Into
(
result
)
return
}
// Delete takes name of the example and deletes it. Returns an error if one occurs.
func
(
c
*
examples
)
Delete
(
name
string
,
options
*
meta_v1
.
DeleteOptions
)
error
{
return
c
.
client
.
Delete
()
.
Namespace
(
c
.
ns
)
.
Resource
(
"examples"
)
.
Name
(
name
)
.
Body
(
options
)
.
Do
()
.
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
examples
)
DeleteCollection
(
options
*
meta_v1
.
DeleteOptions
,
listOptions
meta_v1
.
ListOptions
)
error
{
return
c
.
client
.
Delete
()
.
Namespace
(
c
.
ns
)
.
Resource
(
"examples"
)
.
VersionedParams
(
&
listOptions
,
scheme
.
ParameterCodec
)
.
Body
(
options
)
.
Do
()
.
Error
()
}
// Patch applies the patch and returns the patched example.
func
(
c
*
examples
)
Patch
(
name
string
,
pt
types
.
PatchType
,
data
[]
byte
,
subresources
...
string
)
(
result
*
v1
.
Example
,
err
error
)
{
result
=
&
v1
.
Example
{}
err
=
c
.
client
.
Patch
(
pt
)
.
Namespace
(
c
.
ns
)
.
Resource
(
"examples"
)
.
SubResource
(
subresources
...
)
.
Name
(
name
)
.
Body
(
data
)
.
Do
()
.
Into
(
result
)
return
}
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/fake/BUILD
0 → 100644
View file @
019583ad
load("@io_bazel_rules_go//go:def.bzl", "go_library")
go_library(
name = "go_default_library",
srcs = [
"doc.go",
"fake_cr_client.go",
"fake_example.go",
],
importpath = "k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/fake",
visibility = ["//visibility:public"],
deps = [
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/apis/cr/v1:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/labels:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/runtime/schema:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/types:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/watch:go_default_library",
"//vendor/k8s.io/client-go/rest:go_default_library",
"//vendor/k8s.io/client-go/testing:go_default_library",
],
)
filegroup(
name = "package-srcs",
srcs = glob(["**"]),
tags = ["automanaged"],
visibility = ["//visibility:private"],
)
filegroup(
name = "all-srcs",
srcs = [":package-srcs"],
tags = ["automanaged"],
visibility = ["//visibility:public"],
)
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/fake/doc.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
// Package fake has the automatically generated clients.
package
fake
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/fake/fake_cr_client.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package
fake
import
(
v1
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1"
rest
"k8s.io/client-go/rest"
testing
"k8s.io/client-go/testing"
)
type
FakeCrV1
struct
{
*
testing
.
Fake
}
func
(
c
*
FakeCrV1
)
Examples
(
namespace
string
)
v1
.
ExampleInterface
{
return
&
FakeExamples
{
c
,
namespace
}
}
// RESTClient returns a RESTClient that is used to communicate
// with API server by this client implementation.
func
(
c
*
FakeCrV1
)
RESTClient
()
rest
.
Interface
{
var
ret
*
rest
.
RESTClient
return
ret
}
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/fake/fake_example.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package
fake
import
(
cr_v1
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/apis/cr/v1"
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"
)
// FakeExamples implements ExampleInterface
type
FakeExamples
struct
{
Fake
*
FakeCrV1
ns
string
}
var
examplesResource
=
schema
.
GroupVersionResource
{
Group
:
"cr.client-go.k8s.io"
,
Version
:
"v1"
,
Resource
:
"examples"
}
var
examplesKind
=
schema
.
GroupVersionKind
{
Group
:
"cr.client-go.k8s.io"
,
Version
:
"v1"
,
Kind
:
"Example"
}
// Get takes name of the example, and returns the corresponding example object, and an error if there is any.
func
(
c
*
FakeExamples
)
Get
(
name
string
,
options
v1
.
GetOptions
)
(
result
*
cr_v1
.
Example
,
err
error
)
{
obj
,
err
:=
c
.
Fake
.
Invokes
(
testing
.
NewGetAction
(
examplesResource
,
c
.
ns
,
name
),
&
cr_v1
.
Example
{})
if
obj
==
nil
{
return
nil
,
err
}
return
obj
.
(
*
cr_v1
.
Example
),
err
}
// List takes label and field selectors, and returns the list of Examples that match those selectors.
func
(
c
*
FakeExamples
)
List
(
opts
v1
.
ListOptions
)
(
result
*
cr_v1
.
ExampleList
,
err
error
)
{
obj
,
err
:=
c
.
Fake
.
Invokes
(
testing
.
NewListAction
(
examplesResource
,
examplesKind
,
c
.
ns
,
opts
),
&
cr_v1
.
ExampleList
{})
if
obj
==
nil
{
return
nil
,
err
}
label
,
_
,
_
:=
testing
.
ExtractFromListOptions
(
opts
)
if
label
==
nil
{
label
=
labels
.
Everything
()
}
list
:=
&
cr_v1
.
ExampleList
{}
for
_
,
item
:=
range
obj
.
(
*
cr_v1
.
ExampleList
)
.
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 examples.
func
(
c
*
FakeExamples
)
Watch
(
opts
v1
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
Fake
.
InvokesWatch
(
testing
.
NewWatchAction
(
examplesResource
,
c
.
ns
,
opts
))
}
// Create takes the representation of a example and creates it. Returns the server's representation of the example, and an error, if there is any.
func
(
c
*
FakeExamples
)
Create
(
example
*
cr_v1
.
Example
)
(
result
*
cr_v1
.
Example
,
err
error
)
{
obj
,
err
:=
c
.
Fake
.
Invokes
(
testing
.
NewCreateAction
(
examplesResource
,
c
.
ns
,
example
),
&
cr_v1
.
Example
{})
if
obj
==
nil
{
return
nil
,
err
}
return
obj
.
(
*
cr_v1
.
Example
),
err
}
// Update takes the representation of a example and updates it. Returns the server's representation of the example, and an error, if there is any.
func
(
c
*
FakeExamples
)
Update
(
example
*
cr_v1
.
Example
)
(
result
*
cr_v1
.
Example
,
err
error
)
{
obj
,
err
:=
c
.
Fake
.
Invokes
(
testing
.
NewUpdateAction
(
examplesResource
,
c
.
ns
,
example
),
&
cr_v1
.
Example
{})
if
obj
==
nil
{
return
nil
,
err
}
return
obj
.
(
*
cr_v1
.
Example
),
err
}
// Delete takes name of the example and deletes it. Returns an error if one occurs.
func
(
c
*
FakeExamples
)
Delete
(
name
string
,
options
*
v1
.
DeleteOptions
)
error
{
_
,
err
:=
c
.
Fake
.
Invokes
(
testing
.
NewDeleteAction
(
examplesResource
,
c
.
ns
,
name
),
&
cr_v1
.
Example
{})
return
err
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
FakeExamples
)
DeleteCollection
(
options
*
v1
.
DeleteOptions
,
listOptions
v1
.
ListOptions
)
error
{
action
:=
testing
.
NewDeleteCollectionAction
(
examplesResource
,
c
.
ns
,
listOptions
)
_
,
err
:=
c
.
Fake
.
Invokes
(
action
,
&
cr_v1
.
ExampleList
{})
return
err
}
// Patch applies the patch and returns the patched example.
func
(
c
*
FakeExamples
)
Patch
(
name
string
,
pt
types
.
PatchType
,
data
[]
byte
,
subresources
...
string
)
(
result
*
cr_v1
.
Example
,
err
error
)
{
obj
,
err
:=
c
.
Fake
.
Invokes
(
testing
.
NewPatchSubresourceAction
(
examplesResource
,
c
.
ns
,
name
,
data
,
subresources
...
),
&
cr_v1
.
Example
{})
if
obj
==
nil
{
return
nil
,
err
}
return
obj
.
(
*
cr_v1
.
Example
),
err
}
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/generated_expansion.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package
v1
type
ExampleExpansion
interface
{}
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/BUILD
0 → 100644
View file @
019583ad
load("@io_bazel_rules_go//go:def.bzl", "go_library")
go_library(
name = "go_default_library",
srcs = [
"factory.go",
"generic.go",
],
importpath = "k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions",
visibility = ["//visibility:public"],
deps = [
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/apis/cr/v1:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/cr:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/internalinterfaces:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/runtime:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/runtime/schema:go_default_library",
"//vendor/k8s.io/client-go/tools/cache: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/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/cr:all-srcs",
"//staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/internalinterfaces:all-srcs",
],
tags = ["automanaged"],
visibility = ["//visibility:public"],
)
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/cr/BUILD
0 → 100644
View file @
019583ad
load("@io_bazel_rules_go//go:def.bzl", "go_library")
go_library(
name = "go_default_library",
srcs = ["interface.go"],
importpath = "k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/cr",
visibility = ["//visibility:public"],
deps = [
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/cr/v1:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/internalinterfaces: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/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/cr/v1:all-srcs",
],
tags = ["automanaged"],
visibility = ["//visibility:public"],
)
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/cr/interface.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
// This file was automatically generated by informer-gen
package
cr
import
(
v1
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/cr/v1"
internalinterfaces
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/internalinterfaces"
)
// Interface provides access to each of this group's versions.
type
Interface
interface
{
// V1 provides access to shared informers for resources in V1.
V1
()
v1
.
Interface
}
type
group
struct
{
internalinterfaces
.
SharedInformerFactory
}
// New returns a new Interface.
func
New
(
f
internalinterfaces
.
SharedInformerFactory
)
Interface
{
return
&
group
{
f
}
}
// V1 returns a new v1.Interface.
func
(
g
*
group
)
V1
()
v1
.
Interface
{
return
v1
.
New
(
g
.
SharedInformerFactory
)
}
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/cr/v1/BUILD
0 → 100644
View file @
019583ad
load("@io_bazel_rules_go//go:def.bzl", "go_library")
go_library(
name = "go_default_library",
srcs = [
"example.go",
"interface.go",
],
importpath = "k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/cr/v1",
visibility = ["//visibility:public"],
deps = [
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/apis/cr/v1:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/internalinterfaces:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/listers/cr/v1:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/runtime:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/watch:go_default_library",
"//vendor/k8s.io/client-go/tools/cache: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/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/cr/v1/example.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
// This file was automatically generated by informer-gen
package
v1
import
(
cr_v1
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/apis/cr/v1"
versioned
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned"
internalinterfaces
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/internalinterfaces"
v1
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/listers/cr/v1"
meta_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"
time
"time"
)
// ExampleInformer provides access to a shared informer and lister for
// Examples.
type
ExampleInformer
interface
{
Informer
()
cache
.
SharedIndexInformer
Lister
()
v1
.
ExampleLister
}
type
exampleInformer
struct
{
factory
internalinterfaces
.
SharedInformerFactory
}
// NewExampleInformer constructs a new informer for Example 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
NewExampleInformer
(
client
versioned
.
Interface
,
namespace
string
,
resyncPeriod
time
.
Duration
,
indexers
cache
.
Indexers
)
cache
.
SharedIndexInformer
{
return
cache
.
NewSharedIndexInformer
(
&
cache
.
ListWatch
{
ListFunc
:
func
(
options
meta_v1
.
ListOptions
)
(
runtime
.
Object
,
error
)
{
return
client
.
CrV1
()
.
Examples
(
namespace
)
.
List
(
options
)
},
WatchFunc
:
func
(
options
meta_v1
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
client
.
CrV1
()
.
Examples
(
namespace
)
.
Watch
(
options
)
},
},
&
cr_v1
.
Example
{},
resyncPeriod
,
indexers
,
)
}
func
defaultExampleInformer
(
client
versioned
.
Interface
,
resyncPeriod
time
.
Duration
)
cache
.
SharedIndexInformer
{
return
NewExampleInformer
(
client
,
meta_v1
.
NamespaceAll
,
resyncPeriod
,
cache
.
Indexers
{
cache
.
NamespaceIndex
:
cache
.
MetaNamespaceIndexFunc
})
}
func
(
f
*
exampleInformer
)
Informer
()
cache
.
SharedIndexInformer
{
return
f
.
factory
.
InformerFor
(
&
cr_v1
.
Example
{},
defaultExampleInformer
)
}
func
(
f
*
exampleInformer
)
Lister
()
v1
.
ExampleLister
{
return
v1
.
NewExampleLister
(
f
.
Informer
()
.
GetIndexer
())
}
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/cr/v1/interface.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
// This file was automatically generated by informer-gen
package
v1
import
(
internalinterfaces
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/internalinterfaces"
)
// Interface provides access to all the informers in this group version.
type
Interface
interface
{
// Examples returns a ExampleInformer.
Examples
()
ExampleInformer
}
type
version
struct
{
internalinterfaces
.
SharedInformerFactory
}
// New returns a new Interface.
func
New
(
f
internalinterfaces
.
SharedInformerFactory
)
Interface
{
return
&
version
{
f
}
}
// Examples returns a ExampleInformer.
func
(
v
*
version
)
Examples
()
ExampleInformer
{
return
&
exampleInformer
{
factory
:
v
.
SharedInformerFactory
}
}
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/factory.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
// This file was automatically generated by informer-gen
package
externalversions
import
(
versioned
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned"
cr
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/cr"
internalinterfaces
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/internalinterfaces"
runtime
"k8s.io/apimachinery/pkg/runtime"
schema
"k8s.io/apimachinery/pkg/runtime/schema"
cache
"k8s.io/client-go/tools/cache"
reflect
"reflect"
sync
"sync"
time
"time"
)
type
sharedInformerFactory
struct
{
client
versioned
.
Interface
lock
sync
.
Mutex
defaultResync
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
}
// NewSharedInformerFactory constructs a new instance of sharedInformerFactory
func
NewSharedInformerFactory
(
client
versioned
.
Interface
,
defaultResync
time
.
Duration
)
SharedInformerFactory
{
return
&
sharedInformerFactory
{
client
:
client
,
defaultResync
:
defaultResync
,
informers
:
make
(
map
[
reflect
.
Type
]
cache
.
SharedIndexInformer
),
startedInformers
:
make
(
map
[
reflect
.
Type
]
bool
),
}
}
// 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
}
informer
=
newFunc
(
f
.
client
,
f
.
defaultResync
)
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
Cr
()
cr
.
Interface
}
func
(
f
*
sharedInformerFactory
)
Cr
()
cr
.
Interface
{
return
cr
.
New
(
f
)
}
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/generic.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
// This file was automatically generated by informer-gen
package
externalversions
import
(
"fmt"
v1
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/apis/cr/v1"
schema
"k8s.io/apimachinery/pkg/runtime/schema"
cache
"k8s.io/client-go/tools/cache"
)
// 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=Cr, Version=V1
case
v1
.
SchemeGroupVersion
.
WithResource
(
"examples"
)
:
return
&
genericInformer
{
resource
:
resource
.
GroupResource
(),
informer
:
f
.
Cr
()
.
V1
()
.
Examples
()
.
Informer
()},
nil
}
return
nil
,
fmt
.
Errorf
(
"no informer found for %v"
,
resource
)
}
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/internalinterfaces/BUILD
0 → 100644
View file @
019583ad
load("@io_bazel_rules_go//go:def.bzl", "go_library")
go_library(
name = "go_default_library",
srcs = ["factory_interfaces.go"],
importpath = "k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/internalinterfaces",
visibility = ["//visibility:public"],
deps = [
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/runtime:go_default_library",
"//vendor/k8s.io/client-go/tools/cache: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/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/internalinterfaces/factory_interfaces.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
// This file was automatically generated by informer-gen
package
internalinterfaces
import
(
versioned
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned"
runtime
"k8s.io/apimachinery/pkg/runtime"
cache
"k8s.io/client-go/tools/cache"
time
"time"
)
type
NewInformerFunc
func
(
versioned
.
Interface
,
time
.
Duration
)
cache
.
SharedIndexInformer
// SharedInformerFactory a small interface to allow for adding an informer without an import cycle
type
SharedInformerFactory
interface
{
Start
(
stopCh
<-
chan
struct
{})
InformerFor
(
obj
runtime
.
Object
,
newFunc
NewInformerFunc
)
cache
.
SharedIndexInformer
}
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/listers/cr/v1/BUILD
0 → 100644
View file @
019583ad
load("@io_bazel_rules_go//go:def.bzl", "go_library")
go_library(
name = "go_default_library",
srcs = [
"example.go",
"expansion_generated.go",
],
importpath = "k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/listers/cr/v1",
visibility = ["//visibility:public"],
deps = [
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/pkg/apis/cr/v1:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/api/errors:go_default_library",
"//vendor/k8s.io/apimachinery/pkg/labels:go_default_library",
"//vendor/k8s.io/client-go/tools/cache: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/apiextensions-apiserver/examples/client-go/pkg/client/listers/cr/v1/example.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
// This file was automatically generated by lister-gen
package
v1
import
(
v1
"k8s.io/apiextensions-apiserver/examples/client-go/pkg/apis/cr/v1"
"k8s.io/apimachinery/pkg/api/errors"
"k8s.io/apimachinery/pkg/labels"
"k8s.io/client-go/tools/cache"
)
// ExampleLister helps list Examples.
type
ExampleLister
interface
{
// List lists all Examples in the indexer.
List
(
selector
labels
.
Selector
)
(
ret
[]
*
v1
.
Example
,
err
error
)
// Examples returns an object that can list and get Examples.
Examples
(
namespace
string
)
ExampleNamespaceLister
ExampleListerExpansion
}
// exampleLister implements the ExampleLister interface.
type
exampleLister
struct
{
indexer
cache
.
Indexer
}
// NewExampleLister returns a new ExampleLister.
func
NewExampleLister
(
indexer
cache
.
Indexer
)
ExampleLister
{
return
&
exampleLister
{
indexer
:
indexer
}
}
// List lists all Examples in the indexer.
func
(
s
*
exampleLister
)
List
(
selector
labels
.
Selector
)
(
ret
[]
*
v1
.
Example
,
err
error
)
{
err
=
cache
.
ListAll
(
s
.
indexer
,
selector
,
func
(
m
interface
{})
{
ret
=
append
(
ret
,
m
.
(
*
v1
.
Example
))
})
return
ret
,
err
}
// Examples returns an object that can list and get Examples.
func
(
s
*
exampleLister
)
Examples
(
namespace
string
)
ExampleNamespaceLister
{
return
exampleNamespaceLister
{
indexer
:
s
.
indexer
,
namespace
:
namespace
}
}
// ExampleNamespaceLister helps list and get Examples.
type
ExampleNamespaceLister
interface
{
// List lists all Examples in the indexer for a given namespace.
List
(
selector
labels
.
Selector
)
(
ret
[]
*
v1
.
Example
,
err
error
)
// Get retrieves the Example from the indexer for a given namespace and name.
Get
(
name
string
)
(
*
v1
.
Example
,
error
)
ExampleNamespaceListerExpansion
}
// exampleNamespaceLister implements the ExampleNamespaceLister
// interface.
type
exampleNamespaceLister
struct
{
indexer
cache
.
Indexer
namespace
string
}
// List lists all Examples in the indexer for a given namespace.
func
(
s
exampleNamespaceLister
)
List
(
selector
labels
.
Selector
)
(
ret
[]
*
v1
.
Example
,
err
error
)
{
err
=
cache
.
ListAllByNamespace
(
s
.
indexer
,
s
.
namespace
,
selector
,
func
(
m
interface
{})
{
ret
=
append
(
ret
,
m
.
(
*
v1
.
Example
))
})
return
ret
,
err
}
// Get retrieves the Example from the indexer for a given namespace and name.
func
(
s
exampleNamespaceLister
)
Get
(
name
string
)
(
*
v1
.
Example
,
error
)
{
obj
,
exists
,
err
:=
s
.
indexer
.
GetByKey
(
s
.
namespace
+
"/"
+
name
)
if
err
!=
nil
{
return
nil
,
err
}
if
!
exists
{
return
nil
,
errors
.
NewNotFound
(
v1
.
Resource
(
"example"
),
name
)
}
return
obj
.
(
*
v1
.
Example
),
nil
}
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/listers/cr/v1/expansion_generated.go
0 → 100644
View file @
019583ad
/*
Copyright 2017 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
// This file was automatically generated by lister-gen
package
v1
// ExampleListerExpansion allows custom methods to be added to
// ExampleLister.
type
ExampleListerExpansion
interface
{}
// ExampleNamespaceListerExpansion allows custom methods to be added to
// ExampleNamespaceLister.
type
ExampleNamespaceListerExpansion
interface
{}
staging/src/k8s.io/apiextensions-apiserver/test/integration/BUILD
View file @
019583ad
...
@@ -9,7 +9,6 @@ go_test(
...
@@ -9,7 +9,6 @@ go_test(
name = "go_default_test",
name = "go_default_test",
srcs = [
srcs = [
"basic_test.go",
"basic_test.go",
"client-go_test.go",
"finalization_test.go",
"finalization_test.go",
"registration_test.go",
"registration_test.go",
"validation_test.go",
"validation_test.go",
...
@@ -19,10 +18,6 @@ go_test(
...
@@ -19,10 +18,6 @@ go_test(
deps = [
deps = [
"//vendor/github.com/coreos/etcd/clientv3:go_default_library",
"//vendor/github.com/coreos/etcd/clientv3:go_default_library",
"//vendor/github.com/stretchr/testify/require:go_default_library",
"//vendor/github.com/stretchr/testify/require:go_default_library",
"//vendor/k8s.io/api/core/v1:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/apis/cr/v1:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/client:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/examples/client-go/controller:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1beta1:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1beta1:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/pkg/apiserver:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/pkg/apiserver:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/test/integration/testserver:go_default_library",
"//vendor/k8s.io/apiextensions-apiserver/test/integration/testserver:go_default_library",
...
...
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