Skip to content

Commit d3db3ce

Browse files
soltyshsoltysh
committed
Staging changes for batch/v1beta1 cronjobs
1 parent 81ba426 commit d3db3ce

32 files changed

+3606
-1
lines changed

‎staging/src/k8s.io/client-go/informers/batch/interface.go

+8
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ package batch
2020

2121
import (
2222
v1 "k8s.io/client-go/informers/batch/v1"
23+
v1beta1 "k8s.io/client-go/informers/batch/v1beta1"
2324
v2alpha1 "k8s.io/client-go/informers/batch/v2alpha1"
2425
internalinterfaces "k8s.io/client-go/informers/internalinterfaces"
2526
)
@@ -28,6 +29,8 @@ import (
2829
type Interface interface {
2930
// V1 provides access to shared informers for resources in V1.
3031
V1() v1.Interface
32+
// V1beta1 provides access to shared informers for resources in V1beta1.
33+
V1beta1() v1beta1.Interface
3134
// V2alpha1 provides access to shared informers for resources in V2alpha1.
3235
V2alpha1() v2alpha1.Interface
3336
}
@@ -46,6 +49,11 @@ func (g *group) V1() v1.Interface {
4649
return v1.New(g.SharedInformerFactory)
4750
}
4851

52+
// V1beta1 returns a new v1beta1.Interface.
53+
func (g *group) V1beta1() v1beta1.Interface {
54+
return v1beta1.New(g.SharedInformerFactory)
55+
}
56+
4957
// V2alpha1 returns a new v2alpha1.Interface.
5058
func (g *group) V2alpha1() v2alpha1.Interface {
5159
return v2alpha1.New(g.SharedInformerFactory)

‎staging/src/k8s.io/client-go/informers/batch/v1beta1/cronjob.go

+68
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,68 @@
1+
/*
2+
Copyright 2017 The Kubernetes Authors.
3+
4+
Licensed under the Apache License, Version 2.0 (the "License");
5+
you may not use this file except in compliance with the License.
6+
You may obtain a copy of the License at
7+
8+
http://www.apache.org/licenses/LICENSE-2.0
9+
10+
Unless required by applicable law or agreed to in writing, software
11+
distributed under the License is distributed on an "AS IS" BASIS,
12+
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
See the License for the specific language governing permissions and
14+
limitations under the License.
15+
*/
16+
17+
// This file was automatically generated by informer-gen
18+
19+
package v1beta1
20+
21+
import (
22+
v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
23+
runtime "k8s.io/apimachinery/pkg/runtime"
24+
watch "k8s.io/apimachinery/pkg/watch"
25+
internalinterfaces "k8s.io/client-go/informers/internalinterfaces"
26+
kubernetes "k8s.io/client-go/kubernetes"
27+
v1beta1 "k8s.io/client-go/listers/batch/v1beta1"
28+
batch_v1beta1 "k8s.io/client-go/pkg/apis/batch/v1beta1"
29+
cache "k8s.io/client-go/tools/cache"
30+
time "time"
31+
)
32+
33+
// CronJobInformer provides access to a shared informer and lister for
34+
// CronJobs.
35+
type CronJobInformer interface {
36+
Informer() cache.SharedIndexInformer
37+
Lister() v1beta1.CronJobLister
38+
}
39+
40+
type cronJobInformer struct {
41+
factory internalinterfaces.SharedInformerFactory
42+
}
43+
44+
func newCronJobInformer(client kubernetes.Interface, resyncPeriod time.Duration) cache.SharedIndexInformer {
45+
sharedIndexInformer := cache.NewSharedIndexInformer(
46+
&cache.ListWatch{
47+
ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
48+
return client.BatchV1beta1().CronJobs(v1.NamespaceAll).List(options)
49+
},
50+
WatchFunc: func(options v1.ListOptions) (watch.Interface, error) {
51+
return client.BatchV1beta1().CronJobs(v1.NamespaceAll).Watch(options)
52+
},
53+
},
54+
&batch_v1beta1.CronJob{},
55+
resyncPeriod,
56+
cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc},
57+
)
58+
59+
return sharedIndexInformer
60+
}
61+
62+
func (f *cronJobInformer) Informer() cache.SharedIndexInformer {
63+
return f.factory.InformerFor(&batch_v1beta1.CronJob{}, newCronJobInformer)
64+
}
65+
66+
func (f *cronJobInformer) Lister() v1beta1.CronJobLister {
67+
return v1beta1.NewCronJobLister(f.Informer().GetIndexer())
68+
}

‎staging/src/k8s.io/client-go/informers/batch/v1beta1/interface.go

+43
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,43 @@
1+
/*
2+
Copyright 2017 The Kubernetes Authors.
3+
4+
Licensed under the Apache License, Version 2.0 (the "License");
5+
you may not use this file except in compliance with the License.
6+
You may obtain a copy of the License at
7+
8+
http://www.apache.org/licenses/LICENSE-2.0
9+
10+
Unless required by applicable law or agreed to in writing, software
11+
distributed under the License is distributed on an "AS IS" BASIS,
12+
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
See the License for the specific language governing permissions and
14+
limitations under the License.
15+
*/
16+
17+
// This file was automatically generated by informer-gen
18+
19+
package v1beta1
20+
21+
import (
22+
internalinterfaces "k8s.io/client-go/informers/internalinterfaces"
23+
)
24+
25+
// Interface provides access to all the informers in this group version.
26+
type Interface interface {
27+
// CronJobs returns a CronJobInformer.
28+
CronJobs() CronJobInformer
29+
}
30+
31+
type version struct {
32+
internalinterfaces.SharedInformerFactory
33+
}
34+
35+
// New returns a new Interface.
36+
func New(f internalinterfaces.SharedInformerFactory) Interface {
37+
return &version{f}
38+
}
39+
40+
// CronJobs returns a CronJobInformer.
41+
func (v *version) CronJobs() CronJobInformer {
42+
return &cronJobInformer{factory: v.SharedInformerFactory}
43+
}

‎staging/src/k8s.io/client-go/informers/generic.go

+5
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@ import (
2626
v1 "k8s.io/client-go/pkg/apis/autoscaling/v1"
2727
v2alpha1 "k8s.io/client-go/pkg/apis/autoscaling/v2alpha1"
2828
batch_v1 "k8s.io/client-go/pkg/apis/batch/v1"
29+
batch_v1beta1 "k8s.io/client-go/pkg/apis/batch/v1beta1"
2930
batch_v2alpha1 "k8s.io/client-go/pkg/apis/batch/v2alpha1"
3031
certificates_v1beta1 "k8s.io/client-go/pkg/apis/certificates/v1beta1"
3132
extensions_v1beta1 "k8s.io/client-go/pkg/apis/extensions/v1beta1"
@@ -80,6 +81,10 @@ func (f *sharedInformerFactory) ForResource(resource schema.GroupVersionResource
8081
case batch_v1.SchemeGroupVersion.WithResource("jobs"):
8182
return &genericInformer{resource: resource.GroupResource(), informer: f.Batch().V1().Jobs().Informer()}, nil
8283

84+
// Group=Batch, Version=V1beta1
85+
case batch_v1beta1.SchemeGroupVersion.WithResource("cronjobs"):
86+
return &genericInformer{resource: resource.GroupResource(), informer: f.Batch().V1beta1().CronJobs().Informer()}, nil
87+
8388
// Group=Batch, Version=V2alpha1
8489
case batch_v2alpha1.SchemeGroupVersion.WithResource("cronjobs"):
8590
return &genericInformer{resource: resource.GroupResource(), informer: f.Batch().V2alpha1().CronJobs().Informer()}, nil

‎staging/src/k8s.io/client-go/kubernetes/clientset.go

+17
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@ import (
2727
autoscalingv1 "k8s.io/client-go/kubernetes/typed/autoscaling/v1"
2828
autoscalingv2alpha1 "k8s.io/client-go/kubernetes/typed/autoscaling/v2alpha1"
2929
batchv1 "k8s.io/client-go/kubernetes/typed/batch/v1"
30+
batchv1beta1 "k8s.io/client-go/kubernetes/typed/batch/v1beta1"
3031
batchv2alpha1 "k8s.io/client-go/kubernetes/typed/batch/v2alpha1"
3132
certificatesv1beta1 "k8s.io/client-go/kubernetes/typed/certificates/v1beta1"
3233
corev1 "k8s.io/client-go/kubernetes/typed/core/v1"
@@ -62,6 +63,7 @@ type Interface interface {
6263
BatchV1() batchv1.BatchV1Interface
6364
// Deprecated: please explicitly pick a version if possible.
6465
Batch() batchv1.BatchV1Interface
66+
BatchV1beta1() batchv1beta1.BatchV1beta1Interface
6567
BatchV2alpha1() batchv2alpha1.BatchV2alpha1Interface
6668
CertificatesV1beta1() certificatesv1beta1.CertificatesV1beta1Interface
6769
// Deprecated: please explicitly pick a version if possible.
@@ -94,6 +96,7 @@ type Clientset struct {
9496
*autoscalingv1.AutoscalingV1Client
9597
*autoscalingv2alpha1.AutoscalingV2alpha1Client
9698
*batchv1.BatchV1Client
99+
*batchv1beta1.BatchV1beta1Client
97100
*batchv2alpha1.BatchV2alpha1Client
98101
*certificatesv1beta1.CertificatesV1beta1Client
99102
*extensionsv1beta1.ExtensionsV1beta1Client
@@ -229,6 +232,14 @@ func (c *Clientset) Batch() batchv1.BatchV1Interface {
229232
return c.BatchV1Client
230233
}
231234

235+
// BatchV1beta1 retrieves the BatchV1beta1Client
236+
func (c *Clientset) BatchV1beta1() batchv1beta1.BatchV1beta1Interface {
237+
if c == nil {
238+
return nil
239+
}
240+
return c.BatchV1beta1Client
241+
}
242+
232243
// BatchV2alpha1 retrieves the BatchV2alpha1Client
233244
func (c *Clientset) BatchV2alpha1() batchv2alpha1.BatchV2alpha1Interface {
234245
if c == nil {
@@ -382,6 +393,10 @@ func NewForConfig(c *rest.Config) (*Clientset, error) {
382393
if err != nil {
383394
return nil, err
384395
}
396+
cs.BatchV1beta1Client, err = batchv1beta1.NewForConfig(&configShallowCopy)
397+
if err != nil {
398+
return nil, err
399+
}
385400
cs.BatchV2alpha1Client, err = batchv2alpha1.NewForConfig(&configShallowCopy)
386401
if err != nil {
387402
return nil, err
@@ -432,6 +447,7 @@ func NewForConfigOrDie(c *rest.Config) *Clientset {
432447
cs.AutoscalingV1Client = autoscalingv1.NewForConfigOrDie(c)
433448
cs.AutoscalingV2alpha1Client = autoscalingv2alpha1.NewForConfigOrDie(c)
434449
cs.BatchV1Client = batchv1.NewForConfigOrDie(c)
450+
cs.BatchV1beta1Client = batchv1beta1.NewForConfigOrDie(c)
435451
cs.BatchV2alpha1Client = batchv2alpha1.NewForConfigOrDie(c)
436452
cs.CertificatesV1beta1Client = certificatesv1beta1.NewForConfigOrDie(c)
437453
cs.ExtensionsV1beta1Client = extensionsv1beta1.NewForConfigOrDie(c)
@@ -456,6 +472,7 @@ func New(c rest.Interface) *Clientset {
456472
cs.AutoscalingV1Client = autoscalingv1.New(c)
457473
cs.AutoscalingV2alpha1Client = autoscalingv2alpha1.New(c)
458474
cs.BatchV1Client = batchv1.New(c)
475+
cs.BatchV1beta1Client = batchv1beta1.New(c)
459476
cs.BatchV2alpha1Client = batchv2alpha1.New(c)
460477
cs.CertificatesV1beta1Client = certificatesv1beta1.New(c)
461478
cs.ExtensionsV1beta1Client = extensionsv1beta1.New(c)

‎staging/src/k8s.io/client-go/kubernetes/fake/clientset_generated.go

+7
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,8 @@ import (
3838
fakeautoscalingv2alpha1 "k8s.io/client-go/kubernetes/typed/autoscaling/v2alpha1/fake"
3939
batchv1 "k8s.io/client-go/kubernetes/typed/batch/v1"
4040
fakebatchv1 "k8s.io/client-go/kubernetes/typed/batch/v1/fake"
41+
batchv1beta1 "k8s.io/client-go/kubernetes/typed/batch/v1beta1"
42+
fakebatchv1beta1 "k8s.io/client-go/kubernetes/typed/batch/v1beta1/fake"
4143
batchv2alpha1 "k8s.io/client-go/kubernetes/typed/batch/v2alpha1"
4244
fakebatchv2alpha1 "k8s.io/client-go/kubernetes/typed/batch/v2alpha1/fake"
4345
certificatesv1beta1 "k8s.io/client-go/kubernetes/typed/certificates/v1beta1"
@@ -165,6 +167,11 @@ func (c *Clientset) Batch() batchv1.BatchV1Interface {
165167
return &fakebatchv1.FakeBatchV1{Fake: &c.Fake}
166168
}
167169

170+
// BatchV1beta1 retrieves the BatchV1beta1Client
171+
func (c *Clientset) BatchV1beta1() batchv1beta1.BatchV1beta1Interface {
172+
return &fakebatchv1beta1.FakeBatchV1beta1{Fake: &c.Fake}
173+
}
174+
168175
// BatchV2alpha1 retrieves the BatchV2alpha1Client
169176
func (c *Clientset) BatchV2alpha1() batchv2alpha1.BatchV2alpha1Interface {
170177
return &fakebatchv2alpha1.FakeBatchV2alpha1{Fake: &c.Fake}

‎staging/src/k8s.io/client-go/kubernetes/scheme/register.go

+2
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@ import (
3030
autoscalingv1 "k8s.io/client-go/pkg/apis/autoscaling/v1"
3131
autoscalingv2alpha1 "k8s.io/client-go/pkg/apis/autoscaling/v2alpha1"
3232
batchv1 "k8s.io/client-go/pkg/apis/batch/v1"
33+
batchv1beta1 "k8s.io/client-go/pkg/apis/batch/v1beta1"
3334
batchv2alpha1 "k8s.io/client-go/pkg/apis/batch/v2alpha1"
3435
certificatesv1beta1 "k8s.io/client-go/pkg/apis/certificates/v1beta1"
3536
extensionsv1beta1 "k8s.io/client-go/pkg/apis/extensions/v1beta1"
@@ -72,6 +73,7 @@ func AddToScheme(scheme *runtime.Scheme) {
7273
autoscalingv1.AddToScheme(scheme)
7374
autoscalingv2alpha1.AddToScheme(scheme)
7475
batchv1.AddToScheme(scheme)
76+
batchv1beta1.AddToScheme(scheme)
7577
batchv2alpha1.AddToScheme(scheme)
7678
certificatesv1beta1.AddToScheme(scheme)
7779
extensionsv1beta1.AddToScheme(scheme)

‎staging/src/k8s.io/client-go/kubernetes/typed/batch/v1beta1/batch_client.go

+88
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,88 @@
1+
/*
2+
Copyright 2017 The Kubernetes Authors.
3+
4+
Licensed under the Apache License, Version 2.0 (the "License");
5+
you may not use this file except in compliance with the License.
6+
You may obtain a copy of the License at
7+
8+
http://www.apache.org/licenses/LICENSE-2.0
9+
10+
Unless required by applicable law or agreed to in writing, software
11+
distributed under the License is distributed on an "AS IS" BASIS,
12+
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
See the License for the specific language governing permissions and
14+
limitations under the License.
15+
*/
16+
17+
package v1beta1
18+
19+
import (
20+
serializer "k8s.io/apimachinery/pkg/runtime/serializer"
21+
"k8s.io/client-go/kubernetes/scheme"
22+
v1beta1 "k8s.io/client-go/pkg/apis/batch/v1beta1"
23+
rest "k8s.io/client-go/rest"
24+
)
25+
26+
type BatchV1beta1Interface interface {
27+
RESTClient() rest.Interface
28+
CronJobsGetter
29+
}
30+
31+
// BatchV1beta1Client is used to interact with features provided by the batch group.
32+
type BatchV1beta1Client struct {
33+
restClient rest.Interface
34+
}
35+
36+
func (c *BatchV1beta1Client) CronJobs(namespace string) CronJobInterface {
37+
return newCronJobs(c, namespace)
38+
}
39+
40+
// NewForConfig creates a new BatchV1beta1Client for the given config.
41+
func NewForConfig(c *rest.Config) (*BatchV1beta1Client, error) {
42+
config := *c
43+
if err := setConfigDefaults(&config); err != nil {
44+
return nil, err
45+
}
46+
client, err := rest.RESTClientFor(&config)
47+
if err != nil {
48+
return nil, err
49+
}
50+
return &BatchV1beta1Client{client}, nil
51+
}
52+
53+
// NewForConfigOrDie creates a new BatchV1beta1Client for the given config and
54+
// panics if there is an error in the config.
55+
func NewForConfigOrDie(c *rest.Config) *BatchV1beta1Client {
56+
client, err := NewForConfig(c)
57+
if err != nil {
58+
panic(err)
59+
}
60+
return client
61+
}
62+
63+
// New creates a new BatchV1beta1Client for the given RESTClient.
64+
func New(c rest.Interface) *BatchV1beta1Client {
65+
return &BatchV1beta1Client{c}
66+
}
67+
68+
func setConfigDefaults(config *rest.Config) error {
69+
gv := v1beta1.SchemeGroupVersion
70+
config.GroupVersion = &gv
71+
config.APIPath = "/apis"
72+
config.NegotiatedSerializer = serializer.DirectCodecFactory{CodecFactory: scheme.Codecs}
73+
74+
if config.UserAgent == "" {
75+
config.UserAgent = rest.DefaultKubernetesUserAgent()
76+
}
77+
78+
return nil
79+
}
80+
81+
// RESTClient returns a RESTClient that is used to communicate
82+
// with API server by this client implementation.
83+
func (c *BatchV1beta1Client) RESTClient() rest.Interface {
84+
if c == nil {
85+
return nil
86+
}
87+
return c.restClient
88+
}

0 commit comments

Comments
 (0)