- Sort Score
- Num 10 results
- Language All
Results 31 - 40 of 129 for tracker (0.06 seconds)
-
cmd/xl-storage.go
// suspended or disabled on this bucket. RenameData will replace // the 'null' version. We add a free-version to track its tiered // content for asynchronous deletion. // // Note: RestoreObject and HealObject requests don't end up replacing the // null version and therefore don't require the free-version to track // anything if fi.VersionID == "" && !fi.IsRestoreObjReq() && !fi.Healing() {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 91.7K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.22.md
- Replace `go-bindata` with `//go:embed`. ([#99829](https://github.com/kubernetes/kubernetes/pull/99829), [@palnabarun](https://github.com/palnabarun)) - The `DynamicFakeClient` now exposes its tracker via a `Tracker()` function. ([#100085](https://github.com/kubernetes/kubernetes/pull/100085), [@markusthoemmes](https://github.com/markusthoemmes))
Created: Fri Dec 26 09:05:12 GMT 2025 - Last Modified: Tue Dec 13 12:43:45 GMT 2022 - 454.1K bytes - Click Count (0) -
cmd/http-tracer.go
op = strings.Replace(op, "ReadinessCheckHandler", "health.Readiness", 1) op = strings.Replace(op, "-fm", "", 1) return op } // If trace is enabled, execute the request if it is traced by other handlers // otherwise, generate a trace event with request information but no response. func httpTracerMiddleware(h http.Handler) http.Handler { return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Sep 24 17:13:00 GMT 2024 - 6K bytes - Click Count (0) -
guava/src/com/google/common/base/Ticker.java
*/ @GwtCompatible public abstract class Ticker { /** Constructor for use by subclasses. */ protected Ticker() {} /** Returns the number of nanoseconds elapsed since this ticker's fixed point of reference. */ public abstract long read(); /** * A ticker that reads the current time using {@link System#nanoTime}. * * @since 10.0 */ public static Ticker systemTicker() { return SYSTEM_TICKER; }Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 1.8K bytes - Click Count (0) -
tests/tracer_test.go
func (S Tracer) Warn(ctx context.Context, s string, i ...interface{}) { S.Logger.Warn(ctx, s, i...) } func (S Tracer) Error(ctx context.Context, s string, i ...interface{}) { S.Logger.Error(ctx, s, i...) } func (S Tracer) Trace(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error) { S.Logger.Trace(ctx, begin, fc, err) S.Test(ctx, begin, fc, err)
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Tue Oct 18 09:28:06 GMT 2022 - 830 bytes - Click Count (0) -
tests/migrate_test.go
} session := DB.Session(&gorm.Session{Logger: tracer}) DB.Migrator().DropTable(model1) var modifySql []string if err := session.AutoMigrate(model1); err != nil { t.Fatalf("failed to auto migrate, got error: %v", err) } if err := session.AutoMigrate(model1); err != nil { t.Fatalf("failed to auto migrate, got error: %v", err) } tracer2 := Tracer{ Logger: DB.Config.Logger,
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Wed Aug 20 04:51:17 GMT 2025 - 65.2K bytes - Click Count (0) -
src/test/java/jcifs/util/SmbCircuitBreakerTest.java
assertTrue(cbWithMetrics.getMinResponseTime() > 0, "Min response time should be tracked"); assertTrue(cbWithMetrics.getMaxResponseTime() > 0, "Max response time should be tracked"); assertTrue(cbWithMetrics.getP95ResponseTime() > 0, "P95 response time should be tracked");
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 23.2K bytes - Click Count (0) -
cmd/streaming-v4-unsigned.go
func newUnsignedV4ChunkedReader(req *http.Request, trailer bool, signature bool) (io.ReadCloser, APIErrorCode) { if signature { if errCode := doesSignatureMatch(unsignedPayloadTrailer, req, globalSite.Region(), serviceS3); errCode != ErrNone { return nil, errCode } } if trailer { // Discard anything unsigned. req.Trailer = make(http.Header) trailers := req.Header.Values(awsTrailerHeader)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Apr 03 14:55:52 GMT 2025 - 6.3K bytes - Click Count (0) -
android/guava-testlib/test/com/google/common/testing/FakeTickerTest.java
public void testAdvance() { FakeTicker ticker = new FakeTicker(); assertEquals(0, ticker.read()); assertSame(ticker, ticker.advance(10)); assertEquals(10, ticker.read()); ticker.advance(1, MILLISECONDS); assertEquals(1000010L, ticker.read()); ticker.advance(Duration.ofMillis(1)); assertEquals(2000010L, ticker.read()); } public void testAutoIncrementStep_returnsSameInstance() {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 6.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/cache/CacheExpirationTest.java
.expireAfterWrite(EXPIRING_TIME, MILLISECONDS) .removalListener(removalListener) .ticker(ticker) .build(loader); checkExpiration(cache, loader, ticker, removalListener); } public void testExpiration_expireAfterAccess() { FakeTicker ticker = new FakeTicker(); CountingRemovalListener<String, Integer> removalListener = countingRemovalListener();
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Sep 30 22:03:28 GMT 2025 - 19.2K bytes - Click Count (0)