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
f03a2670
Commit
f03a2670
authored
Sep 15, 2015
by
k8s-merge-robot
Browse files
Options
Browse Files
Download
Plain Diff
Merge pull request #13895 from jhadvig/typos_fix
Auto commit by PR queue bot
parents
7d7ceea0
7582e90d
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
2 additions
and
2 deletions
+2
-2
nodecontroller.go
pkg/controller/node/nodecontroller.go
+1
-1
mux.go
pkg/watch/mux.go
+1
-1
No files found.
pkg/controller/node/nodecontroller.go
View file @
f03a2670
...
...
@@ -417,7 +417,7 @@ func (nc *NodeController) recordNodeStatusChange(node *api.Node, new_status stri
}
// For a given node checks its conditions and tries to update it. Returns grace period to which given node
// is entitled, state of current and last observed Ready Condition, and an error if it oc
u
red.
// is entitled, state of current and last observed Ready Condition, and an error if it oc
cur
red.
func
(
nc
*
NodeController
)
tryUpdateNodeStatus
(
node
*
api
.
Node
)
(
time
.
Duration
,
api
.
NodeCondition
,
*
api
.
NodeCondition
,
error
)
{
var
err
error
var
gracePeriod
time
.
Duration
...
...
pkg/watch/mux.go
View file @
f03a2670
...
...
@@ -59,7 +59,7 @@ type Broadcaster struct {
}
// NewBroadcaster creates a new Broadcaster. queueLength is the maximum number of events to queue per watcher.
// It is guaranteed that events will be dist
ibuted in the order in which they o
cur,
// It is guaranteed that events will be dist
ributed in the order in which they oc
cur,
// but the order in which a single event is distributed among all of the watchers is unspecified.
func
NewBroadcaster
(
queueLength
int
,
fullChannelBehavior
FullChannelBehavior
)
*
Broadcaster
{
m
:=
&
Broadcaster
{
...
...
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