- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 836 for Time (0.17 sec)
-
internal/bucket/lifecycle/lifecycle_test.go
testCases := []struct { modTime time.Time days ExpirationDays expected time.Time }{ { time.Date(2020, time.March, 15, 10, 10, 10, 0, time.UTC), 4, time.Date(2020, time.March, 20, 0, 0, 0, 0, time.UTC), }, { time.Date(2020, time.March, 15, 0, 0, 0, 0, time.UTC), 1, time.Date(2020, time.March, 17, 0, 0, 0, 0, time.UTC), }, }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu May 23 01:12:48 UTC 2024 - 55.1K bytes - Viewed (0) -
src/archive/tar/reader_test.go
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Thu Oct 03 15:48:09 UTC 2024 - 46.9K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
// Offset checks a bit. time.Sleep(time.Duration(rng.Int63n(int64(1 * time.Second)))) dctx, dcancel := context.WithCancel(ctx) started := time.Now() go func() { timeout := time.NewTimer(globalDriveConfig.GetMaxTimeout()) select { case <-dctx.Done(): if !timeout.Stop() { <-timeout.C } case <-timeout.C: spent := time.Since(started)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Oct 26 09:56:26 UTC 2024 - 34.5K bytes - Viewed (0) -
docs/sts/dex.md
### Start Dex ``` ~ ./bin/dex serve dex.yaml time="2020-07-12T20:45:50Z" level=info msg="config issuer: http://127.0.0.1:5556/dex" time="2020-07-12T20:45:50Z" level=info msg="config storage: sqlite3" time="2020-07-12T20:45:50Z" level=info msg="config static client: Example App" time="2020-07-12T20:45:50Z" level=info msg="config connector: mock" time="2020-07-12T20:45:50Z" level=info msg="config connector: local passwords enabled"
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Mar 21 06:38:06 UTC 2023 - 3.8K bytes - Viewed (0) -
internal/config/batch/batch.go
type Config struct { ReplicationWorkersWait time.Duration `json:"replicationWorkersWait"` KeyRotationWorkersWait time.Duration `json:"keyRotationWorkersWait"` ExpirationWorkersWait time.Duration `json:"expirationWorkersWait"` } // ExpirationWait returns the duration for which a batch expiration worker // would wait before working on next object. func (opts Config) ExpirationWait() time.Duration { configMu.RLock()
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.7K bytes - Viewed (0) -
internal/dsync/utils.go
package dsync import ( "math/rand" "time" ) func backoffWait(min, unit, cap time.Duration) func(*rand.Rand, uint) time.Duration { if unit > time.Hour { // Protect against integer overflow panic("unit cannot exceed one hour") } return func(r *rand.Rand, attempt uint) time.Duration { sleep := min sleep += unit * time.Duration(attempt) if sleep > cap { sleep = cap }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat May 13 15:42:21 UTC 2023 - 1.2K bytes - Viewed (0) -
internal/rest/client.go
auth: auth, connected: connected, lastConn: time.Now().UnixNano(), MaxErrResponseSize: 4096, HealthCheckReconnectUnit: 200 * time.Millisecond, HealthCheckTimeout: time.Second, } if err != nil { clnt.lastErr = err clnt.lastErrTime = time.Now() } if clnt.HealthCheckFn != nil { // make connection pre-emptively.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jul 26 12:55:01 UTC 2024 - 14.7K bytes - Viewed (0) -
cmd/data-scanner-metric.go
globalTrace.Publish(scannerTrace(s, startTime, duration, strings.Join(paths, " "), custom)) } } } // time a scanner action. // Use for s < scannerMetricLastRealtime func (p *scannerMetrics) time(s scannerMetric) func() { startTime := time.Now() return func() { duration := time.Since(startTime) atomic.AddUint64(&p.operations[s], 1) if s < scannerMetricLastRealtime { p.latency[s].add(duration)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 25 05:15:31 UTC 2023 - 9.1K bytes - Viewed (0) -
cmd/globals.go
globalDomainIPs set.StringSet // Root domain IP address(s) for a distributed MinIO deployment globalOperationTimeout = newDynamicTimeout(10*time.Minute, 5*time.Minute) // default timeout for general ops globalDeleteOperationTimeout = newDynamicTimeout(5*time.Minute, 1*time.Minute) // default time for delete ops globalBucketObjectLockSys *BucketObjectLockSys globalBucketQuotaSys *BucketQuotaSys
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Sep 03 18:23:41 UTC 2024 - 16.2K bytes - Viewed (0) -
internal/ioutil/ioutil_test.go
"errors" "io" "os" "strings" "testing" "time" ) type sleepWriter struct { timeout time.Duration } func (w *sleepWriter) Write(p []byte) (n int, err error) { time.Sleep(w.timeout) return len(p), nil } func (w *sleepWriter) Close() error { return nil } func TestDeadlineWorker(t *testing.T) { work := NewDeadlineWorker(500 * time.Millisecond) err := work.Run(func() error {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 5.5K bytes - Viewed (0)