mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-03 01:06:27 +00:00
Merge pull request #10716 from justinsb/spelling
Misc (non-code) spelling fixes
This commit is contained in:
commit
bb6f2f7ad9
@ -769,7 +769,7 @@ function kube-down {
|
|||||||
echo "Bringing down cluster"
|
echo "Bringing down cluster"
|
||||||
set +e # Do not stop on error
|
set +e # Do not stop on error
|
||||||
|
|
||||||
# The gcloud APIs don't return machine parsable error codes/retry information. Therefore the best we can
|
# The gcloud APIs don't return machine parseable error codes/retry information. Therefore the best we can
|
||||||
# do is parse the output and special case particular responses we are interested in.
|
# do is parse the output and special case particular responses we are interested in.
|
||||||
if gcloud preview managed-instance-groups --project "${PROJECT}" --zone "${ZONE}" describe "${NODE_INSTANCE_PREFIX}-group" &>/dev/null; then
|
if gcloud preview managed-instance-groups --project "${PROJECT}" --zone "${ZONE}" describe "${NODE_INSTANCE_PREFIX}-group" &>/dev/null; then
|
||||||
deleteCmdOutput=$(gcloud preview managed-instance-groups --zone "${ZONE}" delete \
|
deleteCmdOutput=$(gcloud preview managed-instance-groups --zone "${ZONE}" delete \
|
||||||
@ -777,7 +777,7 @@ function kube-down {
|
|||||||
--quiet \
|
--quiet \
|
||||||
"${NODE_INSTANCE_PREFIX}-group")
|
"${NODE_INSTANCE_PREFIX}-group")
|
||||||
if [[ "$deleteCmdOutput" != "" ]]; then
|
if [[ "$deleteCmdOutput" != "" ]]; then
|
||||||
# Managed instance group deletion is done asyncronously, we must wait for it to complete, or subsequent steps fail
|
# Managed instance group deletion is done asynchronously, we must wait for it to complete, or subsequent steps fail
|
||||||
deleteCmdOperationId=$(echo $deleteCmdOutput | grep "Operation:" | sed "s/.*Operation:[[:space:]]*\([^[:space:]]*\).*/\1/g")
|
deleteCmdOperationId=$(echo $deleteCmdOutput | grep "Operation:" | sed "s/.*Operation:[[:space:]]*\([^[:space:]]*\).*/\1/g")
|
||||||
if [[ "$deleteCmdOperationId" != "" ]]; then
|
if [[ "$deleteCmdOperationId" != "" ]]; then
|
||||||
deleteCmdStatus="PENDING"
|
deleteCmdStatus="PENDING"
|
||||||
|
@ -90,7 +90,7 @@ var (
|
|||||||
type SyncHandler interface {
|
type SyncHandler interface {
|
||||||
|
|
||||||
// Syncs current state to match the specified pods. SyncPodType specified what
|
// Syncs current state to match the specified pods. SyncPodType specified what
|
||||||
// type of sync is occuring per pod. StartTime specifies the time at which
|
// type of sync is occurring per pod. StartTime specifies the time at which
|
||||||
// syncing began (for use in monitoring).
|
// syncing began (for use in monitoring).
|
||||||
SyncPods(pods []*api.Pod, podSyncTypes map[types.UID]SyncPodType, mirrorPods map[string]*api.Pod,
|
SyncPods(pods []*api.Pod, podSyncTypes map[types.UID]SyncPodType, mirrorPods map[string]*api.Pod,
|
||||||
startTime time.Time) error
|
startTime time.Time) error
|
||||||
@ -417,7 +417,7 @@ type Kubelet struct {
|
|||||||
serviceLister serviceLister
|
serviceLister serviceLister
|
||||||
nodeLister nodeLister
|
nodeLister nodeLister
|
||||||
|
|
||||||
// Last timestamp when runtime responsed on ping.
|
// Last timestamp when runtime responded on ping.
|
||||||
// Mutex is used to protect this value.
|
// Mutex is used to protect this value.
|
||||||
runtimeMutex sync.Mutex
|
runtimeMutex sync.Mutex
|
||||||
runtimeUpThreshold time.Duration
|
runtimeUpThreshold time.Duration
|
||||||
@ -479,7 +479,7 @@ type Kubelet struct {
|
|||||||
// will only be fresh values from Kubelet at an interval of nodeStatusUpdateFrequency.
|
// will only be fresh values from Kubelet at an interval of nodeStatusUpdateFrequency.
|
||||||
// The constant must be less than podEvictionTimeout.
|
// The constant must be less than podEvictionTimeout.
|
||||||
// 2. nodeStatusUpdateFrequency needs to be large enough for kubelet to generate node
|
// 2. nodeStatusUpdateFrequency needs to be large enough for kubelet to generate node
|
||||||
// status. Kubelet may fail to update node status reliablly if the value is too small,
|
// status. Kubelet may fail to update node status reliably if the value is too small,
|
||||||
// as it takes time to gather all necessary node information.
|
// as it takes time to gather all necessary node information.
|
||||||
nodeStatusUpdateFrequency time.Duration
|
nodeStatusUpdateFrequency time.Duration
|
||||||
|
|
||||||
@ -669,7 +669,7 @@ func (kl *Kubelet) GetNode() (*api.Node, error) {
|
|||||||
return nil, fmt.Errorf("node %v not found", nodeName)
|
return nil, fmt.Errorf("node %v not found", nodeName)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Starts garbage collection theads.
|
// Starts garbage collection threads.
|
||||||
func (kl *Kubelet) StartGarbageCollection() {
|
func (kl *Kubelet) StartGarbageCollection() {
|
||||||
go util.Forever(func() {
|
go util.Forever(func() {
|
||||||
if err := kl.containerGC.GarbageCollect(); err != nil {
|
if err := kl.containerGC.GarbageCollect(); err != nil {
|
||||||
@ -932,7 +932,7 @@ func (kl *Kubelet) getServiceEnvVarMap(ns string) (map[string]string, error) {
|
|||||||
)
|
)
|
||||||
|
|
||||||
// Get all service resources from the master (via a cache),
|
// Get all service resources from the master (via a cache),
|
||||||
// and populate them into service enviroment variables.
|
// and populate them into service environment variables.
|
||||||
if kl.serviceLister == nil {
|
if kl.serviceLister == nil {
|
||||||
// Kubelets without masters (e.g. plain GCE ContainerVM) don't set env vars.
|
// Kubelets without masters (e.g. plain GCE ContainerVM) don't set env vars.
|
||||||
return m, nil
|
return m, nil
|
||||||
|
@ -520,7 +520,7 @@ var _ = Describe("Nodes", func() {
|
|||||||
Logf("Waiting for node %s to be ready", node.Name)
|
Logf("Waiting for node %s to be ready", node.Name)
|
||||||
waitForNodeToBe(c, node.Name, true, 2*time.Minute)
|
waitForNodeToBe(c, node.Name, true, 2*time.Minute)
|
||||||
|
|
||||||
By("verify wheter new pods can be created on the re-attached node")
|
By("verify whether new pods can be created on the re-attached node")
|
||||||
// increasing the RC size is not a valid way to test this
|
// increasing the RC size is not a valid way to test this
|
||||||
// since we have no guarantees the pod will be scheduled on our node.
|
// since we have no guarantees the pod will be scheduled on our node.
|
||||||
additionalPod := "additionalpod"
|
additionalPod := "additionalpod"
|
||||||
|
@ -842,7 +842,7 @@ func startCmdAndStreamOutput(cmd *exec.Cmd) (stdout, stderr io.ReadCloser, err e
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
Logf("Asyncronously running '%s %s'", cmd.Path, strings.Join(cmd.Args, " "))
|
Logf("Asynchronously running '%s %s'", cmd.Path, strings.Join(cmd.Args, " "))
|
||||||
err = cmd.Start()
|
err = cmd.Start()
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user