mirror of
				https://github.com/optim-enterprises-bv/kubernetes.git
				synced 2025-11-04 04:08:16 +00:00 
			
		
		
		
	Merge pull request #24826 from caesarxuchao/autogenerate-1-3
Automatic merge from submit-queue Add release_1_3 clientset in update-codegen Add release_1_3 clientset in update-codegen to keep it update-to-date; update the generated clientset.
This commit is contained in:
		@@ -43,11 +43,10 @@ setgen=$(kube::util::find-binary "set-gen")
 | 
				
			|||||||
# update- and verify- scripts.
 | 
					# update- and verify- scripts.
 | 
				
			||||||
${clientgen} "$@"
 | 
					${clientgen} "$@"
 | 
				
			||||||
${clientgen} -t "$@"
 | 
					${clientgen} -t "$@"
 | 
				
			||||||
 | 
					${clientgen} --clientset-name="release_1_3" --input="api/v1,extensions/v1beta1,autoscaling/v1,batch/v1"
 | 
				
			||||||
# Clientgen for federation clientset.
 | 
					# Clientgen for federation clientset.
 | 
				
			||||||
${clientgen} --clientset-name=federation_internalclientset --clientset-path=k8s.io/kubernetes/federation/client/clientset_generated --input="../../federation/apis/federation/","api/" --included-types-overrides="api/Service"   "$@"
 | 
					${clientgen} --clientset-name=federation_internalclientset --clientset-path=k8s.io/kubernetes/federation/client/clientset_generated --input="../../federation/apis/federation/","api/" --included-types-overrides="api/Service"   "$@"
 | 
				
			||||||
${clientgen} --clientset-name=federation_release_1_3 --clientset-path=k8s.io/kubernetes/federation/client/clientset_generated --input="../../federation/apis/federation/v1alpha1","api/v1" --included-types-overrides="api/v1/Service"   "$@"
 | 
					${clientgen} --clientset-name=federation_release_1_3 --clientset-path=k8s.io/kubernetes/federation/client/clientset_generated --input="../../federation/apis/federation/v1alpha1","api/v1" --included-types-overrides="api/v1/Service"   "$@"
 | 
				
			||||||
 | 
					 | 
				
			||||||
${conversiongen} "$@"
 | 
					${conversiongen} "$@"
 | 
				
			||||||
${deepcopygen} "$@"
 | 
					${deepcopygen} "$@"
 | 
				
			||||||
${setgen} "$@"
 | 
					${setgen} "$@"
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -65,6 +65,8 @@ type HorizontalPodAutoscalerStatus struct {
 | 
				
			|||||||
	CurrentCPUUtilizationPercentage *int32 `json:"currentCPUUtilizationPercentage,omitempty" protobuf:"varint,5,opt,name=currentCPUUtilizationPercentage"`
 | 
						CurrentCPUUtilizationPercentage *int32 `json:"currentCPUUtilizationPercentage,omitempty" protobuf:"varint,5,opt,name=currentCPUUtilizationPercentage"`
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// +genclient=true
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// configuration of a horizontal pod autoscaler.
 | 
					// configuration of a horizontal pod autoscaler.
 | 
				
			||||||
type HorizontalPodAutoscaler struct {
 | 
					type HorizontalPodAutoscaler struct {
 | 
				
			||||||
	unversioned.TypeMeta `json:",inline"`
 | 
						unversioned.TypeMeta `json:",inline"`
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -21,6 +21,8 @@ import (
 | 
				
			|||||||
	"k8s.io/kubernetes/pkg/api/v1"
 | 
						"k8s.io/kubernetes/pkg/api/v1"
 | 
				
			||||||
)
 | 
					)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// +genclient=true
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// Job represents the configuration of a single job.
 | 
					// Job represents the configuration of a single job.
 | 
				
			||||||
type Job struct {
 | 
					type Job struct {
 | 
				
			||||||
	unversioned.TypeMeta `json:",inline"`
 | 
						unversioned.TypeMeta `json:",inline"`
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -18,16 +18,21 @@ package release_1_3
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
import (
 | 
					import (
 | 
				
			||||||
	"github.com/golang/glog"
 | 
						"github.com/golang/glog"
 | 
				
			||||||
 | 
						v1autoscaling "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3/typed/autoscaling/v1"
 | 
				
			||||||
 | 
						v1batch "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3/typed/batch/v1"
 | 
				
			||||||
	v1core "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3/typed/core/v1"
 | 
						v1core "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3/typed/core/v1"
 | 
				
			||||||
	v1beta1extensions "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3/typed/extensions/v1beta1"
 | 
						v1beta1extensions "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3/typed/extensions/v1beta1"
 | 
				
			||||||
	restclient "k8s.io/kubernetes/pkg/client/restclient"
 | 
						restclient "k8s.io/kubernetes/pkg/client/restclient"
 | 
				
			||||||
	discovery "k8s.io/kubernetes/pkg/client/typed/discovery"
 | 
						discovery "k8s.io/kubernetes/pkg/client/typed/discovery"
 | 
				
			||||||
 | 
						"k8s.io/kubernetes/pkg/util/flowcontrol"
 | 
				
			||||||
)
 | 
					)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
type Interface interface {
 | 
					type Interface interface {
 | 
				
			||||||
	Discovery() discovery.DiscoveryInterface
 | 
						Discovery() discovery.DiscoveryInterface
 | 
				
			||||||
	Core() v1core.CoreInterface
 | 
						Core() v1core.CoreInterface
 | 
				
			||||||
	Extensions() v1beta1extensions.ExtensionsInterface
 | 
						Extensions() v1beta1extensions.ExtensionsInterface
 | 
				
			||||||
 | 
						Autoscaling() v1autoscaling.AutoscalingInterface
 | 
				
			||||||
 | 
						Batch() v1batch.BatchInterface
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// Clientset contains the clients for groups. Each group has exactly one
 | 
					// Clientset contains the clients for groups. Each group has exactly one
 | 
				
			||||||
@@ -36,18 +41,42 @@ type Clientset struct {
 | 
				
			|||||||
	*discovery.DiscoveryClient
 | 
						*discovery.DiscoveryClient
 | 
				
			||||||
	*v1core.CoreClient
 | 
						*v1core.CoreClient
 | 
				
			||||||
	*v1beta1extensions.ExtensionsClient
 | 
						*v1beta1extensions.ExtensionsClient
 | 
				
			||||||
 | 
						*v1autoscaling.AutoscalingClient
 | 
				
			||||||
 | 
						*v1batch.BatchClient
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// Core retrieves the CoreClient
 | 
					// Core retrieves the CoreClient
 | 
				
			||||||
func (c *Clientset) Core() v1core.CoreInterface {
 | 
					func (c *Clientset) Core() v1core.CoreInterface {
 | 
				
			||||||
 | 
						if c == nil {
 | 
				
			||||||
 | 
							return nil
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
	return c.CoreClient
 | 
						return c.CoreClient
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// Extensions retrieves the ExtensionsClient
 | 
					// Extensions retrieves the ExtensionsClient
 | 
				
			||||||
func (c *Clientset) Extensions() v1beta1extensions.ExtensionsInterface {
 | 
					func (c *Clientset) Extensions() v1beta1extensions.ExtensionsInterface {
 | 
				
			||||||
 | 
						if c == nil {
 | 
				
			||||||
 | 
							return nil
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
	return c.ExtensionsClient
 | 
						return c.ExtensionsClient
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Autoscaling retrieves the AutoscalingClient
 | 
				
			||||||
 | 
					func (c *Clientset) Autoscaling() v1autoscaling.AutoscalingInterface {
 | 
				
			||||||
 | 
						if c == nil {
 | 
				
			||||||
 | 
							return nil
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return c.AutoscalingClient
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Batch retrieves the BatchClient
 | 
				
			||||||
 | 
					func (c *Clientset) Batch() v1batch.BatchInterface {
 | 
				
			||||||
 | 
						if c == nil {
 | 
				
			||||||
 | 
							return nil
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return c.BatchClient
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// Discovery retrieves the DiscoveryClient
 | 
					// Discovery retrieves the DiscoveryClient
 | 
				
			||||||
func (c *Clientset) Discovery() discovery.DiscoveryInterface {
 | 
					func (c *Clientset) Discovery() discovery.DiscoveryInterface {
 | 
				
			||||||
	return c.DiscoveryClient
 | 
						return c.DiscoveryClient
 | 
				
			||||||
@@ -55,18 +84,30 @@ func (c *Clientset) Discovery() discovery.DiscoveryInterface {
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
// NewForConfig creates a new Clientset for the given config.
 | 
					// NewForConfig creates a new Clientset for the given config.
 | 
				
			||||||
func NewForConfig(c *restclient.Config) (*Clientset, error) {
 | 
					func NewForConfig(c *restclient.Config) (*Clientset, error) {
 | 
				
			||||||
 | 
						configShallowCopy := *c
 | 
				
			||||||
 | 
						if configShallowCopy.RateLimiter == nil && configShallowCopy.QPS > 0 {
 | 
				
			||||||
 | 
							configShallowCopy.RateLimiter = flowcontrol.NewTokenBucketRateLimiter(configShallowCopy.QPS, configShallowCopy.Burst)
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
	var clientset Clientset
 | 
						var clientset Clientset
 | 
				
			||||||
	var err error
 | 
						var err error
 | 
				
			||||||
	clientset.CoreClient, err = v1core.NewForConfig(c)
 | 
						clientset.CoreClient, err = v1core.NewForConfig(&configShallowCopy)
 | 
				
			||||||
	if err != nil {
 | 
						if err != nil {
 | 
				
			||||||
		return &clientset, err
 | 
							return &clientset, err
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
	clientset.ExtensionsClient, err = v1beta1extensions.NewForConfig(c)
 | 
						clientset.ExtensionsClient, err = v1beta1extensions.NewForConfig(&configShallowCopy)
 | 
				
			||||||
 | 
						if err != nil {
 | 
				
			||||||
 | 
							return &clientset, err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						clientset.AutoscalingClient, err = v1autoscaling.NewForConfig(&configShallowCopy)
 | 
				
			||||||
 | 
						if err != nil {
 | 
				
			||||||
 | 
							return &clientset, err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						clientset.BatchClient, err = v1batch.NewForConfig(&configShallowCopy)
 | 
				
			||||||
	if err != nil {
 | 
						if err != nil {
 | 
				
			||||||
		return &clientset, err
 | 
							return &clientset, err
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	clientset.DiscoveryClient, err = discovery.NewDiscoveryClientForConfig(c)
 | 
						clientset.DiscoveryClient, err = discovery.NewDiscoveryClientForConfig(&configShallowCopy)
 | 
				
			||||||
	if err != nil {
 | 
						if err != nil {
 | 
				
			||||||
		glog.Errorf("failed to create the DiscoveryClient: %v", err)
 | 
							glog.Errorf("failed to create the DiscoveryClient: %v", err)
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
@@ -79,6 +120,8 @@ func NewForConfigOrDie(c *restclient.Config) *Clientset {
 | 
				
			|||||||
	var clientset Clientset
 | 
						var clientset Clientset
 | 
				
			||||||
	clientset.CoreClient = v1core.NewForConfigOrDie(c)
 | 
						clientset.CoreClient = v1core.NewForConfigOrDie(c)
 | 
				
			||||||
	clientset.ExtensionsClient = v1beta1extensions.NewForConfigOrDie(c)
 | 
						clientset.ExtensionsClient = v1beta1extensions.NewForConfigOrDie(c)
 | 
				
			||||||
 | 
						clientset.AutoscalingClient = v1autoscaling.NewForConfigOrDie(c)
 | 
				
			||||||
 | 
						clientset.BatchClient = v1batch.NewForConfigOrDie(c)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	clientset.DiscoveryClient = discovery.NewDiscoveryClientForConfigOrDie(c)
 | 
						clientset.DiscoveryClient = discovery.NewDiscoveryClientForConfigOrDie(c)
 | 
				
			||||||
	return &clientset
 | 
						return &clientset
 | 
				
			||||||
@@ -89,6 +132,8 @@ func New(c *restclient.RESTClient) *Clientset {
 | 
				
			|||||||
	var clientset Clientset
 | 
						var clientset Clientset
 | 
				
			||||||
	clientset.CoreClient = v1core.New(c)
 | 
						clientset.CoreClient = v1core.New(c)
 | 
				
			||||||
	clientset.ExtensionsClient = v1beta1extensions.New(c)
 | 
						clientset.ExtensionsClient = v1beta1extensions.New(c)
 | 
				
			||||||
 | 
						clientset.AutoscalingClient = v1autoscaling.New(c)
 | 
				
			||||||
 | 
						clientset.BatchClient = v1batch.New(c)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	clientset.DiscoveryClient = discovery.NewDiscoveryClient(c)
 | 
						clientset.DiscoveryClient = discovery.NewDiscoveryClient(c)
 | 
				
			||||||
	return &clientset
 | 
						return &clientset
 | 
				
			||||||
 
 | 
				
			|||||||
							
								
								
									
										20
									
								
								pkg/client/clientset_generated/release_1_3/doc.go
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										20
									
								
								pkg/client/clientset_generated/release_1_3/doc.go
									
									
									
									
									
										Normal file
									
								
							@@ -0,0 +1,20 @@
 | 
				
			|||||||
 | 
					/*
 | 
				
			||||||
 | 
					Copyright 2016 The Kubernetes Authors All rights reserved.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					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 is generated by client-gen with arguments: --clientset-name=release_1_3 --input=[api/v1,extensions/v1beta1,autoscaling/v1,batch/v1]
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// This package has the automatically generated clientset.
 | 
				
			||||||
 | 
					package release_1_3
 | 
				
			||||||
@@ -20,6 +20,10 @@ import (
 | 
				
			|||||||
	"k8s.io/kubernetes/pkg/api"
 | 
						"k8s.io/kubernetes/pkg/api"
 | 
				
			||||||
	"k8s.io/kubernetes/pkg/apimachinery/registered"
 | 
						"k8s.io/kubernetes/pkg/apimachinery/registered"
 | 
				
			||||||
	clientset "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3"
 | 
						clientset "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3"
 | 
				
			||||||
 | 
						v1autoscaling "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3/typed/autoscaling/v1"
 | 
				
			||||||
 | 
						fakev1autoscaling "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3/typed/autoscaling/v1/fake"
 | 
				
			||||||
 | 
						v1batch "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3/typed/batch/v1"
 | 
				
			||||||
 | 
						fakev1batch "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3/typed/batch/v1/fake"
 | 
				
			||||||
	v1core "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3/typed/core/v1"
 | 
						v1core "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3/typed/core/v1"
 | 
				
			||||||
	fakev1core "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3/typed/core/v1/fake"
 | 
						fakev1core "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3/typed/core/v1/fake"
 | 
				
			||||||
	v1beta1extensions "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3/typed/extensions/v1beta1"
 | 
						v1beta1extensions "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3/typed/extensions/v1beta1"
 | 
				
			||||||
@@ -70,3 +74,13 @@ func (c *Clientset) Core() v1core.CoreInterface {
 | 
				
			|||||||
func (c *Clientset) Extensions() v1beta1extensions.ExtensionsInterface {
 | 
					func (c *Clientset) Extensions() v1beta1extensions.ExtensionsInterface {
 | 
				
			||||||
	return &fakev1beta1extensions.FakeExtensions{Fake: &c.Fake}
 | 
						return &fakev1beta1extensions.FakeExtensions{Fake: &c.Fake}
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Autoscaling retrieves the AutoscalingClient
 | 
				
			||||||
 | 
					func (c *Clientset) Autoscaling() v1autoscaling.AutoscalingInterface {
 | 
				
			||||||
 | 
						return &fakev1autoscaling.FakeAutoscaling{Fake: &c.Fake}
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Batch retrieves the BatchClient
 | 
				
			||||||
 | 
					func (c *Clientset) Batch() v1batch.BatchInterface {
 | 
				
			||||||
 | 
						return &fakev1batch.FakeBatch{Fake: &c.Fake}
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 
 | 
				
			|||||||
							
								
								
									
										20
									
								
								pkg/client/clientset_generated/release_1_3/fake/doc.go
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										20
									
								
								pkg/client/clientset_generated/release_1_3/fake/doc.go
									
									
									
									
									
										Normal file
									
								
							@@ -0,0 +1,20 @@
 | 
				
			|||||||
 | 
					/*
 | 
				
			||||||
 | 
					Copyright 2016 The Kubernetes Authors All rights reserved.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					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 is generated by client-gen with arguments: --clientset-name=release_1_3 --input=[api/v1,extensions/v1beta1,autoscaling/v1,batch/v1]
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// This package has the automatically generated fake clientset.
 | 
				
			||||||
 | 
					package fake
 | 
				
			||||||
@@ -0,0 +1,101 @@
 | 
				
			|||||||
 | 
					/*
 | 
				
			||||||
 | 
					Copyright 2016 The Kubernetes Authors All rights reserved.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					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 (
 | 
				
			||||||
 | 
						api "k8s.io/kubernetes/pkg/api"
 | 
				
			||||||
 | 
						registered "k8s.io/kubernetes/pkg/apimachinery/registered"
 | 
				
			||||||
 | 
						restclient "k8s.io/kubernetes/pkg/client/restclient"
 | 
				
			||||||
 | 
					)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					type AutoscalingInterface interface {
 | 
				
			||||||
 | 
						GetRESTClient() *restclient.RESTClient
 | 
				
			||||||
 | 
						HorizontalPodAutoscalersGetter
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// AutoscalingClient is used to interact with features provided by the Autoscaling group.
 | 
				
			||||||
 | 
					type AutoscalingClient struct {
 | 
				
			||||||
 | 
						*restclient.RESTClient
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *AutoscalingClient) HorizontalPodAutoscalers(namespace string) HorizontalPodAutoscalerInterface {
 | 
				
			||||||
 | 
						return newHorizontalPodAutoscalers(c, namespace)
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// NewForConfig creates a new AutoscalingClient for the given config.
 | 
				
			||||||
 | 
					func NewForConfig(c *restclient.Config) (*AutoscalingClient, error) {
 | 
				
			||||||
 | 
						config := *c
 | 
				
			||||||
 | 
						if err := setConfigDefaults(&config); err != nil {
 | 
				
			||||||
 | 
							return nil, err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						client, err := restclient.RESTClientFor(&config)
 | 
				
			||||||
 | 
						if err != nil {
 | 
				
			||||||
 | 
							return nil, err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return &AutoscalingClient{client}, nil
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// NewForConfigOrDie creates a new AutoscalingClient for the given config and
 | 
				
			||||||
 | 
					// panics if there is an error in the config.
 | 
				
			||||||
 | 
					func NewForConfigOrDie(c *restclient.Config) *AutoscalingClient {
 | 
				
			||||||
 | 
						client, err := NewForConfig(c)
 | 
				
			||||||
 | 
						if err != nil {
 | 
				
			||||||
 | 
							panic(err)
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return client
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// New creates a new AutoscalingClient for the given RESTClient.
 | 
				
			||||||
 | 
					func New(c *restclient.RESTClient) *AutoscalingClient {
 | 
				
			||||||
 | 
						return &AutoscalingClient{c}
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func setConfigDefaults(config *restclient.Config) error {
 | 
				
			||||||
 | 
						// if autoscaling group is not registered, return an error
 | 
				
			||||||
 | 
						g, err := registered.Group("autoscaling")
 | 
				
			||||||
 | 
						if err != nil {
 | 
				
			||||||
 | 
							return err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						config.APIPath = "/apis"
 | 
				
			||||||
 | 
						if config.UserAgent == "" {
 | 
				
			||||||
 | 
							config.UserAgent = restclient.DefaultKubernetesUserAgent()
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						// TODO: Unconditionally set the config.Version, until we fix the config.
 | 
				
			||||||
 | 
						//if config.Version == "" {
 | 
				
			||||||
 | 
						copyGroupVersion := g.GroupVersion
 | 
				
			||||||
 | 
						config.GroupVersion = ©GroupVersion
 | 
				
			||||||
 | 
						//}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						config.NegotiatedSerializer = api.Codecs
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						if config.QPS == 0 {
 | 
				
			||||||
 | 
							config.QPS = 5
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						if config.Burst == 0 {
 | 
				
			||||||
 | 
							config.Burst = 10
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return nil
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// GetRESTClient returns a RESTClient that is used to communicate
 | 
				
			||||||
 | 
					// with API server by this client implementation.
 | 
				
			||||||
 | 
					func (c *AutoscalingClient) GetRESTClient() *restclient.RESTClient {
 | 
				
			||||||
 | 
						if c == nil {
 | 
				
			||||||
 | 
							return nil
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return c.RESTClient
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
@@ -0,0 +1,20 @@
 | 
				
			|||||||
 | 
					/*
 | 
				
			||||||
 | 
					Copyright 2016 The Kubernetes Authors All rights reserved.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					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 is generated by client-gen with arguments: --clientset-name=release_1_3 --input=[api/v1,extensions/v1beta1,autoscaling/v1,batch/v1]
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// This package has the automatically generated typed clients.
 | 
				
			||||||
 | 
					package v1
 | 
				
			||||||
@@ -0,0 +1,20 @@
 | 
				
			|||||||
 | 
					/*
 | 
				
			||||||
 | 
					Copyright 2016 The Kubernetes Authors All rights reserved.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					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 is generated by client-gen with arguments: --clientset-name=release_1_3 --input=[api/v1,extensions/v1beta1,autoscaling/v1,batch/v1]
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Package fake has the automatically generated clients.
 | 
				
			||||||
 | 
					package fake
 | 
				
			||||||
@@ -0,0 +1,37 @@
 | 
				
			|||||||
 | 
					/*
 | 
				
			||||||
 | 
					Copyright 2016 The Kubernetes Authors All rights reserved.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					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/kubernetes/pkg/client/clientset_generated/release_1_3/typed/autoscaling/v1"
 | 
				
			||||||
 | 
						restclient "k8s.io/kubernetes/pkg/client/restclient"
 | 
				
			||||||
 | 
						core "k8s.io/kubernetes/pkg/client/testing/core"
 | 
				
			||||||
 | 
					)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					type FakeAutoscaling struct {
 | 
				
			||||||
 | 
						*core.Fake
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakeAutoscaling) HorizontalPodAutoscalers(namespace string) v1.HorizontalPodAutoscalerInterface {
 | 
				
			||||||
 | 
						return &FakeHorizontalPodAutoscalers{c, namespace}
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// GetRESTClient returns a RESTClient that is used to communicate
 | 
				
			||||||
 | 
					// with API server by this client implementation.
 | 
				
			||||||
 | 
					func (c *FakeAutoscaling) GetRESTClient() *restclient.RESTClient {
 | 
				
			||||||
 | 
						return nil
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
@@ -0,0 +1,116 @@
 | 
				
			|||||||
 | 
					/*
 | 
				
			||||||
 | 
					Copyright 2016 The Kubernetes Authors All rights reserved.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					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 (
 | 
				
			||||||
 | 
						api "k8s.io/kubernetes/pkg/api"
 | 
				
			||||||
 | 
						unversioned "k8s.io/kubernetes/pkg/api/unversioned"
 | 
				
			||||||
 | 
						v1 "k8s.io/kubernetes/pkg/apis/autoscaling/v1"
 | 
				
			||||||
 | 
						core "k8s.io/kubernetes/pkg/client/testing/core"
 | 
				
			||||||
 | 
						labels "k8s.io/kubernetes/pkg/labels"
 | 
				
			||||||
 | 
						watch "k8s.io/kubernetes/pkg/watch"
 | 
				
			||||||
 | 
					)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// FakeHorizontalPodAutoscalers implements HorizontalPodAutoscalerInterface
 | 
				
			||||||
 | 
					type FakeHorizontalPodAutoscalers struct {
 | 
				
			||||||
 | 
						Fake *FakeAutoscaling
 | 
				
			||||||
 | 
						ns   string
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					var horizontalpodautoscalersResource = unversioned.GroupVersionResource{Group: "autoscaling", Version: "v1", Resource: "horizontalpodautoscalers"}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakeHorizontalPodAutoscalers) Create(horizontalPodAutoscaler *v1.HorizontalPodAutoscaler) (result *v1.HorizontalPodAutoscaler, err error) {
 | 
				
			||||||
 | 
						obj, err := c.Fake.
 | 
				
			||||||
 | 
							Invokes(core.NewCreateAction(horizontalpodautoscalersResource, c.ns, horizontalPodAutoscaler), &v1.HorizontalPodAutoscaler{})
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						if obj == nil {
 | 
				
			||||||
 | 
							return nil, err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return obj.(*v1.HorizontalPodAutoscaler), err
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakeHorizontalPodAutoscalers) Update(horizontalPodAutoscaler *v1.HorizontalPodAutoscaler) (result *v1.HorizontalPodAutoscaler, err error) {
 | 
				
			||||||
 | 
						obj, err := c.Fake.
 | 
				
			||||||
 | 
							Invokes(core.NewUpdateAction(horizontalpodautoscalersResource, c.ns, horizontalPodAutoscaler), &v1.HorizontalPodAutoscaler{})
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						if obj == nil {
 | 
				
			||||||
 | 
							return nil, err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return obj.(*v1.HorizontalPodAutoscaler), err
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakeHorizontalPodAutoscalers) UpdateStatus(horizontalPodAutoscaler *v1.HorizontalPodAutoscaler) (*v1.HorizontalPodAutoscaler, error) {
 | 
				
			||||||
 | 
						obj, err := c.Fake.
 | 
				
			||||||
 | 
							Invokes(core.NewUpdateSubresourceAction(horizontalpodautoscalersResource, "status", c.ns, horizontalPodAutoscaler), &v1.HorizontalPodAutoscaler{})
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						if obj == nil {
 | 
				
			||||||
 | 
							return nil, err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return obj.(*v1.HorizontalPodAutoscaler), err
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakeHorizontalPodAutoscalers) Delete(name string, options *api.DeleteOptions) error {
 | 
				
			||||||
 | 
						_, err := c.Fake.
 | 
				
			||||||
 | 
							Invokes(core.NewDeleteAction(horizontalpodautoscalersResource, c.ns, name), &v1.HorizontalPodAutoscaler{})
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						return err
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakeHorizontalPodAutoscalers) DeleteCollection(options *api.DeleteOptions, listOptions api.ListOptions) error {
 | 
				
			||||||
 | 
						action := core.NewDeleteCollectionAction(horizontalpodautoscalersResource, c.ns, listOptions)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						_, err := c.Fake.Invokes(action, &v1.HorizontalPodAutoscalerList{})
 | 
				
			||||||
 | 
						return err
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakeHorizontalPodAutoscalers) Get(name string) (result *v1.HorizontalPodAutoscaler, err error) {
 | 
				
			||||||
 | 
						obj, err := c.Fake.
 | 
				
			||||||
 | 
							Invokes(core.NewGetAction(horizontalpodautoscalersResource, c.ns, name), &v1.HorizontalPodAutoscaler{})
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						if obj == nil {
 | 
				
			||||||
 | 
							return nil, err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return obj.(*v1.HorizontalPodAutoscaler), err
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakeHorizontalPodAutoscalers) List(opts api.ListOptions) (result *v1.HorizontalPodAutoscalerList, err error) {
 | 
				
			||||||
 | 
						obj, err := c.Fake.
 | 
				
			||||||
 | 
							Invokes(core.NewListAction(horizontalpodautoscalersResource, c.ns, opts), &v1.HorizontalPodAutoscalerList{})
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						if obj == nil {
 | 
				
			||||||
 | 
							return nil, err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						label := opts.LabelSelector
 | 
				
			||||||
 | 
						if label == nil {
 | 
				
			||||||
 | 
							label = labels.Everything()
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						list := &v1.HorizontalPodAutoscalerList{}
 | 
				
			||||||
 | 
						for _, item := range obj.(*v1.HorizontalPodAutoscalerList).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 horizontalPodAutoscalers.
 | 
				
			||||||
 | 
					func (c *FakeHorizontalPodAutoscalers) Watch(opts api.ListOptions) (watch.Interface, error) {
 | 
				
			||||||
 | 
						return c.Fake.
 | 
				
			||||||
 | 
							InvokesWatch(core.NewWatchAction(horizontalpodautoscalersResource, c.ns, opts))
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
@@ -0,0 +1,19 @@
 | 
				
			|||||||
 | 
					/*
 | 
				
			||||||
 | 
					Copyright 2016 The Kubernetes Authors All rights reserved.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					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 HorizontalPodAutoscalerExpansion interface{}
 | 
				
			||||||
@@ -0,0 +1,150 @@
 | 
				
			|||||||
 | 
					/*
 | 
				
			||||||
 | 
					Copyright 2016 The Kubernetes Authors All rights reserved.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					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 (
 | 
				
			||||||
 | 
						api "k8s.io/kubernetes/pkg/api"
 | 
				
			||||||
 | 
						v1 "k8s.io/kubernetes/pkg/apis/autoscaling/v1"
 | 
				
			||||||
 | 
						watch "k8s.io/kubernetes/pkg/watch"
 | 
				
			||||||
 | 
					)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// HorizontalPodAutoscalersGetter has a method to return a HorizontalPodAutoscalerInterface.
 | 
				
			||||||
 | 
					// A group's client should implement this interface.
 | 
				
			||||||
 | 
					type HorizontalPodAutoscalersGetter interface {
 | 
				
			||||||
 | 
						HorizontalPodAutoscalers(namespace string) HorizontalPodAutoscalerInterface
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// HorizontalPodAutoscalerInterface has methods to work with HorizontalPodAutoscaler resources.
 | 
				
			||||||
 | 
					type HorizontalPodAutoscalerInterface interface {
 | 
				
			||||||
 | 
						Create(*v1.HorizontalPodAutoscaler) (*v1.HorizontalPodAutoscaler, error)
 | 
				
			||||||
 | 
						Update(*v1.HorizontalPodAutoscaler) (*v1.HorizontalPodAutoscaler, error)
 | 
				
			||||||
 | 
						UpdateStatus(*v1.HorizontalPodAutoscaler) (*v1.HorizontalPodAutoscaler, error)
 | 
				
			||||||
 | 
						Delete(name string, options *api.DeleteOptions) error
 | 
				
			||||||
 | 
						DeleteCollection(options *api.DeleteOptions, listOptions api.ListOptions) error
 | 
				
			||||||
 | 
						Get(name string) (*v1.HorizontalPodAutoscaler, error)
 | 
				
			||||||
 | 
						List(opts api.ListOptions) (*v1.HorizontalPodAutoscalerList, error)
 | 
				
			||||||
 | 
						Watch(opts api.ListOptions) (watch.Interface, error)
 | 
				
			||||||
 | 
						HorizontalPodAutoscalerExpansion
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// horizontalPodAutoscalers implements HorizontalPodAutoscalerInterface
 | 
				
			||||||
 | 
					type horizontalPodAutoscalers struct {
 | 
				
			||||||
 | 
						client *AutoscalingClient
 | 
				
			||||||
 | 
						ns     string
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// newHorizontalPodAutoscalers returns a HorizontalPodAutoscalers
 | 
				
			||||||
 | 
					func newHorizontalPodAutoscalers(c *AutoscalingClient, namespace string) *horizontalPodAutoscalers {
 | 
				
			||||||
 | 
						return &horizontalPodAutoscalers{
 | 
				
			||||||
 | 
							client: c,
 | 
				
			||||||
 | 
							ns:     namespace,
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Create takes the representation of a horizontalPodAutoscaler and creates it.  Returns the server's representation of the horizontalPodAutoscaler, and an error, if there is any.
 | 
				
			||||||
 | 
					func (c *horizontalPodAutoscalers) Create(horizontalPodAutoscaler *v1.HorizontalPodAutoscaler) (result *v1.HorizontalPodAutoscaler, err error) {
 | 
				
			||||||
 | 
						result = &v1.HorizontalPodAutoscaler{}
 | 
				
			||||||
 | 
						err = c.client.Post().
 | 
				
			||||||
 | 
							Namespace(c.ns).
 | 
				
			||||||
 | 
							Resource("horizontalpodautoscalers").
 | 
				
			||||||
 | 
							Body(horizontalPodAutoscaler).
 | 
				
			||||||
 | 
							Do().
 | 
				
			||||||
 | 
							Into(result)
 | 
				
			||||||
 | 
						return
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Update takes the representation of a horizontalPodAutoscaler and updates it. Returns the server's representation of the horizontalPodAutoscaler, and an error, if there is any.
 | 
				
			||||||
 | 
					func (c *horizontalPodAutoscalers) Update(horizontalPodAutoscaler *v1.HorizontalPodAutoscaler) (result *v1.HorizontalPodAutoscaler, err error) {
 | 
				
			||||||
 | 
						result = &v1.HorizontalPodAutoscaler{}
 | 
				
			||||||
 | 
						err = c.client.Put().
 | 
				
			||||||
 | 
							Namespace(c.ns).
 | 
				
			||||||
 | 
							Resource("horizontalpodautoscalers").
 | 
				
			||||||
 | 
							Name(horizontalPodAutoscaler.Name).
 | 
				
			||||||
 | 
							Body(horizontalPodAutoscaler).
 | 
				
			||||||
 | 
							Do().
 | 
				
			||||||
 | 
							Into(result)
 | 
				
			||||||
 | 
						return
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *horizontalPodAutoscalers) UpdateStatus(horizontalPodAutoscaler *v1.HorizontalPodAutoscaler) (result *v1.HorizontalPodAutoscaler, err error) {
 | 
				
			||||||
 | 
						result = &v1.HorizontalPodAutoscaler{}
 | 
				
			||||||
 | 
						err = c.client.Put().
 | 
				
			||||||
 | 
							Namespace(c.ns).
 | 
				
			||||||
 | 
							Resource("horizontalpodautoscalers").
 | 
				
			||||||
 | 
							Name(horizontalPodAutoscaler.Name).
 | 
				
			||||||
 | 
							SubResource("status").
 | 
				
			||||||
 | 
							Body(horizontalPodAutoscaler).
 | 
				
			||||||
 | 
							Do().
 | 
				
			||||||
 | 
							Into(result)
 | 
				
			||||||
 | 
						return
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Delete takes name of the horizontalPodAutoscaler and deletes it. Returns an error if one occurs.
 | 
				
			||||||
 | 
					func (c *horizontalPodAutoscalers) Delete(name string, options *api.DeleteOptions) error {
 | 
				
			||||||
 | 
						return c.client.Delete().
 | 
				
			||||||
 | 
							Namespace(c.ns).
 | 
				
			||||||
 | 
							Resource("horizontalpodautoscalers").
 | 
				
			||||||
 | 
							Name(name).
 | 
				
			||||||
 | 
							Body(options).
 | 
				
			||||||
 | 
							Do().
 | 
				
			||||||
 | 
							Error()
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// DeleteCollection deletes a collection of objects.
 | 
				
			||||||
 | 
					func (c *horizontalPodAutoscalers) DeleteCollection(options *api.DeleteOptions, listOptions api.ListOptions) error {
 | 
				
			||||||
 | 
						return c.client.Delete().
 | 
				
			||||||
 | 
							Namespace(c.ns).
 | 
				
			||||||
 | 
							Resource("horizontalpodautoscalers").
 | 
				
			||||||
 | 
							VersionedParams(&listOptions, api.ParameterCodec).
 | 
				
			||||||
 | 
							Body(options).
 | 
				
			||||||
 | 
							Do().
 | 
				
			||||||
 | 
							Error()
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Get takes name of the horizontalPodAutoscaler, and returns the corresponding horizontalPodAutoscaler object, and an error if there is any.
 | 
				
			||||||
 | 
					func (c *horizontalPodAutoscalers) Get(name string) (result *v1.HorizontalPodAutoscaler, err error) {
 | 
				
			||||||
 | 
						result = &v1.HorizontalPodAutoscaler{}
 | 
				
			||||||
 | 
						err = c.client.Get().
 | 
				
			||||||
 | 
							Namespace(c.ns).
 | 
				
			||||||
 | 
							Resource("horizontalpodautoscalers").
 | 
				
			||||||
 | 
							Name(name).
 | 
				
			||||||
 | 
							Do().
 | 
				
			||||||
 | 
							Into(result)
 | 
				
			||||||
 | 
						return
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// List takes label and field selectors, and returns the list of HorizontalPodAutoscalers that match those selectors.
 | 
				
			||||||
 | 
					func (c *horizontalPodAutoscalers) List(opts api.ListOptions) (result *v1.HorizontalPodAutoscalerList, err error) {
 | 
				
			||||||
 | 
						result = &v1.HorizontalPodAutoscalerList{}
 | 
				
			||||||
 | 
						err = c.client.Get().
 | 
				
			||||||
 | 
							Namespace(c.ns).
 | 
				
			||||||
 | 
							Resource("horizontalpodautoscalers").
 | 
				
			||||||
 | 
							VersionedParams(&opts, api.ParameterCodec).
 | 
				
			||||||
 | 
							Do().
 | 
				
			||||||
 | 
							Into(result)
 | 
				
			||||||
 | 
						return
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Watch returns a watch.Interface that watches the requested horizontalPodAutoscalers.
 | 
				
			||||||
 | 
					func (c *horizontalPodAutoscalers) Watch(opts api.ListOptions) (watch.Interface, error) {
 | 
				
			||||||
 | 
						return c.client.Get().
 | 
				
			||||||
 | 
							Prefix("watch").
 | 
				
			||||||
 | 
							Namespace(c.ns).
 | 
				
			||||||
 | 
							Resource("horizontalpodautoscalers").
 | 
				
			||||||
 | 
							VersionedParams(&opts, api.ParameterCodec).
 | 
				
			||||||
 | 
							Watch()
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
@@ -0,0 +1,101 @@
 | 
				
			|||||||
 | 
					/*
 | 
				
			||||||
 | 
					Copyright 2016 The Kubernetes Authors All rights reserved.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					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 (
 | 
				
			||||||
 | 
						api "k8s.io/kubernetes/pkg/api"
 | 
				
			||||||
 | 
						registered "k8s.io/kubernetes/pkg/apimachinery/registered"
 | 
				
			||||||
 | 
						restclient "k8s.io/kubernetes/pkg/client/restclient"
 | 
				
			||||||
 | 
					)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					type BatchInterface interface {
 | 
				
			||||||
 | 
						GetRESTClient() *restclient.RESTClient
 | 
				
			||||||
 | 
						JobsGetter
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// BatchClient is used to interact with features provided by the Batch group.
 | 
				
			||||||
 | 
					type BatchClient struct {
 | 
				
			||||||
 | 
						*restclient.RESTClient
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *BatchClient) Jobs(namespace string) JobInterface {
 | 
				
			||||||
 | 
						return newJobs(c, namespace)
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// NewForConfig creates a new BatchClient for the given config.
 | 
				
			||||||
 | 
					func NewForConfig(c *restclient.Config) (*BatchClient, error) {
 | 
				
			||||||
 | 
						config := *c
 | 
				
			||||||
 | 
						if err := setConfigDefaults(&config); err != nil {
 | 
				
			||||||
 | 
							return nil, err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						client, err := restclient.RESTClientFor(&config)
 | 
				
			||||||
 | 
						if err != nil {
 | 
				
			||||||
 | 
							return nil, err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return &BatchClient{client}, nil
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// NewForConfigOrDie creates a new BatchClient for the given config and
 | 
				
			||||||
 | 
					// panics if there is an error in the config.
 | 
				
			||||||
 | 
					func NewForConfigOrDie(c *restclient.Config) *BatchClient {
 | 
				
			||||||
 | 
						client, err := NewForConfig(c)
 | 
				
			||||||
 | 
						if err != nil {
 | 
				
			||||||
 | 
							panic(err)
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return client
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// New creates a new BatchClient for the given RESTClient.
 | 
				
			||||||
 | 
					func New(c *restclient.RESTClient) *BatchClient {
 | 
				
			||||||
 | 
						return &BatchClient{c}
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func setConfigDefaults(config *restclient.Config) error {
 | 
				
			||||||
 | 
						// if batch group is not registered, return an error
 | 
				
			||||||
 | 
						g, err := registered.Group("batch")
 | 
				
			||||||
 | 
						if err != nil {
 | 
				
			||||||
 | 
							return err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						config.APIPath = "/apis"
 | 
				
			||||||
 | 
						if config.UserAgent == "" {
 | 
				
			||||||
 | 
							config.UserAgent = restclient.DefaultKubernetesUserAgent()
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						// TODO: Unconditionally set the config.Version, until we fix the config.
 | 
				
			||||||
 | 
						//if config.Version == "" {
 | 
				
			||||||
 | 
						copyGroupVersion := g.GroupVersion
 | 
				
			||||||
 | 
						config.GroupVersion = ©GroupVersion
 | 
				
			||||||
 | 
						//}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						config.NegotiatedSerializer = api.Codecs
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						if config.QPS == 0 {
 | 
				
			||||||
 | 
							config.QPS = 5
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						if config.Burst == 0 {
 | 
				
			||||||
 | 
							config.Burst = 10
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return nil
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// GetRESTClient returns a RESTClient that is used to communicate
 | 
				
			||||||
 | 
					// with API server by this client implementation.
 | 
				
			||||||
 | 
					func (c *BatchClient) GetRESTClient() *restclient.RESTClient {
 | 
				
			||||||
 | 
						if c == nil {
 | 
				
			||||||
 | 
							return nil
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return c.RESTClient
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
@@ -0,0 +1,20 @@
 | 
				
			|||||||
 | 
					/*
 | 
				
			||||||
 | 
					Copyright 2016 The Kubernetes Authors All rights reserved.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					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 is generated by client-gen with arguments: --clientset-name=release_1_3 --input=[api/v1,extensions/v1beta1,autoscaling/v1,batch/v1]
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// This package has the automatically generated typed clients.
 | 
				
			||||||
 | 
					package v1
 | 
				
			||||||
@@ -0,0 +1,20 @@
 | 
				
			|||||||
 | 
					/*
 | 
				
			||||||
 | 
					Copyright 2016 The Kubernetes Authors All rights reserved.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					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 is generated by client-gen with arguments: --clientset-name=release_1_3 --input=[api/v1,extensions/v1beta1,autoscaling/v1,batch/v1]
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Package fake has the automatically generated clients.
 | 
				
			||||||
 | 
					package fake
 | 
				
			||||||
@@ -0,0 +1,37 @@
 | 
				
			|||||||
 | 
					/*
 | 
				
			||||||
 | 
					Copyright 2016 The Kubernetes Authors All rights reserved.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					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/kubernetes/pkg/client/clientset_generated/release_1_3/typed/batch/v1"
 | 
				
			||||||
 | 
						restclient "k8s.io/kubernetes/pkg/client/restclient"
 | 
				
			||||||
 | 
						core "k8s.io/kubernetes/pkg/client/testing/core"
 | 
				
			||||||
 | 
					)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					type FakeBatch struct {
 | 
				
			||||||
 | 
						*core.Fake
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakeBatch) Jobs(namespace string) v1.JobInterface {
 | 
				
			||||||
 | 
						return &FakeJobs{c, namespace}
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// GetRESTClient returns a RESTClient that is used to communicate
 | 
				
			||||||
 | 
					// with API server by this client implementation.
 | 
				
			||||||
 | 
					func (c *FakeBatch) GetRESTClient() *restclient.RESTClient {
 | 
				
			||||||
 | 
						return nil
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
@@ -0,0 +1,116 @@
 | 
				
			|||||||
 | 
					/*
 | 
				
			||||||
 | 
					Copyright 2016 The Kubernetes Authors All rights reserved.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					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 (
 | 
				
			||||||
 | 
						api "k8s.io/kubernetes/pkg/api"
 | 
				
			||||||
 | 
						unversioned "k8s.io/kubernetes/pkg/api/unversioned"
 | 
				
			||||||
 | 
						v1 "k8s.io/kubernetes/pkg/apis/batch/v1"
 | 
				
			||||||
 | 
						core "k8s.io/kubernetes/pkg/client/testing/core"
 | 
				
			||||||
 | 
						labels "k8s.io/kubernetes/pkg/labels"
 | 
				
			||||||
 | 
						watch "k8s.io/kubernetes/pkg/watch"
 | 
				
			||||||
 | 
					)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// FakeJobs implements JobInterface
 | 
				
			||||||
 | 
					type FakeJobs struct {
 | 
				
			||||||
 | 
						Fake *FakeBatch
 | 
				
			||||||
 | 
						ns   string
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					var jobsResource = unversioned.GroupVersionResource{Group: "batch", Version: "v1", Resource: "jobs"}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakeJobs) Create(job *v1.Job) (result *v1.Job, err error) {
 | 
				
			||||||
 | 
						obj, err := c.Fake.
 | 
				
			||||||
 | 
							Invokes(core.NewCreateAction(jobsResource, c.ns, job), &v1.Job{})
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						if obj == nil {
 | 
				
			||||||
 | 
							return nil, err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return obj.(*v1.Job), err
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakeJobs) Update(job *v1.Job) (result *v1.Job, err error) {
 | 
				
			||||||
 | 
						obj, err := c.Fake.
 | 
				
			||||||
 | 
							Invokes(core.NewUpdateAction(jobsResource, c.ns, job), &v1.Job{})
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						if obj == nil {
 | 
				
			||||||
 | 
							return nil, err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return obj.(*v1.Job), err
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakeJobs) UpdateStatus(job *v1.Job) (*v1.Job, error) {
 | 
				
			||||||
 | 
						obj, err := c.Fake.
 | 
				
			||||||
 | 
							Invokes(core.NewUpdateSubresourceAction(jobsResource, "status", c.ns, job), &v1.Job{})
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						if obj == nil {
 | 
				
			||||||
 | 
							return nil, err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return obj.(*v1.Job), err
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakeJobs) Delete(name string, options *api.DeleteOptions) error {
 | 
				
			||||||
 | 
						_, err := c.Fake.
 | 
				
			||||||
 | 
							Invokes(core.NewDeleteAction(jobsResource, c.ns, name), &v1.Job{})
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						return err
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakeJobs) DeleteCollection(options *api.DeleteOptions, listOptions api.ListOptions) error {
 | 
				
			||||||
 | 
						action := core.NewDeleteCollectionAction(jobsResource, c.ns, listOptions)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						_, err := c.Fake.Invokes(action, &v1.JobList{})
 | 
				
			||||||
 | 
						return err
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakeJobs) Get(name string) (result *v1.Job, err error) {
 | 
				
			||||||
 | 
						obj, err := c.Fake.
 | 
				
			||||||
 | 
							Invokes(core.NewGetAction(jobsResource, c.ns, name), &v1.Job{})
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						if obj == nil {
 | 
				
			||||||
 | 
							return nil, err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return obj.(*v1.Job), err
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakeJobs) List(opts api.ListOptions) (result *v1.JobList, err error) {
 | 
				
			||||||
 | 
						obj, err := c.Fake.
 | 
				
			||||||
 | 
							Invokes(core.NewListAction(jobsResource, c.ns, opts), &v1.JobList{})
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						if obj == nil {
 | 
				
			||||||
 | 
							return nil, err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						label := opts.LabelSelector
 | 
				
			||||||
 | 
						if label == nil {
 | 
				
			||||||
 | 
							label = labels.Everything()
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						list := &v1.JobList{}
 | 
				
			||||||
 | 
						for _, item := range obj.(*v1.JobList).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 jobs.
 | 
				
			||||||
 | 
					func (c *FakeJobs) Watch(opts api.ListOptions) (watch.Interface, error) {
 | 
				
			||||||
 | 
						return c.Fake.
 | 
				
			||||||
 | 
							InvokesWatch(core.NewWatchAction(jobsResource, c.ns, opts))
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
@@ -0,0 +1,19 @@
 | 
				
			|||||||
 | 
					/*
 | 
				
			||||||
 | 
					Copyright 2016 The Kubernetes Authors All rights reserved.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					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 JobExpansion interface{}
 | 
				
			||||||
							
								
								
									
										150
									
								
								pkg/client/clientset_generated/release_1_3/typed/batch/v1/job.go
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										150
									
								
								pkg/client/clientset_generated/release_1_3/typed/batch/v1/job.go
									
									
									
									
									
										Normal file
									
								
							@@ -0,0 +1,150 @@
 | 
				
			|||||||
 | 
					/*
 | 
				
			||||||
 | 
					Copyright 2016 The Kubernetes Authors All rights reserved.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					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 (
 | 
				
			||||||
 | 
						api "k8s.io/kubernetes/pkg/api"
 | 
				
			||||||
 | 
						v1 "k8s.io/kubernetes/pkg/apis/batch/v1"
 | 
				
			||||||
 | 
						watch "k8s.io/kubernetes/pkg/watch"
 | 
				
			||||||
 | 
					)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// JobsGetter has a method to return a JobInterface.
 | 
				
			||||||
 | 
					// A group's client should implement this interface.
 | 
				
			||||||
 | 
					type JobsGetter interface {
 | 
				
			||||||
 | 
						Jobs(namespace string) JobInterface
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// JobInterface has methods to work with Job resources.
 | 
				
			||||||
 | 
					type JobInterface interface {
 | 
				
			||||||
 | 
						Create(*v1.Job) (*v1.Job, error)
 | 
				
			||||||
 | 
						Update(*v1.Job) (*v1.Job, error)
 | 
				
			||||||
 | 
						UpdateStatus(*v1.Job) (*v1.Job, error)
 | 
				
			||||||
 | 
						Delete(name string, options *api.DeleteOptions) error
 | 
				
			||||||
 | 
						DeleteCollection(options *api.DeleteOptions, listOptions api.ListOptions) error
 | 
				
			||||||
 | 
						Get(name string) (*v1.Job, error)
 | 
				
			||||||
 | 
						List(opts api.ListOptions) (*v1.JobList, error)
 | 
				
			||||||
 | 
						Watch(opts api.ListOptions) (watch.Interface, error)
 | 
				
			||||||
 | 
						JobExpansion
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// jobs implements JobInterface
 | 
				
			||||||
 | 
					type jobs struct {
 | 
				
			||||||
 | 
						client *BatchClient
 | 
				
			||||||
 | 
						ns     string
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// newJobs returns a Jobs
 | 
				
			||||||
 | 
					func newJobs(c *BatchClient, namespace string) *jobs {
 | 
				
			||||||
 | 
						return &jobs{
 | 
				
			||||||
 | 
							client: c,
 | 
				
			||||||
 | 
							ns:     namespace,
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Create takes the representation of a job and creates it.  Returns the server's representation of the job, and an error, if there is any.
 | 
				
			||||||
 | 
					func (c *jobs) Create(job *v1.Job) (result *v1.Job, err error) {
 | 
				
			||||||
 | 
						result = &v1.Job{}
 | 
				
			||||||
 | 
						err = c.client.Post().
 | 
				
			||||||
 | 
							Namespace(c.ns).
 | 
				
			||||||
 | 
							Resource("jobs").
 | 
				
			||||||
 | 
							Body(job).
 | 
				
			||||||
 | 
							Do().
 | 
				
			||||||
 | 
							Into(result)
 | 
				
			||||||
 | 
						return
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Update takes the representation of a job and updates it. Returns the server's representation of the job, and an error, if there is any.
 | 
				
			||||||
 | 
					func (c *jobs) Update(job *v1.Job) (result *v1.Job, err error) {
 | 
				
			||||||
 | 
						result = &v1.Job{}
 | 
				
			||||||
 | 
						err = c.client.Put().
 | 
				
			||||||
 | 
							Namespace(c.ns).
 | 
				
			||||||
 | 
							Resource("jobs").
 | 
				
			||||||
 | 
							Name(job.Name).
 | 
				
			||||||
 | 
							Body(job).
 | 
				
			||||||
 | 
							Do().
 | 
				
			||||||
 | 
							Into(result)
 | 
				
			||||||
 | 
						return
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *jobs) UpdateStatus(job *v1.Job) (result *v1.Job, err error) {
 | 
				
			||||||
 | 
						result = &v1.Job{}
 | 
				
			||||||
 | 
						err = c.client.Put().
 | 
				
			||||||
 | 
							Namespace(c.ns).
 | 
				
			||||||
 | 
							Resource("jobs").
 | 
				
			||||||
 | 
							Name(job.Name).
 | 
				
			||||||
 | 
							SubResource("status").
 | 
				
			||||||
 | 
							Body(job).
 | 
				
			||||||
 | 
							Do().
 | 
				
			||||||
 | 
							Into(result)
 | 
				
			||||||
 | 
						return
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Delete takes name of the job and deletes it. Returns an error if one occurs.
 | 
				
			||||||
 | 
					func (c *jobs) Delete(name string, options *api.DeleteOptions) error {
 | 
				
			||||||
 | 
						return c.client.Delete().
 | 
				
			||||||
 | 
							Namespace(c.ns).
 | 
				
			||||||
 | 
							Resource("jobs").
 | 
				
			||||||
 | 
							Name(name).
 | 
				
			||||||
 | 
							Body(options).
 | 
				
			||||||
 | 
							Do().
 | 
				
			||||||
 | 
							Error()
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// DeleteCollection deletes a collection of objects.
 | 
				
			||||||
 | 
					func (c *jobs) DeleteCollection(options *api.DeleteOptions, listOptions api.ListOptions) error {
 | 
				
			||||||
 | 
						return c.client.Delete().
 | 
				
			||||||
 | 
							Namespace(c.ns).
 | 
				
			||||||
 | 
							Resource("jobs").
 | 
				
			||||||
 | 
							VersionedParams(&listOptions, api.ParameterCodec).
 | 
				
			||||||
 | 
							Body(options).
 | 
				
			||||||
 | 
							Do().
 | 
				
			||||||
 | 
							Error()
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Get takes name of the job, and returns the corresponding job object, and an error if there is any.
 | 
				
			||||||
 | 
					func (c *jobs) Get(name string) (result *v1.Job, err error) {
 | 
				
			||||||
 | 
						result = &v1.Job{}
 | 
				
			||||||
 | 
						err = c.client.Get().
 | 
				
			||||||
 | 
							Namespace(c.ns).
 | 
				
			||||||
 | 
							Resource("jobs").
 | 
				
			||||||
 | 
							Name(name).
 | 
				
			||||||
 | 
							Do().
 | 
				
			||||||
 | 
							Into(result)
 | 
				
			||||||
 | 
						return
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// List takes label and field selectors, and returns the list of Jobs that match those selectors.
 | 
				
			||||||
 | 
					func (c *jobs) List(opts api.ListOptions) (result *v1.JobList, err error) {
 | 
				
			||||||
 | 
						result = &v1.JobList{}
 | 
				
			||||||
 | 
						err = c.client.Get().
 | 
				
			||||||
 | 
							Namespace(c.ns).
 | 
				
			||||||
 | 
							Resource("jobs").
 | 
				
			||||||
 | 
							VersionedParams(&opts, api.ParameterCodec).
 | 
				
			||||||
 | 
							Do().
 | 
				
			||||||
 | 
							Into(result)
 | 
				
			||||||
 | 
						return
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Watch returns a watch.Interface that watches the requested jobs.
 | 
				
			||||||
 | 
					func (c *jobs) Watch(opts api.ListOptions) (watch.Interface, error) {
 | 
				
			||||||
 | 
						return c.client.Get().
 | 
				
			||||||
 | 
							Prefix("watch").
 | 
				
			||||||
 | 
							Namespace(c.ns).
 | 
				
			||||||
 | 
							Resource("jobs").
 | 
				
			||||||
 | 
							VersionedParams(&opts, api.ParameterCodec).
 | 
				
			||||||
 | 
							Watch()
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
@@ -23,6 +23,7 @@ import (
 | 
				
			|||||||
)
 | 
					)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
type CoreInterface interface {
 | 
					type CoreInterface interface {
 | 
				
			||||||
 | 
						GetRESTClient() *restclient.RESTClient
 | 
				
			||||||
	ComponentStatusesGetter
 | 
						ComponentStatusesGetter
 | 
				
			||||||
	ConfigMapsGetter
 | 
						ConfigMapsGetter
 | 
				
			||||||
	EndpointsGetter
 | 
						EndpointsGetter
 | 
				
			||||||
@@ -159,3 +160,12 @@ func setConfigDefaults(config *restclient.Config) error {
 | 
				
			|||||||
	}
 | 
						}
 | 
				
			||||||
	return nil
 | 
						return nil
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// GetRESTClient returns a RESTClient that is used to communicate
 | 
				
			||||||
 | 
					// with API server by this client implementation.
 | 
				
			||||||
 | 
					func (c *CoreClient) GetRESTClient() *restclient.RESTClient {
 | 
				
			||||||
 | 
						if c == nil {
 | 
				
			||||||
 | 
							return nil
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return c.RESTClient
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -14,7 +14,7 @@ See the License for the specific language governing permissions and
 | 
				
			|||||||
limitations under the License.
 | 
					limitations under the License.
 | 
				
			||||||
*/
 | 
					*/
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// This package is generated by client-gen with arguments: --clientset-name=release_1_3 --input=[api/v1,extensions/v1beta1]
 | 
					// This package is generated by client-gen with arguments: --clientset-name=release_1_3 --input=[api/v1,extensions/v1beta1,autoscaling/v1,batch/v1]
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// This package has the automatically generated typed clients.
 | 
					// This package has the automatically generated typed clients.
 | 
				
			||||||
package v1
 | 
					package v1
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -14,7 +14,7 @@ See the License for the specific language governing permissions and
 | 
				
			|||||||
limitations under the License.
 | 
					limitations under the License.
 | 
				
			||||||
*/
 | 
					*/
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// This package is generated by client-gen with arguments: --clientset-name=release_1_3 --input=[api/v1,extensions/v1beta1]
 | 
					// This package is generated by client-gen with arguments: --clientset-name=release_1_3 --input=[api/v1,extensions/v1beta1,autoscaling/v1,batch/v1]
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// Package fake has the automatically generated clients.
 | 
					// Package fake has the automatically generated clients.
 | 
				
			||||||
package fake
 | 
					package fake
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -18,6 +18,7 @@ package fake
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
import (
 | 
					import (
 | 
				
			||||||
	v1 "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3/typed/core/v1"
 | 
						v1 "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3/typed/core/v1"
 | 
				
			||||||
 | 
						restclient "k8s.io/kubernetes/pkg/client/restclient"
 | 
				
			||||||
	core "k8s.io/kubernetes/pkg/client/testing/core"
 | 
						core "k8s.io/kubernetes/pkg/client/testing/core"
 | 
				
			||||||
)
 | 
					)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
@@ -84,3 +85,9 @@ func (c *FakeCore) Services(namespace string) v1.ServiceInterface {
 | 
				
			|||||||
func (c *FakeCore) ServiceAccounts(namespace string) v1.ServiceAccountInterface {
 | 
					func (c *FakeCore) ServiceAccounts(namespace string) v1.ServiceAccountInterface {
 | 
				
			||||||
	return &FakeServiceAccounts{c, namespace}
 | 
						return &FakeServiceAccounts{c, namespace}
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// GetRESTClient returns a RESTClient that is used to communicate
 | 
				
			||||||
 | 
					// with API server by this client implementation.
 | 
				
			||||||
 | 
					func (c *FakeCore) GetRESTClient() *restclient.RESTClient {
 | 
				
			||||||
 | 
						return nil
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -14,7 +14,7 @@ See the License for the specific language governing permissions and
 | 
				
			|||||||
limitations under the License.
 | 
					limitations under the License.
 | 
				
			||||||
*/
 | 
					*/
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// This package is generated by client-gen with arguments: --clientset-name=release_1_3 --input=[api/v1,extensions/v1beta1]
 | 
					// This package is generated by client-gen with arguments: --clientset-name=release_1_3 --input=[api/v1,extensions/v1beta1,autoscaling/v1,batch/v1]
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// This package has the automatically generated typed clients.
 | 
					// This package has the automatically generated typed clients.
 | 
				
			||||||
package v1beta1
 | 
					package v1beta1
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -23,11 +23,13 @@ import (
 | 
				
			|||||||
)
 | 
					)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
type ExtensionsInterface interface {
 | 
					type ExtensionsInterface interface {
 | 
				
			||||||
 | 
						GetRESTClient() *restclient.RESTClient
 | 
				
			||||||
	DaemonSetsGetter
 | 
						DaemonSetsGetter
 | 
				
			||||||
	DeploymentsGetter
 | 
						DeploymentsGetter
 | 
				
			||||||
	HorizontalPodAutoscalersGetter
 | 
						HorizontalPodAutoscalersGetter
 | 
				
			||||||
	IngressesGetter
 | 
						IngressesGetter
 | 
				
			||||||
	JobsGetter
 | 
						JobsGetter
 | 
				
			||||||
 | 
						PodSecurityPoliciesGetter
 | 
				
			||||||
	ReplicaSetsGetter
 | 
						ReplicaSetsGetter
 | 
				
			||||||
	ScalesGetter
 | 
						ScalesGetter
 | 
				
			||||||
	ThirdPartyResourcesGetter
 | 
						ThirdPartyResourcesGetter
 | 
				
			||||||
@@ -58,6 +60,10 @@ func (c *ExtensionsClient) Jobs(namespace string) JobInterface {
 | 
				
			|||||||
	return newJobs(c, namespace)
 | 
						return newJobs(c, namespace)
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *ExtensionsClient) PodSecurityPolicies() PodSecurityPolicyInterface {
 | 
				
			||||||
 | 
						return newPodSecurityPolicies(c)
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
func (c *ExtensionsClient) ReplicaSets(namespace string) ReplicaSetInterface {
 | 
					func (c *ExtensionsClient) ReplicaSets(namespace string) ReplicaSetInterface {
 | 
				
			||||||
	return newReplicaSets(c, namespace)
 | 
						return newReplicaSets(c, namespace)
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
@@ -124,3 +130,12 @@ func setConfigDefaults(config *restclient.Config) error {
 | 
				
			|||||||
	}
 | 
						}
 | 
				
			||||||
	return nil
 | 
						return nil
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// GetRESTClient returns a RESTClient that is used to communicate
 | 
				
			||||||
 | 
					// with API server by this client implementation.
 | 
				
			||||||
 | 
					func (c *ExtensionsClient) GetRESTClient() *restclient.RESTClient {
 | 
				
			||||||
 | 
						if c == nil {
 | 
				
			||||||
 | 
							return nil
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return c.RESTClient
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -14,7 +14,7 @@ See the License for the specific language governing permissions and
 | 
				
			|||||||
limitations under the License.
 | 
					limitations under the License.
 | 
				
			||||||
*/
 | 
					*/
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// This package is generated by client-gen with arguments: --clientset-name=release_1_3 --input=[api/v1,extensions/v1beta1]
 | 
					// This package is generated by client-gen with arguments: --clientset-name=release_1_3 --input=[api/v1,extensions/v1beta1,autoscaling/v1,batch/v1]
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// Package fake has the automatically generated clients.
 | 
					// Package fake has the automatically generated clients.
 | 
				
			||||||
package fake
 | 
					package fake
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -18,6 +18,7 @@ package fake
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
import (
 | 
					import (
 | 
				
			||||||
	v1beta1 "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3/typed/extensions/v1beta1"
 | 
						v1beta1 "k8s.io/kubernetes/pkg/client/clientset_generated/release_1_3/typed/extensions/v1beta1"
 | 
				
			||||||
 | 
						restclient "k8s.io/kubernetes/pkg/client/restclient"
 | 
				
			||||||
	core "k8s.io/kubernetes/pkg/client/testing/core"
 | 
						core "k8s.io/kubernetes/pkg/client/testing/core"
 | 
				
			||||||
)
 | 
					)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
@@ -45,6 +46,10 @@ func (c *FakeExtensions) Jobs(namespace string) v1beta1.JobInterface {
 | 
				
			|||||||
	return &FakeJobs{c, namespace}
 | 
						return &FakeJobs{c, namespace}
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakeExtensions) PodSecurityPolicies() v1beta1.PodSecurityPolicyInterface {
 | 
				
			||||||
 | 
						return &FakePodSecurityPolicies{c}
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
func (c *FakeExtensions) ReplicaSets(namespace string) v1beta1.ReplicaSetInterface {
 | 
					func (c *FakeExtensions) ReplicaSets(namespace string) v1beta1.ReplicaSetInterface {
 | 
				
			||||||
	return &FakeReplicaSets{c, namespace}
 | 
						return &FakeReplicaSets{c, namespace}
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
@@ -56,3 +61,9 @@ func (c *FakeExtensions) Scales(namespace string) v1beta1.ScaleInterface {
 | 
				
			|||||||
func (c *FakeExtensions) ThirdPartyResources() v1beta1.ThirdPartyResourceInterface {
 | 
					func (c *FakeExtensions) ThirdPartyResources() v1beta1.ThirdPartyResourceInterface {
 | 
				
			||||||
	return &FakeThirdPartyResources{c}
 | 
						return &FakeThirdPartyResources{c}
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// GetRESTClient returns a RESTClient that is used to communicate
 | 
				
			||||||
 | 
					// with API server by this client implementation.
 | 
				
			||||||
 | 
					func (c *FakeExtensions) GetRESTClient() *restclient.RESTClient {
 | 
				
			||||||
 | 
						return nil
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -0,0 +1,99 @@
 | 
				
			|||||||
 | 
					/*
 | 
				
			||||||
 | 
					Copyright 2016 The Kubernetes Authors All rights reserved.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					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 (
 | 
				
			||||||
 | 
						api "k8s.io/kubernetes/pkg/api"
 | 
				
			||||||
 | 
						unversioned "k8s.io/kubernetes/pkg/api/unversioned"
 | 
				
			||||||
 | 
						v1beta1 "k8s.io/kubernetes/pkg/apis/extensions/v1beta1"
 | 
				
			||||||
 | 
						core "k8s.io/kubernetes/pkg/client/testing/core"
 | 
				
			||||||
 | 
						labels "k8s.io/kubernetes/pkg/labels"
 | 
				
			||||||
 | 
						watch "k8s.io/kubernetes/pkg/watch"
 | 
				
			||||||
 | 
					)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// FakePodSecurityPolicies implements PodSecurityPolicyInterface
 | 
				
			||||||
 | 
					type FakePodSecurityPolicies struct {
 | 
				
			||||||
 | 
						Fake *FakeExtensions
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					var podsecuritypoliciesResource = unversioned.GroupVersionResource{Group: "extensions", Version: "v1beta1", Resource: "podsecuritypolicies"}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakePodSecurityPolicies) Create(podSecurityPolicy *v1beta1.PodSecurityPolicy) (result *v1beta1.PodSecurityPolicy, err error) {
 | 
				
			||||||
 | 
						obj, err := c.Fake.
 | 
				
			||||||
 | 
							Invokes(core.NewRootCreateAction(podsecuritypoliciesResource, podSecurityPolicy), &v1beta1.PodSecurityPolicy{})
 | 
				
			||||||
 | 
						if obj == nil {
 | 
				
			||||||
 | 
							return nil, err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return obj.(*v1beta1.PodSecurityPolicy), err
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakePodSecurityPolicies) Update(podSecurityPolicy *v1beta1.PodSecurityPolicy) (result *v1beta1.PodSecurityPolicy, err error) {
 | 
				
			||||||
 | 
						obj, err := c.Fake.
 | 
				
			||||||
 | 
							Invokes(core.NewRootUpdateAction(podsecuritypoliciesResource, podSecurityPolicy), &v1beta1.PodSecurityPolicy{})
 | 
				
			||||||
 | 
						if obj == nil {
 | 
				
			||||||
 | 
							return nil, err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return obj.(*v1beta1.PodSecurityPolicy), err
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakePodSecurityPolicies) Delete(name string, options *api.DeleteOptions) error {
 | 
				
			||||||
 | 
						_, err := c.Fake.
 | 
				
			||||||
 | 
							Invokes(core.NewRootDeleteAction(podsecuritypoliciesResource, name), &v1beta1.PodSecurityPolicy{})
 | 
				
			||||||
 | 
						return err
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakePodSecurityPolicies) DeleteCollection(options *api.DeleteOptions, listOptions api.ListOptions) error {
 | 
				
			||||||
 | 
						action := core.NewRootDeleteCollectionAction(podsecuritypoliciesResource, listOptions)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						_, err := c.Fake.Invokes(action, &v1beta1.PodSecurityPolicyList{})
 | 
				
			||||||
 | 
						return err
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakePodSecurityPolicies) Get(name string) (result *v1beta1.PodSecurityPolicy, err error) {
 | 
				
			||||||
 | 
						obj, err := c.Fake.
 | 
				
			||||||
 | 
							Invokes(core.NewRootGetAction(podsecuritypoliciesResource, name), &v1beta1.PodSecurityPolicy{})
 | 
				
			||||||
 | 
						if obj == nil {
 | 
				
			||||||
 | 
							return nil, err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return obj.(*v1beta1.PodSecurityPolicy), err
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					func (c *FakePodSecurityPolicies) List(opts api.ListOptions) (result *v1beta1.PodSecurityPolicyList, err error) {
 | 
				
			||||||
 | 
						obj, err := c.Fake.
 | 
				
			||||||
 | 
							Invokes(core.NewRootListAction(podsecuritypoliciesResource, opts), &v1beta1.PodSecurityPolicyList{})
 | 
				
			||||||
 | 
						if obj == nil {
 | 
				
			||||||
 | 
							return nil, err
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						label := opts.LabelSelector
 | 
				
			||||||
 | 
						if label == nil {
 | 
				
			||||||
 | 
							label = labels.Everything()
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						list := &v1beta1.PodSecurityPolicyList{}
 | 
				
			||||||
 | 
						for _, item := range obj.(*v1beta1.PodSecurityPolicyList).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 podSecurityPolicies.
 | 
				
			||||||
 | 
					func (c *FakePodSecurityPolicies) Watch(opts api.ListOptions) (watch.Interface, error) {
 | 
				
			||||||
 | 
						return c.Fake.
 | 
				
			||||||
 | 
							InvokesWatch(core.NewRootWatchAction(podsecuritypoliciesResource, opts))
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
@@ -35,7 +35,6 @@ var thirdpartyresourcesResource = unversioned.GroupVersionResource{Group: "exten
 | 
				
			|||||||
func (c *FakeThirdPartyResources) Create(thirdPartyResource *v1beta1.ThirdPartyResource) (result *v1beta1.ThirdPartyResource, err error) {
 | 
					func (c *FakeThirdPartyResources) Create(thirdPartyResource *v1beta1.ThirdPartyResource) (result *v1beta1.ThirdPartyResource, err error) {
 | 
				
			||||||
	obj, err := c.Fake.
 | 
						obj, err := c.Fake.
 | 
				
			||||||
		Invokes(core.NewRootCreateAction(thirdpartyresourcesResource, thirdPartyResource), &v1beta1.ThirdPartyResource{})
 | 
							Invokes(core.NewRootCreateAction(thirdpartyresourcesResource, thirdPartyResource), &v1beta1.ThirdPartyResource{})
 | 
				
			||||||
 | 
					 | 
				
			||||||
	if obj == nil {
 | 
						if obj == nil {
 | 
				
			||||||
		return nil, err
 | 
							return nil, err
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
@@ -45,7 +44,6 @@ func (c *FakeThirdPartyResources) Create(thirdPartyResource *v1beta1.ThirdPartyR
 | 
				
			|||||||
func (c *FakeThirdPartyResources) Update(thirdPartyResource *v1beta1.ThirdPartyResource) (result *v1beta1.ThirdPartyResource, err error) {
 | 
					func (c *FakeThirdPartyResources) Update(thirdPartyResource *v1beta1.ThirdPartyResource) (result *v1beta1.ThirdPartyResource, err error) {
 | 
				
			||||||
	obj, err := c.Fake.
 | 
						obj, err := c.Fake.
 | 
				
			||||||
		Invokes(core.NewRootUpdateAction(thirdpartyresourcesResource, thirdPartyResource), &v1beta1.ThirdPartyResource{})
 | 
							Invokes(core.NewRootUpdateAction(thirdpartyresourcesResource, thirdPartyResource), &v1beta1.ThirdPartyResource{})
 | 
				
			||||||
 | 
					 | 
				
			||||||
	if obj == nil {
 | 
						if obj == nil {
 | 
				
			||||||
		return nil, err
 | 
							return nil, err
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
@@ -55,7 +53,6 @@ func (c *FakeThirdPartyResources) Update(thirdPartyResource *v1beta1.ThirdPartyR
 | 
				
			|||||||
func (c *FakeThirdPartyResources) Delete(name string, options *api.DeleteOptions) error {
 | 
					func (c *FakeThirdPartyResources) Delete(name string, options *api.DeleteOptions) error {
 | 
				
			||||||
	_, err := c.Fake.
 | 
						_, err := c.Fake.
 | 
				
			||||||
		Invokes(core.NewRootDeleteAction(thirdpartyresourcesResource, name), &v1beta1.ThirdPartyResource{})
 | 
							Invokes(core.NewRootDeleteAction(thirdpartyresourcesResource, name), &v1beta1.ThirdPartyResource{})
 | 
				
			||||||
 | 
					 | 
				
			||||||
	return err
 | 
						return err
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
@@ -69,7 +66,6 @@ func (c *FakeThirdPartyResources) DeleteCollection(options *api.DeleteOptions, l
 | 
				
			|||||||
func (c *FakeThirdPartyResources) Get(name string) (result *v1beta1.ThirdPartyResource, err error) {
 | 
					func (c *FakeThirdPartyResources) Get(name string) (result *v1beta1.ThirdPartyResource, err error) {
 | 
				
			||||||
	obj, err := c.Fake.
 | 
						obj, err := c.Fake.
 | 
				
			||||||
		Invokes(core.NewRootGetAction(thirdpartyresourcesResource, name), &v1beta1.ThirdPartyResource{})
 | 
							Invokes(core.NewRootGetAction(thirdpartyresourcesResource, name), &v1beta1.ThirdPartyResource{})
 | 
				
			||||||
 | 
					 | 
				
			||||||
	if obj == nil {
 | 
						if obj == nil {
 | 
				
			||||||
		return nil, err
 | 
							return nil, err
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
@@ -79,7 +75,6 @@ func (c *FakeThirdPartyResources) Get(name string) (result *v1beta1.ThirdPartyRe
 | 
				
			|||||||
func (c *FakeThirdPartyResources) List(opts api.ListOptions) (result *v1beta1.ThirdPartyResourceList, err error) {
 | 
					func (c *FakeThirdPartyResources) List(opts api.ListOptions) (result *v1beta1.ThirdPartyResourceList, err error) {
 | 
				
			||||||
	obj, err := c.Fake.
 | 
						obj, err := c.Fake.
 | 
				
			||||||
		Invokes(core.NewRootListAction(thirdpartyresourcesResource, opts), &v1beta1.ThirdPartyResourceList{})
 | 
							Invokes(core.NewRootListAction(thirdpartyresourcesResource, opts), &v1beta1.ThirdPartyResourceList{})
 | 
				
			||||||
 | 
					 | 
				
			||||||
	if obj == nil {
 | 
						if obj == nil {
 | 
				
			||||||
		return nil, err
 | 
							return nil, err
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
@@ -101,5 +96,4 @@ func (c *FakeThirdPartyResources) List(opts api.ListOptions) (result *v1beta1.Th
 | 
				
			|||||||
func (c *FakeThirdPartyResources) Watch(opts api.ListOptions) (watch.Interface, error) {
 | 
					func (c *FakeThirdPartyResources) Watch(opts api.ListOptions) (watch.Interface, error) {
 | 
				
			||||||
	return c.Fake.
 | 
						return c.Fake.
 | 
				
			||||||
		InvokesWatch(core.NewRootWatchAction(thirdpartyresourcesResource, opts))
 | 
							InvokesWatch(core.NewRootWatchAction(thirdpartyresourcesResource, opts))
 | 
				
			||||||
 | 
					 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -27,3 +27,5 @@ type JobExpansion interface{}
 | 
				
			|||||||
type ThirdPartyResourceExpansion interface{}
 | 
					type ThirdPartyResourceExpansion interface{}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
type ReplicaSetExpansion interface{}
 | 
					type ReplicaSetExpansion interface{}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					type PodSecurityPolicyExpansion interface{}
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -0,0 +1,127 @@
 | 
				
			|||||||
 | 
					/*
 | 
				
			||||||
 | 
					Copyright 2016 The Kubernetes Authors All rights reserved.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					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 v1beta1
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					import (
 | 
				
			||||||
 | 
						api "k8s.io/kubernetes/pkg/api"
 | 
				
			||||||
 | 
						v1beta1 "k8s.io/kubernetes/pkg/apis/extensions/v1beta1"
 | 
				
			||||||
 | 
						watch "k8s.io/kubernetes/pkg/watch"
 | 
				
			||||||
 | 
					)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// PodSecurityPoliciesGetter has a method to return a PodSecurityPolicyInterface.
 | 
				
			||||||
 | 
					// A group's client should implement this interface.
 | 
				
			||||||
 | 
					type PodSecurityPoliciesGetter interface {
 | 
				
			||||||
 | 
						PodSecurityPolicies() PodSecurityPolicyInterface
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// PodSecurityPolicyInterface has methods to work with PodSecurityPolicy resources.
 | 
				
			||||||
 | 
					type PodSecurityPolicyInterface interface {
 | 
				
			||||||
 | 
						Create(*v1beta1.PodSecurityPolicy) (*v1beta1.PodSecurityPolicy, error)
 | 
				
			||||||
 | 
						Update(*v1beta1.PodSecurityPolicy) (*v1beta1.PodSecurityPolicy, error)
 | 
				
			||||||
 | 
						Delete(name string, options *api.DeleteOptions) error
 | 
				
			||||||
 | 
						DeleteCollection(options *api.DeleteOptions, listOptions api.ListOptions) error
 | 
				
			||||||
 | 
						Get(name string) (*v1beta1.PodSecurityPolicy, error)
 | 
				
			||||||
 | 
						List(opts api.ListOptions) (*v1beta1.PodSecurityPolicyList, error)
 | 
				
			||||||
 | 
						Watch(opts api.ListOptions) (watch.Interface, error)
 | 
				
			||||||
 | 
						PodSecurityPolicyExpansion
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// podSecurityPolicies implements PodSecurityPolicyInterface
 | 
				
			||||||
 | 
					type podSecurityPolicies struct {
 | 
				
			||||||
 | 
						client *ExtensionsClient
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// newPodSecurityPolicies returns a PodSecurityPolicies
 | 
				
			||||||
 | 
					func newPodSecurityPolicies(c *ExtensionsClient) *podSecurityPolicies {
 | 
				
			||||||
 | 
						return &podSecurityPolicies{
 | 
				
			||||||
 | 
							client: c,
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Create takes the representation of a podSecurityPolicy and creates it.  Returns the server's representation of the podSecurityPolicy, and an error, if there is any.
 | 
				
			||||||
 | 
					func (c *podSecurityPolicies) Create(podSecurityPolicy *v1beta1.PodSecurityPolicy) (result *v1beta1.PodSecurityPolicy, err error) {
 | 
				
			||||||
 | 
						result = &v1beta1.PodSecurityPolicy{}
 | 
				
			||||||
 | 
						err = c.client.Post().
 | 
				
			||||||
 | 
							Resource("podsecuritypolicies").
 | 
				
			||||||
 | 
							Body(podSecurityPolicy).
 | 
				
			||||||
 | 
							Do().
 | 
				
			||||||
 | 
							Into(result)
 | 
				
			||||||
 | 
						return
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Update takes the representation of a podSecurityPolicy and updates it. Returns the server's representation of the podSecurityPolicy, and an error, if there is any.
 | 
				
			||||||
 | 
					func (c *podSecurityPolicies) Update(podSecurityPolicy *v1beta1.PodSecurityPolicy) (result *v1beta1.PodSecurityPolicy, err error) {
 | 
				
			||||||
 | 
						result = &v1beta1.PodSecurityPolicy{}
 | 
				
			||||||
 | 
						err = c.client.Put().
 | 
				
			||||||
 | 
							Resource("podsecuritypolicies").
 | 
				
			||||||
 | 
							Name(podSecurityPolicy.Name).
 | 
				
			||||||
 | 
							Body(podSecurityPolicy).
 | 
				
			||||||
 | 
							Do().
 | 
				
			||||||
 | 
							Into(result)
 | 
				
			||||||
 | 
						return
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Delete takes name of the podSecurityPolicy and deletes it. Returns an error if one occurs.
 | 
				
			||||||
 | 
					func (c *podSecurityPolicies) Delete(name string, options *api.DeleteOptions) error {
 | 
				
			||||||
 | 
						return c.client.Delete().
 | 
				
			||||||
 | 
							Resource("podsecuritypolicies").
 | 
				
			||||||
 | 
							Name(name).
 | 
				
			||||||
 | 
							Body(options).
 | 
				
			||||||
 | 
							Do().
 | 
				
			||||||
 | 
							Error()
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// DeleteCollection deletes a collection of objects.
 | 
				
			||||||
 | 
					func (c *podSecurityPolicies) DeleteCollection(options *api.DeleteOptions, listOptions api.ListOptions) error {
 | 
				
			||||||
 | 
						return c.client.Delete().
 | 
				
			||||||
 | 
							Resource("podsecuritypolicies").
 | 
				
			||||||
 | 
							VersionedParams(&listOptions, api.ParameterCodec).
 | 
				
			||||||
 | 
							Body(options).
 | 
				
			||||||
 | 
							Do().
 | 
				
			||||||
 | 
							Error()
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Get takes name of the podSecurityPolicy, and returns the corresponding podSecurityPolicy object, and an error if there is any.
 | 
				
			||||||
 | 
					func (c *podSecurityPolicies) Get(name string) (result *v1beta1.PodSecurityPolicy, err error) {
 | 
				
			||||||
 | 
						result = &v1beta1.PodSecurityPolicy{}
 | 
				
			||||||
 | 
						err = c.client.Get().
 | 
				
			||||||
 | 
							Resource("podsecuritypolicies").
 | 
				
			||||||
 | 
							Name(name).
 | 
				
			||||||
 | 
							Do().
 | 
				
			||||||
 | 
							Into(result)
 | 
				
			||||||
 | 
						return
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// List takes label and field selectors, and returns the list of PodSecurityPolicies that match those selectors.
 | 
				
			||||||
 | 
					func (c *podSecurityPolicies) List(opts api.ListOptions) (result *v1beta1.PodSecurityPolicyList, err error) {
 | 
				
			||||||
 | 
						result = &v1beta1.PodSecurityPolicyList{}
 | 
				
			||||||
 | 
						err = c.client.Get().
 | 
				
			||||||
 | 
							Resource("podsecuritypolicies").
 | 
				
			||||||
 | 
							VersionedParams(&opts, api.ParameterCodec).
 | 
				
			||||||
 | 
							Do().
 | 
				
			||||||
 | 
							Into(result)
 | 
				
			||||||
 | 
						return
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Watch returns a watch.Interface that watches the requested podSecurityPolicies.
 | 
				
			||||||
 | 
					func (c *podSecurityPolicies) Watch(opts api.ListOptions) (watch.Interface, error) {
 | 
				
			||||||
 | 
						return c.client.Get().
 | 
				
			||||||
 | 
							Prefix("watch").
 | 
				
			||||||
 | 
							Resource("podsecuritypolicies").
 | 
				
			||||||
 | 
							VersionedParams(&opts, api.ParameterCodec).
 | 
				
			||||||
 | 
							Watch()
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
@@ -43,7 +43,6 @@ type ThirdPartyResourceInterface interface {
 | 
				
			|||||||
// thirdPartyResources implements ThirdPartyResourceInterface
 | 
					// thirdPartyResources implements ThirdPartyResourceInterface
 | 
				
			||||||
type thirdPartyResources struct {
 | 
					type thirdPartyResources struct {
 | 
				
			||||||
	client *ExtensionsClient
 | 
						client *ExtensionsClient
 | 
				
			||||||
	ns     string
 | 
					 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// newThirdPartyResources returns a ThirdPartyResources
 | 
					// newThirdPartyResources returns a ThirdPartyResources
 | 
				
			||||||
 
 | 
				
			|||||||
		Reference in New Issue
	
	Block a user