- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 836 for Time (0.06 sec)
-
internal/amztime/parse.go
// extension for http.TimeFormat - return time might be zero // if the timeStr is invalid. func ParseHeader(timeStr string) (time.Time, error) { for _, dateFormat := range httpTimeFormats { t, err := time.Parse(dateFormat, timeStr) if err == nil { return t, nil } } return time.Time{}, ErrMalformedDate } // ParseReplicationTS parse http.TimeFormat first // will try time.RFC3339Nano when parse http.TimeFormat failed
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 2.5K bytes - Viewed (0) -
cmd/metrics-v3-cluster-iam.go
pluginAuthnServiceLastSuccSecondsMD = NewCounterMD(pluginAuthnServiceLastSuccSeconds, "When plugin authentication is configured, returns time (in seconds) since the last successful request to the service")
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu May 02 08:20:42 UTC 2024 - 4.5K bytes - Viewed (0) -
cmd/update-notifier_test.go
{-72 * time.Hour, "another_update_url", ""}, {0, "another_update_url", ""}, {time.Hour, "", ""}, {0 * time.Second, "my_download_url", "now"}, {1 * time.Second, "my_download_url", "1 second before the latest release"}, {37 * time.Second, "my_download_url", "37 seconds before the latest release"}, {60 * time.Second, "my_download_url", "1 minute before the latest release"},
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jul 31 15:36:19 UTC 2023 - 4.1K bytes - Viewed (0) -
internal/grid/muxserver.go
outBlock chan struct{} clientPingInterval time.Duration } func newMuxStateless(ctx context.Context, msg message, c *Connection, handler StatelessHandler) *muxServer { var cancel context.CancelFunc ctx = setCaller(ctx, c.remote) if msg.DeadlineMS > 0 { ctx, cancel = context.WithTimeout(ctx, time.Duration(msg.DeadlineMS)*time.Millisecond) } else { ctx, cancel = context.WithCancel(ctx) }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
cmd/iam-store.go
if isGroup { if store.getUsersSysType() == MinIOUsersSysType { g, ok := c.iamGroupsMap[name] if !ok { if err := store.loadGroup(context.Background(), name, c.iamGroupsMap); err != nil { return nil, time.Time{}, err } g, ok = c.iamGroupsMap[name] if !ok { return nil, time.Time{}, errNoSuchGroup } }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Oct 14 16:35:37 UTC 2024 - 83.2K bytes - Viewed (0) -
cmd/site-replication-utils.go
r := rand.New(rand.NewSource(time.Now().UnixNano())) // Run the site resync metrics load in a loop for { if err := sm.load(ctx, newObjectLayerFn()); err == nil { <-ctx.Done() return } duration := time.Duration(r.Float64() * float64(time.Second*10)) if duration < time.Second { // Make sure to sleep at least a second to avoid high CPU ticks. duration = time.Second } time.Sleep(duration) }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 8.9K bytes - Viewed (1) -
internal/dsync/dsync-server_test.go
if d := atomic.LoadInt64(&l.responseDelay); d != 0 { time.Sleep(time.Duration(d)) } l.mutex.Lock() defer l.mutex.Unlock() reply = !l.lockNotFound return reply, nil } func (l *lockServer) ForceUnlock(args *LockArgs) (reply bool, err error) { if d := atomic.LoadInt64(&l.responseDelay); d != 0 { time.Sleep(time.Duration(d)) } l.mutex.Lock() defer l.mutex.Unlock()
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jan 23 16:46:37 UTC 2023 - 8.3K bytes - Viewed (0) -
internal/cachevalue/cache.go
} // Cache contains a synchronized value that is considered valid // for a specific amount of time. // An Update function must be set to provide an updated value when needed. type Cache[T any] struct { // updateFn must return an updated value. // If an error is returned the cached value is not set. // Only one caller will call this function at any time, others will be blocking. // The returned value can no longer be modified once returned.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 12:50:46 UTC 2024 - 4.4K bytes - Viewed (0) -
cmd/signature-v4-parser.go
if aec != ErrNone { return psv, aec } var e error // Save date in native time.Time. preSignV4Values.Date, e = time.Parse(iso8601Format, query.Get(xhttp.AmzDate)) if e != nil { return psv, ErrMalformedPresignedDate } // Save expires in native time.Duration. preSignV4Values.Expires, e = time.ParseDuration(query.Get(xhttp.AmzExpires) + "s") if e != nil { return psv, ErrMalformedExpires }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 9.4K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
"fmt" "runtime" "sync/atomic" "testing" "time" ) const ( id = "1234-5678" source = "main.go" ) func testSimpleWriteLock(t *testing.T, duration time.Duration) (locked bool) { drwm1 := NewDRWMutex(ds, "simplelock") ctx1, cancel1 := context.WithCancel(context.Background()) if !drwm1.GetRLock(ctx1, cancel1, id, source, Options{Timeout: time.Second}) { panic("Failed to acquire read lock") }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Dec 24 03:49:07 UTC 2022 - 9.7K bytes - Viewed (0)