diff --git a/pkg/controller/garbagecollector/rate_limiter_helper.go b/pkg/controller/garbagecollector/rate_limiter_helper.go index 8d43d28be40..26d89389154 100644 --- a/pkg/controller/garbagecollector/rate_limiter_helper.go +++ b/pkg/controller/garbagecollector/rate_limiter_helper.go @@ -32,7 +32,7 @@ type RegisteredRateLimiter struct { rateLimiters map[schema.GroupVersion]*sync.Once } -// NewRegisteredRateLimiter returns a new RegisteredRateLimiater. +// NewRegisteredRateLimiter returns a new RegisteredRateLimiter. // TODO: NewRegisteredRateLimiter is not dynamic. We need to find a better way // when GC dynamically change the resources it monitors. func NewRegisteredRateLimiter(resources map[schema.GroupVersionResource]struct{}) *RegisteredRateLimiter { diff --git a/pkg/kubelet/eviction/eviction_manager.go b/pkg/kubelet/eviction/eviction_manager.go index f4b19cd5441..5841afe7cdd 100644 --- a/pkg/kubelet/eviction/eviction_manager.go +++ b/pkg/kubelet/eviction/eviction_manager.go @@ -309,8 +309,8 @@ func (m *managerImpl) synchronize(diskInfoProvider DiskInfoProvider, podFunc Act m.lastObservations = observations m.Unlock() - // evict pods if there is a resource uage violation from local volume temporary storage - // If eviction happenes in localVolumeEviction function, skip the rest of eviction action + // evict pods if there is a resource usage violation from local volume temporary storage + // If eviction happens in localVolumeEviction function, skip the rest of eviction action if utilfeature.DefaultFeatureGate.Enabled(features.LocalStorageCapacityIsolation) { if evictedPods := m.localStorageEviction(activePods); len(evictedPods) > 0 { return evictedPods diff --git a/pkg/kubelet/remote/remote_runtime.go b/pkg/kubelet/remote/remote_runtime.go index 647c564b7e3..250dbdb7b26 100644 --- a/pkg/kubelet/remote/remote_runtime.go +++ b/pkg/kubelet/remote/remote_runtime.go @@ -38,20 +38,20 @@ type RemoteRuntimeService struct { } // NewRemoteRuntimeService creates a new internalapi.RuntimeService. -func NewRemoteRuntimeService(endpoint string, connectionTimout time.Duration) (internalapi.RuntimeService, error) { +func NewRemoteRuntimeService(endpoint string, connectionTimeout time.Duration) (internalapi.RuntimeService, error) { glog.Infof("Connecting to runtime service %s", endpoint) addr, dailer, err := util.GetAddressAndDialer(endpoint) if err != nil { return nil, err } - conn, err := grpc.Dial(addr, grpc.WithInsecure(), grpc.WithTimeout(connectionTimout), grpc.WithDialer(dailer)) + conn, err := grpc.Dial(addr, grpc.WithInsecure(), grpc.WithTimeout(connectionTimeout), grpc.WithDialer(dailer)) if err != nil { glog.Errorf("Connect remote runtime %s failed: %v", addr, err) return nil, err } return &RemoteRuntimeService{ - timeout: connectionTimout, + timeout: connectionTimeout, runtimeClient: runtimeapi.NewRuntimeServiceClient(conn), }, nil } diff --git a/pkg/kubelet/rkt/rkt.go b/pkg/kubelet/rkt/rkt.go index fb42a5c6523..1d79761a670 100644 --- a/pkg/kubelet/rkt/rkt.go +++ b/pkg/kubelet/rkt/rkt.go @@ -847,7 +847,7 @@ func (r *Runtime) newAppcRuntimeApp(pod *v1.Pod, podIP string, c v1.Container, r return err } - // Create additional mount for termintation message path. + // Create additional mount for termination message path. mount, err := r.makeContainerLogMount(opts, &c) if err != nil { return err