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
ffeca161
Unverified
Commit
ffeca161
authored
May 25, 2018
by
liz
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Remove some unnecessarily gendered pronouns in comments
parent
8306b0b1
Hide whitespace changes
Inline
Side-by-side
Showing
4 changed files
with
4 additions
and
4 deletions
+4
-4
reset.go
cmd/kubeadm/app/cmd/reset.go
+1
-1
defaults.go
pkg/scheduler/algorithmprovider/defaults/defaults.go
+1
-1
extender_test.go
pkg/scheduler/core/extender_test.go
+1
-1
maxinflight.go
...ng/src/k8s.io/apiserver/pkg/server/filters/maxinflight.go
+1
-1
No files found.
cmd/kubeadm/app/cmd/reset.go
View file @
ffeca161
...
...
@@ -156,7 +156,7 @@ func (r *Reset) Run(out io.Writer) error {
dirsToClean
:=
[]
string
{
"/var/lib/kubelet"
,
"/etc/cni/net.d"
,
"/var/lib/dockershim"
,
"/var/run/kubernetes"
}
// Only clear etcd data when the etcd manifest is found. In case it is not found, we must assume that the user
// provided external etcd endpoints. In that case, it is
his
own responsibility to reset etcd
// provided external etcd endpoints. In that case, it is
their
own responsibility to reset etcd
etcdManifestPath
:=
filepath
.
Join
(
kubeadmconstants
.
KubernetesDir
,
kubeadmconstants
.
ManifestsSubDirName
,
"etcd.yaml"
)
glog
.
V
(
1
)
.
Infof
(
"[reset] checking for etcd manifest"
)
if
_
,
err
:=
os
.
Stat
(
etcdManifestPath
);
err
==
nil
{
...
...
pkg/scheduler/algorithmprovider/defaults/defaults.go
View file @
ffeca161
...
...
@@ -56,7 +56,7 @@ func init() {
// For example:
// https://github.com/kubernetes/kubernetes/blob/36a218e/plugin/pkg/scheduler/factory/factory.go#L422
// Registers predicates and priorities that are not enabled by default, but user can pick when creating
his
// Registers predicates and priorities that are not enabled by default, but user can pick when creating
their
// own set of priorities/predicates.
// PodFitsPorts has been replaced by PodFitsHostPorts for better user understanding.
...
...
pkg/scheduler/core/extender_test.go
View file @
ffeca161
...
...
@@ -135,7 +135,7 @@ func (f *FakeExtender) ProcessPreemption(
nodeToVictimsCopy
:=
map
[
*
v1
.
Node
]
*
schedulerapi
.
Victims
{}
// We don't want to change the original nodeToVictims
for
k
,
v
:=
range
nodeToVictims
{
// In real world implementation, extender's user should have
his
own way to get node object
// In real world implementation, extender's user should have
their
own way to get node object
// by name if needed (e.g. query kube-apiserver etc).
//
// For test purpose, we just use node from parameters directly.
...
...
staging/src/k8s.io/apiserver/pkg/server/filters/maxinflight.go
View file @
ffeca161
...
...
@@ -167,7 +167,7 @@ func WithMaxInFlightLimit(
metrics
.
DroppedRequests
.
WithLabelValues
(
metrics
.
ReadOnlyKind
)
.
Inc
()
}
// at this point we're about to return a 429, BUT not all actors should be rate limited. A system:master is so powerful
// that
he
should always get an answer. It's a super-admin or a loopback connection.
// that
they
should always get an answer. It's a super-admin or a loopback connection.
if
currUser
,
ok
:=
apirequest
.
UserFrom
(
ctx
);
ok
{
for
_
,
group
:=
range
currUser
.
GetGroups
()
{
if
group
==
user
.
SystemPrivilegedGroup
{
...
...
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