mirror of https://github.com/k3s-io/k3s
Minor typos fix
parent
00192ee944
commit
7582e90d01
|
@ -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 ocured.
|
||||
// is entitled, state of current and last observed Ready Condition, and an error if it occurred.
|
||||
func (nc *NodeController) tryUpdateNodeStatus(node *api.Node) (time.Duration, api.NodeCondition, *api.NodeCondition, error) {
|
||||
var err error
|
||||
var gracePeriod time.Duration
|
||||
|
|
|
@ -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 distibuted in the order in which they ocur,
|
||||
// It is guaranteed that events will be distributed in the order in which they occur,
|
||||
// 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{
|
||||
|
|
Loading…
Reference in New Issue