- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 45 for Ashour (0.16 sec)
-
cmd/tier-last-day-stats.go
now := time.Now() l.forwardTo(now) nowIdx := now.Hour() l.Bins[nowIdx] = l.Bins[nowIdx].add(ts) } // forwardTo moves time to t, clearing entries between last update and t. func (l *lastDayTierStats) forwardTo(t time.Time) { if t.IsZero() { t = time.Now() } since := t.Sub(l.UpdatedAt).Hours() // within the hour since l.UpdatedAt if since < 1 { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 2.8K 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 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 13 15:42:21 GMT 2023 - 1.2K bytes - Viewed (0) -
cmd/license-update.go
package cmd import ( "context" "fmt" "math/rand" "time" "github.com/tidwall/gjson" ) const ( licUpdateCycle = 24 * time.Hour * 30 licRenewPath = "/api/cluster/renew-license" ) // initlicenseUpdateJob start the periodic license update job in the background. func initLicenseUpdateJob(ctx context.Context, objAPI ObjectLayer) { go func() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0) -
cmd/data-scanner_test.go
obj := ObjectInfo{ Name: "foo", ModTime: time.Now().Add(-31 * 24 * time.Hour), Size: 100 << 20, VersionID: uuid.New().String(), IsLatest: true, NumVersions: 4, } delMarker := ObjectInfo{ Name: "foo-deleted", ModTime: time.Now().Add(-61 * 24 * time.Hour), Size: 0, VersionID: uuid.New().String(), IsLatest: true,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 6.9K bytes - Viewed (0) -
internal/s3select/sql/parser_test.go
"coalesce(s.id[1], 2, 2 + 3)", "cast(s as string)", "cast(s AS INT)", "cast(s as DECIMAL)", "extract(YEAR from '2018-01-09')", "extract(month from '2018-01-09')", "extract(hour from '2018-01-09')", "extract(day from '2018-01-09')", "substring('abcd' from 2 for 2)", "substring('abcd' from 2)", "substring('abcd' , 2 , 2)", "substring('abcd' , 22 )", "trim(' aab ')",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.2K bytes - Viewed (0) -
cmd/globals.go
// tmp directory are deemed stale. GlobalStaleUploadsExpiry = time.Hour * 24 // 24 hrs. // GlobalStaleUploadsCleanupInterval - Cleanup interval when the stale uploads cleanup is initiated. GlobalStaleUploadsCleanupInterval = time.Hour * 6 // 6 hrs. // Refresh interval to update in-memory iam config cache. globalRefreshIAMInterval = 10 * time.Minute
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
internal/config/identity/openid/openid.go
func GetDefaultExpiration(dsecs string) (time.Duration, error) { timeout := env.Get(config.EnvMinioStsDuration, "") defaultExpiryDuration, err := time.ParseDuration(timeout) if err != nil { defaultExpiryDuration = time.Hour } if timeout == "" && dsecs != "" { expirySecs, err := strconv.ParseInt(dsecs, 10, 64) if err != nil { return 0, auth.ErrInvalidDuration } // The duration, in seconds, of the role session.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 16 04:42:31 GMT 2023 - 16.5K bytes - Viewed (0) -
cmd/metrics-v2.go
lastMinFailedCount MetricName = "last_minute_failed_count" lastMinFailedBytes MetricName = "last_minute_failed_bytes" lastHourFailedCount MetricName = "last_hour_failed_count" lastHourFailedBytes MetricName = "last_hour_failed_bytes" totalFailedCount MetricName = "total_failed_count" totalFailedBytes MetricName = "total_failed_bytes" currActiveWorkers MetricName = "current_active_workers"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
configureCmd.PersistentFlags().StringVar(&clusterID, "clusterID", "", "The ID used to identify the cluster") configureCmd.PersistentFlags().Int64Var(&tokenDuration, "tokenDuration", 3600, "The token duration in seconds (default: 1 hour)") configureCmd.PersistentFlags().StringVar(&ingressSvc, "ingressService", istioEastWestGatewayServiceName, "Name of the Service to be"+
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Apr 17 20:06:41 GMT 2024 - 25.5K bytes - Viewed (0) -
cmd/update-notifier_test.go
{1 * time.Hour, "my_download_url", "1 hour before the latest release"}, {61 * time.Minute, "my_download_url", "1 hour before the latest release"}, {122 * time.Minute, "my_download_url", "2 hours before the latest release"}, {24 * time.Hour, "my_download_url", "1 day before the latest release"}, {25 * time.Hour, "my_download_url", "1 day before the latest release"},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jul 31 15:36:19 GMT 2023 - 4.1K bytes - Viewed (0)