Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
K
k3s
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Registry
Registry
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
Jacklull
k3s
Commits
ebc14e1a
Commit
ebc14e1a
authored
Dec 21, 2015
by
Wojciech Tyczynski
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Regenerate clients
parent
b279227d
Hide whitespace changes
Inline
Side-by-side
Showing
25 changed files
with
622 additions
and
115 deletions
+622
-115
register.go
...ibs/go2idl/client-gen/testdata/apis/testgroup/register.go
+1
-1
register.go
.../go2idl/client-gen/testdata/apis/testgroup/v1/register.go
+2
-1
testType.go
...l/client-gen/testoutput/testgroup/unversioned/testType.go
+28
-5
testgroup_test.go
...nt-gen/testoutput/testgroup/unversioned/testgroup_test.go
+3
-3
daemonSet.go
...lient/typed/generated/extensions/unversioned/daemonSet.go
+28
-5
deployment.go
...ient/typed/generated/extensions/unversioned/deployment.go
+28
-5
horizontalPodAutoscaler.go
...nerated/extensions/unversioned/horizontalPodAutoscaler.go
+28
-5
ingress.go
pkg/client/typed/generated/extensions/unversioned/ingress.go
+28
-5
job.go
pkg/client/typed/generated/extensions/unversioned/job.go
+28
-5
thirdPartyResource.go
...ed/generated/extensions/unversioned/thirdPartyResource.go
+28
-5
componentStatus.go
...ent/typed/generated/legacy/unversioned/componentStatus.go
+28
-5
endpoints.go
pkg/client/typed/generated/legacy/unversioned/endpoints.go
+28
-5
event.go
pkg/client/typed/generated/legacy/unversioned/event.go
+28
-5
limitRange.go
pkg/client/typed/generated/legacy/unversioned/limitRange.go
+28
-5
namespace.go
pkg/client/typed/generated/legacy/unversioned/namespace.go
+28
-5
node.go
pkg/client/typed/generated/legacy/unversioned/node.go
+28
-5
persistentVolume.go
...nt/typed/generated/legacy/unversioned/persistentVolume.go
+28
-5
persistentVolumeClaim.go
...ped/generated/legacy/unversioned/persistentVolumeClaim.go
+28
-5
pod.go
pkg/client/typed/generated/legacy/unversioned/pod.go
+28
-5
podTemplate.go
pkg/client/typed/generated/legacy/unversioned/podTemplate.go
+28
-5
replicationController.go
...ped/generated/legacy/unversioned/replicationController.go
+28
-5
resourceQuota.go
...lient/typed/generated/legacy/unversioned/resourceQuota.go
+28
-5
secret.go
pkg/client/typed/generated/legacy/unversioned/secret.go
+28
-5
service.go
pkg/client/typed/generated/legacy/unversioned/service.go
+28
-5
serviceAccount.go
...ient/typed/generated/legacy/unversioned/serviceAccount.go
+28
-5
No files found.
cmd/libs/go2idl/client-gen/testdata/apis/testgroup/register.go
View file @
ebc14e1a
...
...
@@ -36,7 +36,7 @@ func addKnownTypes() {
)
api
.
Scheme
.
AddKnownTypes
(
SchemeGroupVersion
,
&
unversioned
.
ListOptions
{})
&
api
.
ListOptions
{})
}
func
(
obj
*
TestType
)
GetObjectKind
()
unversioned
.
ObjectKind
{
return
&
obj
.
TypeMeta
}
...
...
cmd/libs/go2idl/client-gen/testdata/apis/testgroup/v1/register.go
View file @
ebc14e1a
...
...
@@ -19,6 +19,7 @@ package v1
import
(
"k8s.io/kubernetes/pkg/api"
"k8s.io/kubernetes/pkg/api/unversioned"
"k8s.io/kubernetes/pkg/api/v1"
"k8s.io/kubernetes/pkg/runtime"
)
...
...
@@ -39,7 +40,7 @@ func addKnownTypes() {
)
api
.
Scheme
.
AddKnownTypes
(
SchemeGroupVersion
,
&
unversioned
.
ListOptions
{})
&
v1
.
ListOptions
{})
}
func
(
obj
*
TestType
)
GetObjectKind
()
unversioned
.
ObjectKind
{
return
&
obj
.
TypeMeta
}
...
...
cmd/libs/go2idl/client-gen/testoutput/testgroup/unversioned/testType.go
View file @
ebc14e1a
...
...
@@ -19,7 +19,6 @@ package unversioned
import
(
testgroup
"k8s.io/kubernetes/cmd/libs/go2idl/client-gen/testdata/apis/testgroup"
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -33,9 +32,10 @@ type TestTypeInterface interface {
Create
(
*
testgroup
.
TestType
)
(
*
testgroup
.
TestType
,
error
)
Update
(
*
testgroup
.
TestType
)
(
*
testgroup
.
TestType
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
testgroup
.
TestType
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
testgroup
.
TestTypeList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
testgroup
.
TestTypeList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// testTypes implements TestTypeInterface
...
...
@@ -95,6 +95,29 @@ func (c *testTypes) Delete(name string, options *api.DeleteOptions) error {
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
testTypes
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"testTypes"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"testTypes"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
Do
()
.
Error
()
}
// Get takes name of the testType, and returns the corresponding testType object, and an error if there is any.
func
(
c
*
testTypes
)
Get
(
name
string
)
(
result
*
testgroup
.
TestType
,
err
error
)
{
result
=
&
testgroup
.
TestType
{}
...
...
@@ -108,7 +131,7 @@ func (c *testTypes) Get(name string) (result *testgroup.TestType, err error) {
}
// List takes label and field selectors, and returns the list of TestTypes that match those selectors.
func
(
c
*
testTypes
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
testgroup
.
TestTypeList
,
err
error
)
{
func
(
c
*
testTypes
)
List
(
opts
api
.
ListOptions
)
(
result
*
testgroup
.
TestTypeList
,
err
error
)
{
result
=
&
testgroup
.
TestTypeList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -120,7 +143,7 @@ func (c *testTypes) List(opts unversioned.ListOptions) (result *testgroup.TestTy
}
// Watch returns a watch.Interface that watches the requested testTypes.
func
(
c
*
testTypes
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
testTypes
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
cmd/libs/go2idl/client-gen/testoutput/testgroup/unversioned/testgroup_test.go
View file @
ebc14e1a
...
...
@@ -152,7 +152,7 @@ func TestListEmptyTestTypes(t *testing.T) {
Response
:
simple
.
Response
{
StatusCode
:
http
.
StatusOK
,
Body
:
&
testgroup
.
TestTypeList
{}},
},
}
podList
,
err
:=
c
.
Setup
(
t
)
.
TestTypes
(
ns
)
.
List
(
unversioned
.
ListOptions
{})
podList
,
err
:=
c
.
Setup
(
t
)
.
TestTypes
(
ns
)
.
List
(
api
.
ListOptions
{})
c
.
simpleClient
.
Validate
(
t
,
podList
,
err
)
}
...
...
@@ -177,7 +177,7 @@ func TestListTestTypes(t *testing.T) {
},
},
}
receivedTestTypeList
,
err
:=
c
.
Setup
(
t
)
.
TestTypes
(
ns
)
.
List
(
unversioned
.
ListOptions
{})
receivedTestTypeList
,
err
:=
c
.
Setup
(
t
)
.
TestTypes
(
ns
)
.
List
(
api
.
ListOptions
{})
c
.
simpleClient
.
Validate
(
t
,
receivedTestTypeList
,
err
)
}
...
...
@@ -210,7 +210,7 @@ func TestListTestTypesLabels(t *testing.T) {
c
.
Setup
(
t
)
c
.
simpleClient
.
QueryValidator
[
labelSelectorQueryParamName
]
=
simple
.
ValidateLabels
selector
:=
labels
.
Set
{
"foo"
:
"bar"
,
"name"
:
"baz"
}
.
AsSelector
()
options
:=
unversioned
.
ListOptions
{
LabelSelector
:
unversioned
.
LabelSelector
{
selector
}
}
options
:=
api
.
ListOptions
{
LabelSelector
:
selector
}
receivedTestTypeList
,
err
:=
c
.
TestTypes
(
ns
)
.
List
(
options
)
c
.
simpleClient
.
Validate
(
t
,
receivedTestTypeList
,
err
)
}
pkg/client/typed/generated/extensions/unversioned/daemonSet.go
View file @
ebc14e1a
...
...
@@ -18,7 +18,6 @@ package unversioned
import
(
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
extensions
"k8s.io/kubernetes/pkg/apis/extensions"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -33,9 +32,10 @@ type DaemonSetInterface interface {
Create
(
*
extensions
.
DaemonSet
)
(
*
extensions
.
DaemonSet
,
error
)
Update
(
*
extensions
.
DaemonSet
)
(
*
extensions
.
DaemonSet
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
extensions
.
DaemonSet
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
extensions
.
DaemonSetList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
extensions
.
DaemonSetList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// daemonSets implements DaemonSetInterface
...
...
@@ -95,6 +95,29 @@ func (c *daemonSets) Delete(name string, options *api.DeleteOptions) error {
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
daemonSets
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"daemonSets"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"daemonSets"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
Do
()
.
Error
()
}
// Get takes name of the daemonSet, and returns the corresponding daemonSet object, and an error if there is any.
func
(
c
*
daemonSets
)
Get
(
name
string
)
(
result
*
extensions
.
DaemonSet
,
err
error
)
{
result
=
&
extensions
.
DaemonSet
{}
...
...
@@ -108,7 +131,7 @@ func (c *daemonSets) Get(name string) (result *extensions.DaemonSet, err error)
}
// List takes label and field selectors, and returns the list of DaemonSets that match those selectors.
func
(
c
*
daemonSets
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
extensions
.
DaemonSetList
,
err
error
)
{
func
(
c
*
daemonSets
)
List
(
opts
api
.
ListOptions
)
(
result
*
extensions
.
DaemonSetList
,
err
error
)
{
result
=
&
extensions
.
DaemonSetList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -120,7 +143,7 @@ func (c *daemonSets) List(opts unversioned.ListOptions) (result *extensions.Daem
}
// Watch returns a watch.Interface that watches the requested daemonSets.
func
(
c
*
daemonSets
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
daemonSets
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
pkg/client/typed/generated/extensions/unversioned/deployment.go
View file @
ebc14e1a
...
...
@@ -18,7 +18,6 @@ package unversioned
import
(
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
extensions
"k8s.io/kubernetes/pkg/apis/extensions"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -33,9 +32,10 @@ type DeploymentInterface interface {
Create
(
*
extensions
.
Deployment
)
(
*
extensions
.
Deployment
,
error
)
Update
(
*
extensions
.
Deployment
)
(
*
extensions
.
Deployment
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
extensions
.
Deployment
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
extensions
.
DeploymentList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
extensions
.
DeploymentList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// deployments implements DeploymentInterface
...
...
@@ -95,6 +95,29 @@ func (c *deployments) Delete(name string, options *api.DeleteOptions) error {
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
deployments
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"deployments"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"deployments"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
Do
()
.
Error
()
}
// Get takes name of the deployment, and returns the corresponding deployment object, and an error if there is any.
func
(
c
*
deployments
)
Get
(
name
string
)
(
result
*
extensions
.
Deployment
,
err
error
)
{
result
=
&
extensions
.
Deployment
{}
...
...
@@ -108,7 +131,7 @@ func (c *deployments) Get(name string) (result *extensions.Deployment, err error
}
// List takes label and field selectors, and returns the list of Deployments that match those selectors.
func
(
c
*
deployments
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
extensions
.
DeploymentList
,
err
error
)
{
func
(
c
*
deployments
)
List
(
opts
api
.
ListOptions
)
(
result
*
extensions
.
DeploymentList
,
err
error
)
{
result
=
&
extensions
.
DeploymentList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -120,7 +143,7 @@ func (c *deployments) List(opts unversioned.ListOptions) (result *extensions.Dep
}
// Watch returns a watch.Interface that watches the requested deployments.
func
(
c
*
deployments
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
deployments
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
pkg/client/typed/generated/extensions/unversioned/horizontalPodAutoscaler.go
View file @
ebc14e1a
...
...
@@ -18,7 +18,6 @@ package unversioned
import
(
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
extensions
"k8s.io/kubernetes/pkg/apis/extensions"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -33,9 +32,10 @@ type HorizontalPodAutoscalerInterface interface {
Create
(
*
extensions
.
HorizontalPodAutoscaler
)
(
*
extensions
.
HorizontalPodAutoscaler
,
error
)
Update
(
*
extensions
.
HorizontalPodAutoscaler
)
(
*
extensions
.
HorizontalPodAutoscaler
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
extensions
.
HorizontalPodAutoscaler
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
extensions
.
HorizontalPodAutoscalerList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
extensions
.
HorizontalPodAutoscalerList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// horizontalPodAutoscalers implements HorizontalPodAutoscalerInterface
...
...
@@ -95,6 +95,29 @@ func (c *horizontalPodAutoscalers) Delete(name string, options *api.DeleteOption
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
horizontalPodAutoscalers
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"horizontalPodAutoscalers"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"horizontalPodAutoscalers"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
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
*
extensions
.
HorizontalPodAutoscaler
,
err
error
)
{
result
=
&
extensions
.
HorizontalPodAutoscaler
{}
...
...
@@ -108,7 +131,7 @@ func (c *horizontalPodAutoscalers) Get(name string) (result *extensions.Horizont
}
// List takes label and field selectors, and returns the list of HorizontalPodAutoscalers that match those selectors.
func
(
c
*
horizontalPodAutoscalers
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
extensions
.
HorizontalPodAutoscalerList
,
err
error
)
{
func
(
c
*
horizontalPodAutoscalers
)
List
(
opts
api
.
ListOptions
)
(
result
*
extensions
.
HorizontalPodAutoscalerList
,
err
error
)
{
result
=
&
extensions
.
HorizontalPodAutoscalerList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -120,7 +143,7 @@ func (c *horizontalPodAutoscalers) List(opts unversioned.ListOptions) (result *e
}
// Watch returns a watch.Interface that watches the requested horizontalPodAutoscalers.
func
(
c
*
horizontalPodAutoscalers
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
horizontalPodAutoscalers
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
pkg/client/typed/generated/extensions/unversioned/ingress.go
View file @
ebc14e1a
...
...
@@ -18,7 +18,6 @@ package unversioned
import
(
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
extensions
"k8s.io/kubernetes/pkg/apis/extensions"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -33,9 +32,10 @@ type IngressInterface interface {
Create
(
*
extensions
.
Ingress
)
(
*
extensions
.
Ingress
,
error
)
Update
(
*
extensions
.
Ingress
)
(
*
extensions
.
Ingress
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
extensions
.
Ingress
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
extensions
.
IngressList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
extensions
.
IngressList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// ingresses implements IngressInterface
...
...
@@ -95,6 +95,29 @@ func (c *ingresses) Delete(name string, options *api.DeleteOptions) error {
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
ingresses
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"ingresses"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"ingresses"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
Do
()
.
Error
()
}
// Get takes name of the ingress, and returns the corresponding ingress object, and an error if there is any.
func
(
c
*
ingresses
)
Get
(
name
string
)
(
result
*
extensions
.
Ingress
,
err
error
)
{
result
=
&
extensions
.
Ingress
{}
...
...
@@ -108,7 +131,7 @@ func (c *ingresses) Get(name string) (result *extensions.Ingress, err error) {
}
// List takes label and field selectors, and returns the list of Ingresses that match those selectors.
func
(
c
*
ingresses
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
extensions
.
IngressList
,
err
error
)
{
func
(
c
*
ingresses
)
List
(
opts
api
.
ListOptions
)
(
result
*
extensions
.
IngressList
,
err
error
)
{
result
=
&
extensions
.
IngressList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -120,7 +143,7 @@ func (c *ingresses) List(opts unversioned.ListOptions) (result *extensions.Ingre
}
// Watch returns a watch.Interface that watches the requested ingresses.
func
(
c
*
ingresses
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
ingresses
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
pkg/client/typed/generated/extensions/unversioned/job.go
View file @
ebc14e1a
...
...
@@ -18,7 +18,6 @@ package unversioned
import
(
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
extensions
"k8s.io/kubernetes/pkg/apis/extensions"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -33,9 +32,10 @@ type JobInterface interface {
Create
(
*
extensions
.
Job
)
(
*
extensions
.
Job
,
error
)
Update
(
*
extensions
.
Job
)
(
*
extensions
.
Job
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
extensions
.
Job
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
extensions
.
JobList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
extensions
.
JobList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// jobs implements JobInterface
...
...
@@ -95,6 +95,29 @@ func (c *jobs) Delete(name string, options *api.DeleteOptions) error {
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
jobs
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"jobs"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"jobs"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
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
*
extensions
.
Job
,
err
error
)
{
result
=
&
extensions
.
Job
{}
...
...
@@ -108,7 +131,7 @@ func (c *jobs) Get(name string) (result *extensions.Job, err error) {
}
// List takes label and field selectors, and returns the list of Jobs that match those selectors.
func
(
c
*
jobs
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
extensions
.
JobList
,
err
error
)
{
func
(
c
*
jobs
)
List
(
opts
api
.
ListOptions
)
(
result
*
extensions
.
JobList
,
err
error
)
{
result
=
&
extensions
.
JobList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -120,7 +143,7 @@ func (c *jobs) List(opts unversioned.ListOptions) (result *extensions.JobList, e
}
// Watch returns a watch.Interface that watches the requested jobs.
func
(
c
*
jobs
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
jobs
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
pkg/client/typed/generated/extensions/unversioned/thirdPartyResource.go
View file @
ebc14e1a
...
...
@@ -18,7 +18,6 @@ package unversioned
import
(
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
extensions
"k8s.io/kubernetes/pkg/apis/extensions"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -33,9 +32,10 @@ type ThirdPartyResourceInterface interface {
Create
(
*
extensions
.
ThirdPartyResource
)
(
*
extensions
.
ThirdPartyResource
,
error
)
Update
(
*
extensions
.
ThirdPartyResource
)
(
*
extensions
.
ThirdPartyResource
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
extensions
.
ThirdPartyResource
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
extensions
.
ThirdPartyResourceList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
extensions
.
ThirdPartyResourceList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// thirdPartyResources implements ThirdPartyResourceInterface
...
...
@@ -95,6 +95,29 @@ func (c *thirdPartyResources) Delete(name string, options *api.DeleteOptions) er
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
thirdPartyResources
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"thirdPartyResources"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"thirdPartyResources"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
Do
()
.
Error
()
}
// Get takes name of the thirdPartyResource, and returns the corresponding thirdPartyResource object, and an error if there is any.
func
(
c
*
thirdPartyResources
)
Get
(
name
string
)
(
result
*
extensions
.
ThirdPartyResource
,
err
error
)
{
result
=
&
extensions
.
ThirdPartyResource
{}
...
...
@@ -108,7 +131,7 @@ func (c *thirdPartyResources) Get(name string) (result *extensions.ThirdPartyRes
}
// List takes label and field selectors, and returns the list of ThirdPartyResources that match those selectors.
func
(
c
*
thirdPartyResources
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
extensions
.
ThirdPartyResourceList
,
err
error
)
{
func
(
c
*
thirdPartyResources
)
List
(
opts
api
.
ListOptions
)
(
result
*
extensions
.
ThirdPartyResourceList
,
err
error
)
{
result
=
&
extensions
.
ThirdPartyResourceList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -120,7 +143,7 @@ func (c *thirdPartyResources) List(opts unversioned.ListOptions) (result *extens
}
// Watch returns a watch.Interface that watches the requested thirdPartyResources.
func
(
c
*
thirdPartyResources
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
thirdPartyResources
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
pkg/client/typed/generated/legacy/unversioned/componentStatus.go
View file @
ebc14e1a
...
...
@@ -18,7 +18,6 @@ package unversioned
import
(
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -32,9 +31,10 @@ type ComponentStatusInterface interface {
Create
(
*
api
.
ComponentStatus
)
(
*
api
.
ComponentStatus
,
error
)
Update
(
*
api
.
ComponentStatus
)
(
*
api
.
ComponentStatus
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
api
.
ComponentStatus
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
api
.
ComponentStatusList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
api
.
ComponentStatusList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// componentStatus implements ComponentStatusInterface
...
...
@@ -94,6 +94,29 @@ func (c *componentStatus) Delete(name string, options *api.DeleteOptions) error
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
componentStatus
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"componentStatus"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"componentStatus"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
Do
()
.
Error
()
}
// Get takes name of the componentStatus, and returns the corresponding componentStatus object, and an error if there is any.
func
(
c
*
componentStatus
)
Get
(
name
string
)
(
result
*
api
.
ComponentStatus
,
err
error
)
{
result
=
&
api
.
ComponentStatus
{}
...
...
@@ -107,7 +130,7 @@ func (c *componentStatus) Get(name string) (result *api.ComponentStatus, err err
}
// List takes label and field selectors, and returns the list of ComponentStatus that match those selectors.
func
(
c
*
componentStatus
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
api
.
ComponentStatusList
,
err
error
)
{
func
(
c
*
componentStatus
)
List
(
opts
api
.
ListOptions
)
(
result
*
api
.
ComponentStatusList
,
err
error
)
{
result
=
&
api
.
ComponentStatusList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -119,7 +142,7 @@ func (c *componentStatus) List(opts unversioned.ListOptions) (result *api.Compon
}
// Watch returns a watch.Interface that watches the requested componentStatus.
func
(
c
*
componentStatus
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
componentStatus
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
pkg/client/typed/generated/legacy/unversioned/endpoints.go
View file @
ebc14e1a
...
...
@@ -18,7 +18,6 @@ package unversioned
import
(
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -32,9 +31,10 @@ type EndpointsInterface interface {
Create
(
*
api
.
Endpoints
)
(
*
api
.
Endpoints
,
error
)
Update
(
*
api
.
Endpoints
)
(
*
api
.
Endpoints
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
api
.
Endpoints
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
api
.
EndpointsList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
api
.
EndpointsList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// endpoints implements EndpointsInterface
...
...
@@ -94,6 +94,29 @@ func (c *endpoints) Delete(name string, options *api.DeleteOptions) error {
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
endpoints
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"endpoints"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"endpoints"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
Do
()
.
Error
()
}
// Get takes name of the endpoints, and returns the corresponding endpoints object, and an error if there is any.
func
(
c
*
endpoints
)
Get
(
name
string
)
(
result
*
api
.
Endpoints
,
err
error
)
{
result
=
&
api
.
Endpoints
{}
...
...
@@ -107,7 +130,7 @@ func (c *endpoints) Get(name string) (result *api.Endpoints, err error) {
}
// List takes label and field selectors, and returns the list of Endpoints that match those selectors.
func
(
c
*
endpoints
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
api
.
EndpointsList
,
err
error
)
{
func
(
c
*
endpoints
)
List
(
opts
api
.
ListOptions
)
(
result
*
api
.
EndpointsList
,
err
error
)
{
result
=
&
api
.
EndpointsList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -119,7 +142,7 @@ func (c *endpoints) List(opts unversioned.ListOptions) (result *api.EndpointsLis
}
// Watch returns a watch.Interface that watches the requested endpoints.
func
(
c
*
endpoints
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
endpoints
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
pkg/client/typed/generated/legacy/unversioned/event.go
View file @
ebc14e1a
...
...
@@ -18,7 +18,6 @@ package unversioned
import
(
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -32,9 +31,10 @@ type EventInterface interface {
Create
(
*
api
.
Event
)
(
*
api
.
Event
,
error
)
Update
(
*
api
.
Event
)
(
*
api
.
Event
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
api
.
Event
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
api
.
EventList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
api
.
EventList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// events implements EventInterface
...
...
@@ -94,6 +94,29 @@ func (c *events) Delete(name string, options *api.DeleteOptions) error {
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
events
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"events"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"events"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
Do
()
.
Error
()
}
// Get takes name of the event, and returns the corresponding event object, and an error if there is any.
func
(
c
*
events
)
Get
(
name
string
)
(
result
*
api
.
Event
,
err
error
)
{
result
=
&
api
.
Event
{}
...
...
@@ -107,7 +130,7 @@ func (c *events) Get(name string) (result *api.Event, err error) {
}
// List takes label and field selectors, and returns the list of Events that match those selectors.
func
(
c
*
events
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
api
.
EventList
,
err
error
)
{
func
(
c
*
events
)
List
(
opts
api
.
ListOptions
)
(
result
*
api
.
EventList
,
err
error
)
{
result
=
&
api
.
EventList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -119,7 +142,7 @@ func (c *events) List(opts unversioned.ListOptions) (result *api.EventList, err
}
// Watch returns a watch.Interface that watches the requested events.
func
(
c
*
events
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
events
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
pkg/client/typed/generated/legacy/unversioned/limitRange.go
View file @
ebc14e1a
...
...
@@ -18,7 +18,6 @@ package unversioned
import
(
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -32,9 +31,10 @@ type LimitRangeInterface interface {
Create
(
*
api
.
LimitRange
)
(
*
api
.
LimitRange
,
error
)
Update
(
*
api
.
LimitRange
)
(
*
api
.
LimitRange
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
api
.
LimitRange
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
api
.
LimitRangeList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
api
.
LimitRangeList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// limitRanges implements LimitRangeInterface
...
...
@@ -94,6 +94,29 @@ func (c *limitRanges) Delete(name string, options *api.DeleteOptions) error {
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
limitRanges
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"limitRanges"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"limitRanges"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
Do
()
.
Error
()
}
// Get takes name of the limitRange, and returns the corresponding limitRange object, and an error if there is any.
func
(
c
*
limitRanges
)
Get
(
name
string
)
(
result
*
api
.
LimitRange
,
err
error
)
{
result
=
&
api
.
LimitRange
{}
...
...
@@ -107,7 +130,7 @@ func (c *limitRanges) Get(name string) (result *api.LimitRange, err error) {
}
// List takes label and field selectors, and returns the list of LimitRanges that match those selectors.
func
(
c
*
limitRanges
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
api
.
LimitRangeList
,
err
error
)
{
func
(
c
*
limitRanges
)
List
(
opts
api
.
ListOptions
)
(
result
*
api
.
LimitRangeList
,
err
error
)
{
result
=
&
api
.
LimitRangeList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -119,7 +142,7 @@ func (c *limitRanges) List(opts unversioned.ListOptions) (result *api.LimitRange
}
// Watch returns a watch.Interface that watches the requested limitRanges.
func
(
c
*
limitRanges
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
limitRanges
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
pkg/client/typed/generated/legacy/unversioned/namespace.go
View file @
ebc14e1a
...
...
@@ -18,7 +18,6 @@ package unversioned
import
(
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -32,9 +31,10 @@ type NamespaceInterface interface {
Create
(
*
api
.
Namespace
)
(
*
api
.
Namespace
,
error
)
Update
(
*
api
.
Namespace
)
(
*
api
.
Namespace
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
api
.
Namespace
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
api
.
NamespaceList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
api
.
NamespaceList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// namespaces implements NamespaceInterface
...
...
@@ -94,6 +94,29 @@ func (c *namespaces) Delete(name string, options *api.DeleteOptions) error {
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
namespaces
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"namespaces"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"namespaces"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
Do
()
.
Error
()
}
// Get takes name of the namespace, and returns the corresponding namespace object, and an error if there is any.
func
(
c
*
namespaces
)
Get
(
name
string
)
(
result
*
api
.
Namespace
,
err
error
)
{
result
=
&
api
.
Namespace
{}
...
...
@@ -107,7 +130,7 @@ func (c *namespaces) Get(name string) (result *api.Namespace, err error) {
}
// List takes label and field selectors, and returns the list of Namespaces that match those selectors.
func
(
c
*
namespaces
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
api
.
NamespaceList
,
err
error
)
{
func
(
c
*
namespaces
)
List
(
opts
api
.
ListOptions
)
(
result
*
api
.
NamespaceList
,
err
error
)
{
result
=
&
api
.
NamespaceList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -119,7 +142,7 @@ func (c *namespaces) List(opts unversioned.ListOptions) (result *api.NamespaceLi
}
// Watch returns a watch.Interface that watches the requested namespaces.
func
(
c
*
namespaces
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
namespaces
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
pkg/client/typed/generated/legacy/unversioned/node.go
View file @
ebc14e1a
...
...
@@ -18,7 +18,6 @@ package unversioned
import
(
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -32,9 +31,10 @@ type NodeInterface interface {
Create
(
*
api
.
Node
)
(
*
api
.
Node
,
error
)
Update
(
*
api
.
Node
)
(
*
api
.
Node
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
api
.
Node
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
api
.
NodeList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
api
.
NodeList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// nodes implements NodeInterface
...
...
@@ -94,6 +94,29 @@ func (c *nodes) Delete(name string, options *api.DeleteOptions) error {
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
nodes
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"nodes"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"nodes"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
Do
()
.
Error
()
}
// Get takes name of the node, and returns the corresponding node object, and an error if there is any.
func
(
c
*
nodes
)
Get
(
name
string
)
(
result
*
api
.
Node
,
err
error
)
{
result
=
&
api
.
Node
{}
...
...
@@ -107,7 +130,7 @@ func (c *nodes) Get(name string) (result *api.Node, err error) {
}
// List takes label and field selectors, and returns the list of Nodes that match those selectors.
func
(
c
*
nodes
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
api
.
NodeList
,
err
error
)
{
func
(
c
*
nodes
)
List
(
opts
api
.
ListOptions
)
(
result
*
api
.
NodeList
,
err
error
)
{
result
=
&
api
.
NodeList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -119,7 +142,7 @@ func (c *nodes) List(opts unversioned.ListOptions) (result *api.NodeList, err er
}
// Watch returns a watch.Interface that watches the requested nodes.
func
(
c
*
nodes
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
nodes
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
pkg/client/typed/generated/legacy/unversioned/persistentVolume.go
View file @
ebc14e1a
...
...
@@ -18,7 +18,6 @@ package unversioned
import
(
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -32,9 +31,10 @@ type PersistentVolumeInterface interface {
Create
(
*
api
.
PersistentVolume
)
(
*
api
.
PersistentVolume
,
error
)
Update
(
*
api
.
PersistentVolume
)
(
*
api
.
PersistentVolume
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
api
.
PersistentVolume
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
api
.
PersistentVolumeList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
api
.
PersistentVolumeList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// persistentVolumes implements PersistentVolumeInterface
...
...
@@ -94,6 +94,29 @@ func (c *persistentVolumes) Delete(name string, options *api.DeleteOptions) erro
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
persistentVolumes
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"persistentVolumes"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"persistentVolumes"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
Do
()
.
Error
()
}
// Get takes name of the persistentVolume, and returns the corresponding persistentVolume object, and an error if there is any.
func
(
c
*
persistentVolumes
)
Get
(
name
string
)
(
result
*
api
.
PersistentVolume
,
err
error
)
{
result
=
&
api
.
PersistentVolume
{}
...
...
@@ -107,7 +130,7 @@ func (c *persistentVolumes) Get(name string) (result *api.PersistentVolume, err
}
// List takes label and field selectors, and returns the list of PersistentVolumes that match those selectors.
func
(
c
*
persistentVolumes
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
api
.
PersistentVolumeList
,
err
error
)
{
func
(
c
*
persistentVolumes
)
List
(
opts
api
.
ListOptions
)
(
result
*
api
.
PersistentVolumeList
,
err
error
)
{
result
=
&
api
.
PersistentVolumeList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -119,7 +142,7 @@ func (c *persistentVolumes) List(opts unversioned.ListOptions) (result *api.Pers
}
// Watch returns a watch.Interface that watches the requested persistentVolumes.
func
(
c
*
persistentVolumes
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
persistentVolumes
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
pkg/client/typed/generated/legacy/unversioned/persistentVolumeClaim.go
View file @
ebc14e1a
...
...
@@ -18,7 +18,6 @@ package unversioned
import
(
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -32,9 +31,10 @@ type PersistentVolumeClaimInterface interface {
Create
(
*
api
.
PersistentVolumeClaim
)
(
*
api
.
PersistentVolumeClaim
,
error
)
Update
(
*
api
.
PersistentVolumeClaim
)
(
*
api
.
PersistentVolumeClaim
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
api
.
PersistentVolumeClaim
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
api
.
PersistentVolumeClaimList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
api
.
PersistentVolumeClaimList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// persistentVolumeClaims implements PersistentVolumeClaimInterface
...
...
@@ -94,6 +94,29 @@ func (c *persistentVolumeClaims) Delete(name string, options *api.DeleteOptions)
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
persistentVolumeClaims
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"persistentVolumeClaims"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"persistentVolumeClaims"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
Do
()
.
Error
()
}
// Get takes name of the persistentVolumeClaim, and returns the corresponding persistentVolumeClaim object, and an error if there is any.
func
(
c
*
persistentVolumeClaims
)
Get
(
name
string
)
(
result
*
api
.
PersistentVolumeClaim
,
err
error
)
{
result
=
&
api
.
PersistentVolumeClaim
{}
...
...
@@ -107,7 +130,7 @@ func (c *persistentVolumeClaims) Get(name string) (result *api.PersistentVolumeC
}
// List takes label and field selectors, and returns the list of PersistentVolumeClaims that match those selectors.
func
(
c
*
persistentVolumeClaims
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
api
.
PersistentVolumeClaimList
,
err
error
)
{
func
(
c
*
persistentVolumeClaims
)
List
(
opts
api
.
ListOptions
)
(
result
*
api
.
PersistentVolumeClaimList
,
err
error
)
{
result
=
&
api
.
PersistentVolumeClaimList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -119,7 +142,7 @@ func (c *persistentVolumeClaims) List(opts unversioned.ListOptions) (result *api
}
// Watch returns a watch.Interface that watches the requested persistentVolumeClaims.
func
(
c
*
persistentVolumeClaims
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
persistentVolumeClaims
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
pkg/client/typed/generated/legacy/unversioned/pod.go
View file @
ebc14e1a
...
...
@@ -18,7 +18,6 @@ package unversioned
import
(
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -32,9 +31,10 @@ type PodInterface interface {
Create
(
*
api
.
Pod
)
(
*
api
.
Pod
,
error
)
Update
(
*
api
.
Pod
)
(
*
api
.
Pod
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
api
.
Pod
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
api
.
PodList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
api
.
PodList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// pods implements PodInterface
...
...
@@ -94,6 +94,29 @@ func (c *pods) Delete(name string, options *api.DeleteOptions) error {
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
pods
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"pods"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"pods"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
Do
()
.
Error
()
}
// Get takes name of the pod, and returns the corresponding pod object, and an error if there is any.
func
(
c
*
pods
)
Get
(
name
string
)
(
result
*
api
.
Pod
,
err
error
)
{
result
=
&
api
.
Pod
{}
...
...
@@ -107,7 +130,7 @@ func (c *pods) Get(name string) (result *api.Pod, err error) {
}
// List takes label and field selectors, and returns the list of Pods that match those selectors.
func
(
c
*
pods
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
api
.
PodList
,
err
error
)
{
func
(
c
*
pods
)
List
(
opts
api
.
ListOptions
)
(
result
*
api
.
PodList
,
err
error
)
{
result
=
&
api
.
PodList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -119,7 +142,7 @@ func (c *pods) List(opts unversioned.ListOptions) (result *api.PodList, err erro
}
// Watch returns a watch.Interface that watches the requested pods.
func
(
c
*
pods
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
pods
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
pkg/client/typed/generated/legacy/unversioned/podTemplate.go
View file @
ebc14e1a
...
...
@@ -18,7 +18,6 @@ package unversioned
import
(
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -32,9 +31,10 @@ type PodTemplateInterface interface {
Create
(
*
api
.
PodTemplate
)
(
*
api
.
PodTemplate
,
error
)
Update
(
*
api
.
PodTemplate
)
(
*
api
.
PodTemplate
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
api
.
PodTemplate
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
api
.
PodTemplateList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
api
.
PodTemplateList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// podTemplates implements PodTemplateInterface
...
...
@@ -94,6 +94,29 @@ func (c *podTemplates) Delete(name string, options *api.DeleteOptions) error {
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
podTemplates
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"podTemplates"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"podTemplates"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
Do
()
.
Error
()
}
// Get takes name of the podTemplate, and returns the corresponding podTemplate object, and an error if there is any.
func
(
c
*
podTemplates
)
Get
(
name
string
)
(
result
*
api
.
PodTemplate
,
err
error
)
{
result
=
&
api
.
PodTemplate
{}
...
...
@@ -107,7 +130,7 @@ func (c *podTemplates) Get(name string) (result *api.PodTemplate, err error) {
}
// List takes label and field selectors, and returns the list of PodTemplates that match those selectors.
func
(
c
*
podTemplates
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
api
.
PodTemplateList
,
err
error
)
{
func
(
c
*
podTemplates
)
List
(
opts
api
.
ListOptions
)
(
result
*
api
.
PodTemplateList
,
err
error
)
{
result
=
&
api
.
PodTemplateList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -119,7 +142,7 @@ func (c *podTemplates) List(opts unversioned.ListOptions) (result *api.PodTempla
}
// Watch returns a watch.Interface that watches the requested podTemplates.
func
(
c
*
podTemplates
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
podTemplates
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
pkg/client/typed/generated/legacy/unversioned/replicationController.go
View file @
ebc14e1a
...
...
@@ -18,7 +18,6 @@ package unversioned
import
(
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -32,9 +31,10 @@ type ReplicationControllerInterface interface {
Create
(
*
api
.
ReplicationController
)
(
*
api
.
ReplicationController
,
error
)
Update
(
*
api
.
ReplicationController
)
(
*
api
.
ReplicationController
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
api
.
ReplicationController
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
api
.
ReplicationControllerList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
api
.
ReplicationControllerList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// replicationControllers implements ReplicationControllerInterface
...
...
@@ -94,6 +94,29 @@ func (c *replicationControllers) Delete(name string, options *api.DeleteOptions)
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
replicationControllers
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"replicationControllers"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"replicationControllers"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
Do
()
.
Error
()
}
// Get takes name of the replicationController, and returns the corresponding replicationController object, and an error if there is any.
func
(
c
*
replicationControllers
)
Get
(
name
string
)
(
result
*
api
.
ReplicationController
,
err
error
)
{
result
=
&
api
.
ReplicationController
{}
...
...
@@ -107,7 +130,7 @@ func (c *replicationControllers) Get(name string) (result *api.ReplicationContro
}
// List takes label and field selectors, and returns the list of ReplicationControllers that match those selectors.
func
(
c
*
replicationControllers
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
api
.
ReplicationControllerList
,
err
error
)
{
func
(
c
*
replicationControllers
)
List
(
opts
api
.
ListOptions
)
(
result
*
api
.
ReplicationControllerList
,
err
error
)
{
result
=
&
api
.
ReplicationControllerList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -119,7 +142,7 @@ func (c *replicationControllers) List(opts unversioned.ListOptions) (result *api
}
// Watch returns a watch.Interface that watches the requested replicationControllers.
func
(
c
*
replicationControllers
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
replicationControllers
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
pkg/client/typed/generated/legacy/unversioned/resourceQuota.go
View file @
ebc14e1a
...
...
@@ -18,7 +18,6 @@ package unversioned
import
(
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -32,9 +31,10 @@ type ResourceQuotaInterface interface {
Create
(
*
api
.
ResourceQuota
)
(
*
api
.
ResourceQuota
,
error
)
Update
(
*
api
.
ResourceQuota
)
(
*
api
.
ResourceQuota
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
api
.
ResourceQuota
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
api
.
ResourceQuotaList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
api
.
ResourceQuotaList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// resourceQuotas implements ResourceQuotaInterface
...
...
@@ -94,6 +94,29 @@ func (c *resourceQuotas) Delete(name string, options *api.DeleteOptions) error {
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
resourceQuotas
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"resourceQuotas"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"resourceQuotas"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
Do
()
.
Error
()
}
// Get takes name of the resourceQuota, and returns the corresponding resourceQuota object, and an error if there is any.
func
(
c
*
resourceQuotas
)
Get
(
name
string
)
(
result
*
api
.
ResourceQuota
,
err
error
)
{
result
=
&
api
.
ResourceQuota
{}
...
...
@@ -107,7 +130,7 @@ func (c *resourceQuotas) Get(name string) (result *api.ResourceQuota, err error)
}
// List takes label and field selectors, and returns the list of ResourceQuotas that match those selectors.
func
(
c
*
resourceQuotas
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
api
.
ResourceQuotaList
,
err
error
)
{
func
(
c
*
resourceQuotas
)
List
(
opts
api
.
ListOptions
)
(
result
*
api
.
ResourceQuotaList
,
err
error
)
{
result
=
&
api
.
ResourceQuotaList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -119,7 +142,7 @@ func (c *resourceQuotas) List(opts unversioned.ListOptions) (result *api.Resourc
}
// Watch returns a watch.Interface that watches the requested resourceQuotas.
func
(
c
*
resourceQuotas
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
resourceQuotas
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
pkg/client/typed/generated/legacy/unversioned/secret.go
View file @
ebc14e1a
...
...
@@ -18,7 +18,6 @@ package unversioned
import
(
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -32,9 +31,10 @@ type SecretInterface interface {
Create
(
*
api
.
Secret
)
(
*
api
.
Secret
,
error
)
Update
(
*
api
.
Secret
)
(
*
api
.
Secret
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
api
.
Secret
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
api
.
SecretList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
api
.
SecretList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// secrets implements SecretInterface
...
...
@@ -94,6 +94,29 @@ func (c *secrets) Delete(name string, options *api.DeleteOptions) error {
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
secrets
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"secrets"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"secrets"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
Do
()
.
Error
()
}
// Get takes name of the secret, and returns the corresponding secret object, and an error if there is any.
func
(
c
*
secrets
)
Get
(
name
string
)
(
result
*
api
.
Secret
,
err
error
)
{
result
=
&
api
.
Secret
{}
...
...
@@ -107,7 +130,7 @@ func (c *secrets) Get(name string) (result *api.Secret, err error) {
}
// List takes label and field selectors, and returns the list of Secrets that match those selectors.
func
(
c
*
secrets
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
api
.
SecretList
,
err
error
)
{
func
(
c
*
secrets
)
List
(
opts
api
.
ListOptions
)
(
result
*
api
.
SecretList
,
err
error
)
{
result
=
&
api
.
SecretList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -119,7 +142,7 @@ func (c *secrets) List(opts unversioned.ListOptions) (result *api.SecretList, er
}
// Watch returns a watch.Interface that watches the requested secrets.
func
(
c
*
secrets
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
secrets
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
pkg/client/typed/generated/legacy/unversioned/service.go
View file @
ebc14e1a
...
...
@@ -18,7 +18,6 @@ package unversioned
import
(
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -32,9 +31,10 @@ type ServiceInterface interface {
Create
(
*
api
.
Service
)
(
*
api
.
Service
,
error
)
Update
(
*
api
.
Service
)
(
*
api
.
Service
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
api
.
Service
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
api
.
ServiceList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
api
.
ServiceList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// services implements ServiceInterface
...
...
@@ -94,6 +94,29 @@ func (c *services) Delete(name string, options *api.DeleteOptions) error {
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
services
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"services"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"services"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
Do
()
.
Error
()
}
// Get takes name of the service, and returns the corresponding service object, and an error if there is any.
func
(
c
*
services
)
Get
(
name
string
)
(
result
*
api
.
Service
,
err
error
)
{
result
=
&
api
.
Service
{}
...
...
@@ -107,7 +130,7 @@ func (c *services) Get(name string) (result *api.Service, err error) {
}
// List takes label and field selectors, and returns the list of Services that match those selectors.
func
(
c
*
services
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
api
.
ServiceList
,
err
error
)
{
func
(
c
*
services
)
List
(
opts
api
.
ListOptions
)
(
result
*
api
.
ServiceList
,
err
error
)
{
result
=
&
api
.
ServiceList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -119,7 +142,7 @@ func (c *services) List(opts unversioned.ListOptions) (result *api.ServiceList,
}
// Watch returns a watch.Interface that watches the requested services.
func
(
c
*
services
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
services
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
pkg/client/typed/generated/legacy/unversioned/serviceAccount.go
View file @
ebc14e1a
...
...
@@ -18,7 +18,6 @@ package unversioned
import
(
api
"k8s.io/kubernetes/pkg/api"
unversioned
"k8s.io/kubernetes/pkg/api/unversioned"
watch
"k8s.io/kubernetes/pkg/watch"
)
...
...
@@ -32,9 +31,10 @@ type ServiceAccountInterface interface {
Create
(
*
api
.
ServiceAccount
)
(
*
api
.
ServiceAccount
,
error
)
Update
(
*
api
.
ServiceAccount
)
(
*
api
.
ServiceAccount
,
error
)
Delete
(
name
string
,
options
*
api
.
DeleteOptions
)
error
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
Get
(
name
string
)
(
*
api
.
ServiceAccount
,
error
)
List
(
opts
unversioned
.
ListOptions
)
(
*
api
.
ServiceAccountList
,
error
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
List
(
opts
api
.
ListOptions
)
(
*
api
.
ServiceAccountList
,
error
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
}
// serviceAccounts implements ServiceAccountInterface
...
...
@@ -94,6 +94,29 @@ func (c *serviceAccounts) Delete(name string, options *api.DeleteOptions) error
Error
()
}
// DeleteCollection deletes a collection of objects.
func
(
c
*
serviceAccounts
)
DeleteCollection
(
options
*
api
.
DeleteOptions
,
listOptions
api
.
ListOptions
)
error
{
if
options
==
nil
{
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"serviceAccounts"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Do
()
.
Error
()
}
body
,
err
:=
api
.
Scheme
.
EncodeToVersion
(
options
,
c
.
client
.
APIVersion
()
.
String
())
if
err
!=
nil
{
return
err
}
return
c
.
client
.
Delete
()
.
NamespaceIfScoped
(
c
.
ns
,
len
(
c
.
ns
)
>
0
)
.
Resource
(
"serviceAccounts"
)
.
VersionedParams
(
&
listOptions
,
api
.
Scheme
)
.
Body
(
body
)
.
Do
()
.
Error
()
}
// Get takes name of the serviceAccount, and returns the corresponding serviceAccount object, and an error if there is any.
func
(
c
*
serviceAccounts
)
Get
(
name
string
)
(
result
*
api
.
ServiceAccount
,
err
error
)
{
result
=
&
api
.
ServiceAccount
{}
...
...
@@ -107,7 +130,7 @@ func (c *serviceAccounts) Get(name string) (result *api.ServiceAccount, err erro
}
// List takes label and field selectors, and returns the list of ServiceAccounts that match those selectors.
func
(
c
*
serviceAccounts
)
List
(
opts
unversioned
.
ListOptions
)
(
result
*
api
.
ServiceAccountList
,
err
error
)
{
func
(
c
*
serviceAccounts
)
List
(
opts
api
.
ListOptions
)
(
result
*
api
.
ServiceAccountList
,
err
error
)
{
result
=
&
api
.
ServiceAccountList
{}
err
=
c
.
client
.
Get
()
.
Namespace
(
c
.
ns
)
.
...
...
@@ -119,7 +142,7 @@ func (c *serviceAccounts) List(opts unversioned.ListOptions) (result *api.Servic
}
// Watch returns a watch.Interface that watches the requested serviceAccounts.
func
(
c
*
serviceAccounts
)
Watch
(
opts
unversioned
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
func
(
c
*
serviceAccounts
)
Watch
(
opts
api
.
ListOptions
)
(
watch
.
Interface
,
error
)
{
return
c
.
client
.
Get
()
.
Prefix
(
"watch"
)
.
Namespace
(
c
.
ns
)
.
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment