Fix typos like limitting

pull/564/head
danielqsj 2018-12-04 11:01:40 +08:00
parent 8f7405ec92
commit 3c055aa4b4
8 changed files with 7 additions and 7 deletions

View File

@ -5,7 +5,7 @@ go_library(
srcs = [ srcs = [
"doc.go", "doc.go",
"horizontal.go", "horizontal.go",
"rate_limitters.go", "rate_limiters.go",
"replica_calculator.go", "replica_calculator.go",
], ],
importpath = "k8s.io/kubernetes/pkg/controller/podautoscaler", importpath = "k8s.io/kubernetes/pkg/controller/podautoscaler",

View File

@ -179,7 +179,7 @@ func (a *HorizontalController) enqueueHPA(obj interface{}) {
return return
} }
// always add rate-limitted so we don't fetch metrics more that once per resync interval // always add rate-limited so we don't fetch metrics more that once per resync interval
a.queue.AddRateLimited(key) a.queue.AddRateLimited(key)
} }

View File

@ -46,7 +46,7 @@ func (r *FixedItemIntervalRateLimiter) NumRequeues(item interface{}) int {
func (r *FixedItemIntervalRateLimiter) Forget(item interface{}) { func (r *FixedItemIntervalRateLimiter) Forget(item interface{}) {
} }
// NewDefaultHPARateLimiter creates a rate limitter which limits overall (as per the // NewDefaultHPARateLimiter creates a rate limiter which limits overall (as per the
// default controller rate limiter), as well as per the resync interval // default controller rate limiter), as well as per the resync interval
func NewDefaultHPARateLimiter(interval time.Duration) workqueue.RateLimiter { func NewDefaultHPARateLimiter(interval time.Duration) workqueue.RateLimiter {
return NewFixedItemIntervalRateLimiter(interval) return NewFixedItemIntervalRateLimiter(interval)

View File

@ -46,7 +46,7 @@ func NewCmdConfig(f cmdutil.Factory, pathOptions *clientcmd.PathOptions, streams
The loading order follows these rules: The loading order follows these rules:
1. If the --` + pathOptions.ExplicitFileFlag + ` flag is set, then only that file is loaded. The flag may only be set once and no merging takes place. 1. If the --` + pathOptions.ExplicitFileFlag + ` flag is set, then only that file is loaded. The flag may only be set once and no merging takes place.
2. If $` + pathOptions.EnvVar + ` environment variable is set, then it is used as a list of paths (normal path delimitting rules for your system). These paths are merged. When a value is modified, it is modified in the file that defines the stanza. When a value is created, it is created in the first file that exists. If no files in the chain exist, then it creates the last file in the list. 2. If $` + pathOptions.EnvVar + ` environment variable is set, then it is used as a list of paths (normal path delimiting rules for your system). These paths are merged. When a value is modified, it is modified in the file that defines the stanza. When a value is created, it is created in the first file that exists. If no files in the chain exist, then it creates the last file in the list.
3. Otherwise, ` + path.Join("${HOME}", pathOptions.GlobalFileSubpath) + ` is used and no merging takes place.`), 3. Otherwise, ` + path.Join("${HOME}", pathOptions.GlobalFileSubpath) + ` is used and no merging takes place.`),
Run: cmdutil.DefaultSubCommandRun(streams.ErrOut), Run: cmdutil.DefaultSubCommandRun(streams.ErrOut),
} }

View File

@ -13,7 +13,7 @@ go_test(
"delaying_queue_test.go", "delaying_queue_test.go",
"metrics_test.go", "metrics_test.go",
"queue_test.go", "queue_test.go",
"rate_limitting_queue_test.go", "rate_limiting_queue_test.go",
], ],
embed = [":go_default_library"], embed = [":go_default_library"],
deps = [ deps = [
@ -31,7 +31,7 @@ go_library(
"metrics.go", "metrics.go",
"parallelizer.go", "parallelizer.go",
"queue.go", "queue.go",
"rate_limitting_queue.go", "rate_limiting_queue.go",
], ],
importmap = "k8s.io/kubernetes/vendor/k8s.io/client-go/util/workqueue", importmap = "k8s.io/kubernetes/vendor/k8s.io/client-go/util/workqueue",
importpath = "k8s.io/client-go/util/workqueue", importpath = "k8s.io/client-go/util/workqueue",

View File

@ -35,7 +35,7 @@ type RateLimiter interface {
} }
// DefaultControllerRateLimiter is a no-arg constructor for a default rate limiter for a workqueue. It has // DefaultControllerRateLimiter is a no-arg constructor for a default rate limiter for a workqueue. It has
// both overall and per-item rate limitting. The overall is a token bucket and the per-item is exponential // both overall and per-item rate limiting. The overall is a token bucket and the per-item is exponential
func DefaultControllerRateLimiter() RateLimiter { func DefaultControllerRateLimiter() RateLimiter {
return NewMaxOfRateLimiter( return NewMaxOfRateLimiter(
NewItemExponentialFailureRateLimiter(5*time.Millisecond, 1000*time.Second), NewItemExponentialFailureRateLimiter(5*time.Millisecond, 1000*time.Second),