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
9e8d4b41
Commit
9e8d4b41
authored
Jul 29, 2017
by
jianglingxia
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Renamed packge name to apiv1
parent
60007128
Hide whitespace changes
Inline
Side-by-side
Showing
6 changed files
with
17 additions
and
17 deletions
+17
-17
deployment_util_test.go
pkg/controller/deployment/util/deployment_util_test.go
+3
-3
tokengetter.go
pkg/controller/serviceaccount/tokengetter.go
+3
-3
factory.go
pkg/kubectl/cmd/util/factory.go
+3
-3
history.go
pkg/kubectl/history.go
+2
-2
rollback.go
pkg/kubectl/rollback.go
+4
-4
rolling_updater.go
pkg/kubectl/rolling_updater.go
+2
-2
No files found.
pkg/controller/deployment/util/deployment_util_test.go
View file @
9e8d4b41
...
...
@@ -35,7 +35,7 @@ import (
"k8s.io/client-go/kubernetes/fake"
"k8s.io/client-go/kubernetes/scheme"
core
"k8s.io/client-go/testing"
k8s_api_
v1
"k8s.io/kubernetes/pkg/api/v1"
api
v1
"k8s.io/kubernetes/pkg/api/v1"
"k8s.io/kubernetes/pkg/controller"
)
...
...
@@ -147,7 +147,7 @@ func generatePod(labels map[string]string, image string) v1.Pod {
func
generateRSWithLabel
(
labels
map
[
string
]
string
,
image
string
)
extensions
.
ReplicaSet
{
return
extensions
.
ReplicaSet
{
ObjectMeta
:
metav1
.
ObjectMeta
{
Name
:
k8s_api_
v1
.
SimpleNameGenerator
.
GenerateName
(
"replicaset"
),
Name
:
api
v1
.
SimpleNameGenerator
.
GenerateName
(
"replicaset"
),
Labels
:
labels
,
},
Spec
:
extensions
.
ReplicaSetSpec
{
...
...
@@ -190,7 +190,7 @@ func generateRS(deployment extensions.Deployment) extensions.ReplicaSet {
return
extensions
.
ReplicaSet
{
ObjectMeta
:
metav1
.
ObjectMeta
{
UID
:
randomUID
(),
Name
:
k8s_api_
v1
.
SimpleNameGenerator
.
GenerateName
(
"replicaset"
),
Name
:
api
v1
.
SimpleNameGenerator
.
GenerateName
(
"replicaset"
),
Labels
:
template
.
Labels
,
OwnerReferences
:
[]
metav1
.
OwnerReference
{
*
newDControllerRef
(
&
deployment
)},
},
...
...
pkg/controller/serviceaccount/tokengetter.go
View file @
9e8d4b41
...
...
@@ -23,7 +23,7 @@ import (
"k8s.io/apiserver/pkg/registry/generic"
"k8s.io/apiserver/pkg/storage/storagebackend"
clientset
"k8s.io/client-go/kubernetes"
k8s_api_
v1
"k8s.io/kubernetes/pkg/api/v1"
api
v1
"k8s.io/kubernetes/pkg/api/v1"
"k8s.io/kubernetes/pkg/registry/core/secret"
secretstore
"k8s.io/kubernetes/pkg/registry/core/secret/storage"
serviceaccountregistry
"k8s.io/kubernetes/pkg/registry/core/serviceaccount"
...
...
@@ -68,7 +68,7 @@ func (r *registryGetter) GetServiceAccount(namespace, name string) (*v1.ServiceA
return
nil
,
err
}
v1ServiceAccount
:=
v1
.
ServiceAccount
{}
err
=
k8s_api_
v1
.
Convert_api_ServiceAccount_To_v1_ServiceAccount
(
internalServiceAccount
,
&
v1ServiceAccount
,
nil
)
err
=
api
v1
.
Convert_api_ServiceAccount_To_v1_ServiceAccount
(
internalServiceAccount
,
&
v1ServiceAccount
,
nil
)
return
&
v1ServiceAccount
,
err
}
...
...
@@ -79,7 +79,7 @@ func (r *registryGetter) GetSecret(namespace, name string) (*v1.Secret, error) {
return
nil
,
err
}
v1Secret
:=
v1
.
Secret
{}
err
=
k8s_api_
v1
.
Convert_api_Secret_To_v1_Secret
(
internalSecret
,
&
v1Secret
,
nil
)
err
=
api
v1
.
Convert_api_Secret_To_v1_Secret
(
internalSecret
,
&
v1Secret
,
nil
)
return
&
v1Secret
,
err
}
...
...
pkg/kubectl/cmd/util/factory.go
View file @
9e8d4b41
...
...
@@ -47,7 +47,7 @@ import (
"k8s.io/client-go/tools/clientcmd"
fedclientset
"k8s.io/kubernetes/federation/client/clientset_generated/federation_clientset"
"k8s.io/kubernetes/pkg/api"
k8s_api_
v1
"k8s.io/kubernetes/pkg/api/v1"
api
v1
"k8s.io/kubernetes/pkg/api/v1"
"k8s.io/kubernetes/pkg/api/validation"
"k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset"
coreclient
"k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset/typed/core/internalversion"
...
...
@@ -296,13 +296,13 @@ func GetFirstPod(client coreclient.PodsGetter, namespace string, selector labels
for
i
:=
range
podList
.
Items
{
pod
:=
podList
.
Items
[
i
]
externalPod
:=
&
v1
.
Pod
{}
k8s_api_
v1
.
Convert_api_Pod_To_v1_Pod
(
&
pod
,
externalPod
,
nil
)
api
v1
.
Convert_api_Pod_To_v1_Pod
(
&
pod
,
externalPod
,
nil
)
pods
=
append
(
pods
,
externalPod
)
}
if
len
(
pods
)
>
0
{
sort
.
Sort
(
sortBy
(
pods
))
internalPod
:=
&
api
.
Pod
{}
k8s_api_
v1
.
Convert_v1_Pod_To_api_Pod
(
pods
[
0
],
internalPod
,
nil
)
api
v1
.
Convert_v1_Pod_To_api_Pod
(
pods
[
0
],
internalPod
,
nil
)
return
internalPod
,
len
(
podList
.
Items
),
nil
}
...
...
pkg/kubectl/history.go
View file @
9e8d4b41
...
...
@@ -33,7 +33,7 @@ import (
"k8s.io/apimachinery/pkg/util/strategicpatch"
externalclientset
"k8s.io/client-go/kubernetes"
"k8s.io/kubernetes/pkg/api"
k8s_api_
v1
"k8s.io/kubernetes/pkg/api/v1"
api
v1
"k8s.io/kubernetes/pkg/api/v1"
"k8s.io/kubernetes/pkg/apis/apps"
"k8s.io/kubernetes/pkg/apis/extensions"
clientset
"k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset"
...
...
@@ -138,7 +138,7 @@ func (h *DeploymentHistoryViewer) ViewHistory(namespace, name string, revision i
func
printTemplate
(
template
*
v1
.
PodTemplateSpec
)
(
string
,
error
)
{
buf
:=
bytes
.
NewBuffer
([]
byte
{})
internalTemplate
:=
&
api
.
PodTemplateSpec
{}
if
err
:=
k8s_api_
v1
.
Convert_v1_PodTemplateSpec_To_api_PodTemplateSpec
(
template
,
internalTemplate
,
nil
);
err
!=
nil
{
if
err
:=
api
v1
.
Convert_v1_PodTemplateSpec_To_api_PodTemplateSpec
(
template
,
internalTemplate
,
nil
);
err
!=
nil
{
return
""
,
fmt
.
Errorf
(
"failed to convert podtemplate, %v"
,
err
)
}
w
:=
printersinternal
.
NewPrefixWriter
(
buf
)
...
...
pkg/kubectl/rollback.go
View file @
9e8d4b41
...
...
@@ -33,7 +33,7 @@ import (
"k8s.io/apimachinery/pkg/types"
"k8s.io/apimachinery/pkg/watch"
"k8s.io/kubernetes/pkg/api"
k8s_api_
v1
"k8s.io/kubernetes/pkg/api/v1"
api
v1
"k8s.io/kubernetes/pkg/api/v1"
"k8s.io/kubernetes/pkg/apis/apps"
"k8s.io/kubernetes/pkg/apis/extensions"
clientset
"k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset"
...
...
@@ -181,7 +181,7 @@ func simpleDryRun(deployment *extensions.Deployment, c clientset.Interface, toRe
}
buf
:=
bytes
.
NewBuffer
([]
byte
{})
internalTemplate
:=
&
api
.
PodTemplateSpec
{}
if
err
:=
k8s_api_
v1
.
Convert_v1_PodTemplateSpec_To_api_PodTemplateSpec
(
template
,
internalTemplate
,
nil
);
err
!=
nil
{
if
err
:=
api
v1
.
Convert_v1_PodTemplateSpec_To_api_PodTemplateSpec
(
template
,
internalTemplate
,
nil
);
err
!=
nil
{
return
""
,
fmt
.
Errorf
(
"failed to convert podtemplate, %v"
,
err
)
}
w
:=
printersinternal
.
NewPrefixWriter
(
buf
)
...
...
@@ -200,7 +200,7 @@ func simpleDryRun(deployment *extensions.Deployment, c clientset.Interface, toRe
buf
:=
bytes
.
NewBuffer
([]
byte
{})
buf
.
WriteString
(
"
\n
"
)
internalTemplate
:=
&
api
.
PodTemplateSpec
{}
if
err
:=
k8s_api_
v1
.
Convert_v1_PodTemplateSpec_To_api_PodTemplateSpec
(
template
,
internalTemplate
,
nil
);
err
!=
nil
{
if
err
:=
api
v1
.
Convert_v1_PodTemplateSpec_To_api_PodTemplateSpec
(
template
,
internalTemplate
,
nil
);
err
!=
nil
{
return
""
,
fmt
.
Errorf
(
"failed to convert podtemplate, %v"
,
err
)
}
w
:=
printersinternal
.
NewPrefixWriter
(
buf
)
...
...
@@ -258,7 +258,7 @@ func (r *DaemonSetRollbacker) Rollback(obj runtime.Object, updatedAnnotations ma
content
:=
bytes
.
NewBuffer
([]
byte
{})
w
:=
printersinternal
.
NewPrefixWriter
(
content
)
internalTemplate
:=
&
api
.
PodTemplateSpec
{}
if
err
:=
k8s_api_
v1
.
Convert_v1_PodTemplateSpec_To_api_PodTemplateSpec
(
&
appliedDS
.
Spec
.
Template
,
internalTemplate
,
nil
);
err
!=
nil
{
if
err
:=
api
v1
.
Convert_v1_PodTemplateSpec_To_api_PodTemplateSpec
(
&
appliedDS
.
Spec
.
Template
,
internalTemplate
,
nil
);
err
!=
nil
{
return
""
,
fmt
.
Errorf
(
"failed to convert podtemplate while printing: %v"
,
err
)
}
printersinternal
.
DescribePodTemplate
(
internalTemplate
,
w
)
...
...
pkg/kubectl/rolling_updater.go
View file @
9e8d4b41
...
...
@@ -32,7 +32,7 @@ import (
"k8s.io/apimachinery/pkg/util/wait"
"k8s.io/client-go/util/integer"
"k8s.io/kubernetes/pkg/api"
k8s_api_
v1
"k8s.io/kubernetes/pkg/api/v1"
api
v1
"k8s.io/kubernetes/pkg/api/v1"
podutil
"k8s.io/kubernetes/pkg/api/v1/pod"
coreclient
"k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset/typed/core/internalversion"
"k8s.io/kubernetes/pkg/client/retry"
...
...
@@ -424,7 +424,7 @@ func (r *RollingUpdater) readyPods(oldRc, newRc *api.ReplicationController, minR
}
for
_
,
pod
:=
range
pods
.
Items
{
v1Pod
:=
&
v1
.
Pod
{}
if
err
:=
k8s_api_
v1
.
Convert_api_Pod_To_v1_Pod
(
&
pod
,
v1Pod
,
nil
);
err
!=
nil
{
if
err
:=
api
v1
.
Convert_api_Pod_To_v1_Pod
(
&
pod
,
v1Pod
,
nil
);
err
!=
nil
{
return
0
,
0
,
err
}
// Do not count deleted pods as ready
...
...
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