- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 286 for irate (0.04 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/waitgroup/ratelimited_waitgroup.go
"context" "fmt" "sync" ) // RateLimiter abstracts the rate limiter used by RateLimitedSafeWaitGroup. // The implementation must be thread-safe. type RateLimiter interface { Wait(ctx context.Context) error } // RateLimiterFactoryFunc is used by the RateLimitedSafeWaitGroup to create a new // instance of a RateLimiter that will be used to rate limit the return rate
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 21 14:08:00 UTC 2023 - 3.7K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/internal/config/config.go
ucfg.rate = make(map[pgkey]float64) for _, p := range ucfg.Programs { ucfg.program[p.Name] = true for _, v := range p.Versions { ucfg.pgversion[pgkey{p.Name, v}] = true } for _, c := range p.Counters { for _, e := range Expand(c.Name) { ucfg.pgcounter[pgkey{p.Name, e}] = true ucfg.rate[pgkey{p.Name, e}] = c.Rate } prefix, _, found := strings.Cut(c.Name, ":")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 17:57:25 UTC 2024 - 3.5K bytes - Viewed (0) -
src/go/doc/testdata/examples/import_groups.golden
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 10 16:17:51 UTC 2022 - 317 bytes - Viewed (0) -
src/go/doc/testdata/examples/import_groups_named.golden
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 10 16:17:51 UTC 2022 - 314 bytes - Viewed (0) -
src/vendor/golang.org/x/crypto/sha3/shake.go
i := byte(1) for i < 8 && b[i] == 0 { i++ } // Prepend number of encoded bytes b[i-1] = 9 - i return b[i-1:] } func newCShake(N, S []byte, rate, outputLen int, dsbyte byte) ShakeHash { c := cshakeState{state: &state{rate: rate, outputLen: outputLen, dsbyte: dsbyte}} // leftEncode returns max 9 bytes c.initBlock = make([]byte, 0, 9*2+len(N)+len(S))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 5.4K bytes - Viewed (0) -
src/vendor/golang.org/x/crypto/sha3/hashes.go
return new512() } func new224Generic() *state { return &state{rate: 144, outputLen: 28, dsbyte: 0x06} } func new256Generic() *state { return &state{rate: 136, outputLen: 32, dsbyte: 0x06} } func new384Generic() *state { return &state{rate: 104, outputLen: 48, dsbyte: 0x06} } func new512Generic() *state { return &state{rate: 72, outputLen: 64, dsbyte: 0x06} }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 2.7K bytes - Viewed (0) -
pkg/controller/podautoscaler/rate_limiters.go
return 1 } // Forget indicates that an item is finished being retried. func (r *FixedItemIntervalRateLimiter) Forget(item string) { } // NewDefaultHPARateLimiter creates a rate limiter which limits overall (as per the // default controller rate limiter), as well as per the resync interval func NewDefaultHPARateLimiter(interval time.Duration) workqueue.TypedRateLimiter[string] { return NewFixedItemIntervalRateLimiter(interval)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 1.8K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/health/HealthExpirationStrategyTest.groovy
} def "knows when heap space is exhausted (#rateThreshold <= #rate, #usageThreshold <= #usage)"(double rateThreshold, int usageThreshold, double rate, int usage, boolean unhealthy) { given: def underTest = new HealthExpirationStrategy( Mock(DaemonHealthStats) { getHeapStats() >> stats(usage, rate, true) getNonHeapStats() >> stats(-1, -1, false) },
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 11.8K bytes - Viewed (0) -
src/runtime/mprof.go
// events have a cycles/rate random chance of returning true. func blocksampled(cycles, rate int64) bool { if rate <= 0 || (rate > cycles && cheaprand64()%rate > cycles) { return false } return true } // saveblockevent records a profile event of the type specified by which. // cycles is the quantity associated with this event and rate is the sampling rate,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 53.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java
* underlying model is a continuous function mapping storedPermits (from 0.0 to maxStoredPermits) * onto the 1/rate (i.e. intervals) that is effective at the given storedPermits. "storedPermits" * essentially measure unused time; we spend unused time buying/storing permits. Rate is * "permits / time", thus "1 / rate = time / permits". Thus, "1/rate" (time / permits) times
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 19.3K bytes - Viewed (0)