- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 43 for UTCNow (0.2 sec)
-
cmd/bucket-replication_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Sep 16 09:28:06 GMT 2023 - 12.2K bytes - Viewed (0) -
cmd/admin-heal-ops.go
h.healFailedItemsMap[d.Endpoint+","+d.State]++ } h.lastHealActivity = UTCNow() } func (h *healSequence) countHeals(healType madmin.HealItemType, healed bool) { h.mutex.Lock() defer h.mutex.Unlock() if !healed { h.scannedItemsMap[healType]++ } else { h.healedItemsMap[healType]++ } h.lastHealActivity = UTCNow() } // isQuitting - determines if the heal sequence is quitting (due to an
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
cmd/post-policy_test.go
"github.com/dustin/go-humanize" ) const ( iso8601DateFormat = "20060102T150405Z" ) func newPostPolicyBytesV4WithContentRange(credential, bucketName, objectKey string, expiration time.Time) []byte { t := UTCNow() // Add the expiration date. expirationStr := fmt.Sprintf(`"expiration": "%s"`, expiration.Format(iso8601TimeFormat)) // Add the bucket condition, only accept buckets equal to the one passed.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 29.6K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
r.mostRecentStatsMu.Lock() if len(r.mostRecentStats.Stats) == 0 { r.mostRecentStats = BucketStatsMap{Stats: make(map[string]BucketStats, 1), Timestamp: UTCNow()} } if len(bs.ReplicationStats.Stats) > 0 { r.mostRecentStats.Stats[bucket] = bs } r.mostRecentStats.Timestamp = UTCNow() r.mostRecentStatsMu.Unlock() return bs } // get the most current of in-memory replication stats and data usage info from crawler.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.4K bytes - Viewed (0) -
cmd/local-locker.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 10.6K bytes - Viewed (0) -
cmd/signature-v4-parser_test.go
"Z7IXGOO6BZ0REAN1Q26I", UTCNow().Format(yyyymmdd), "us-west-1", "ABCD", "ABCD"), expectedCredentials: credentialHeader{}, expectedErrCode: ErrInvalidServiceS3, }, // Test Case - 7. // Test case with invalid region. { inputCredentialStr: generateCredentialStr( "Z7IXGOO6BZ0REAN1Q26I", UTCNow().Format(yyyymmdd), "us-west-2", "s3",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 27.4K bytes - Viewed (0) -
cmd/tier.go
return nil, nil, err } pReader, err := NewPutObjReader(hr).WithEncryption(encHr, &oek) if err != nil { return nil, nil, err } opts := &ObjectOptions{ UserDefined: metadata, MTime: UTCNow(), MaxParity: true, } return pReader, opts, nil } // Reload updates config by reloading remote tier config from config store.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
p.Pools[idx].LastUpdate = UTCNow() p.Pools[idx].Decommission.Complete = true p.Pools[idx].Decommission.Failed = false p.Pools[idx].Decommission.Canceled = false return true } return false } func (p *poolMeta) DecommissionFailed(idx int) bool { if p.Pools[idx].Decommission != nil && !p.Pools[idx].Decommission.Failed { p.Pools[idx].LastUpdate = UTCNow()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
cmd/signature-v4_test.go
} return fmt.Sprintf("%s (%s)", errorCodes[code].Code, errorCodes[code].Description) } func TestDoesPolicySignatureMatch(t *testing.T) { credentialTemplate := "%s/%s/%s/s3/aws4_request" now := UTCNow() accessKey := globalActiveCred.AccessKey testCases := []struct { form http.Header expected APIErrorCode }{ // (0) It should fail if 'X-Amz-Credential' is missing. { form: http.Header{},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 10.4K bytes - Viewed (1) -
cmd/signature-v4.go
} // If the host which signed the request is slightly ahead in time (by less than globalMaxSkewTime) the // request should still be allowed. if pSignValues.Date.After(UTCNow().Add(globalMaxSkewTime)) { return ErrRequestNotReadyYet } if UTCNow().Sub(pSignValues.Date) > pSignValues.Expires { return ErrExpiredPresignRequest } // Save the date and expires. t := pSignValues.Date
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 12.3K bytes - Viewed (0)