- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 32 for locales (0.15 sec)
-
cmd/xl-storage-disk-id-check.go
diskMetric.TotalErrorsTimeout = p.totalErrsTimeout.Load() diskMetric.TotalErrorsAvailability = p.totalErrsAvailability.Load() return diskMetric } // lockedLastMinuteLatency accumulates totals lockless for each second. type lockedLastMinuteLatency struct { cachedSec int64 cached atomic.Pointer[AccElem] mu sync.Mutex init sync.Once lastMinuteLatency }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/erasure-object.go
return err } // RestoreTransitionedObject - restore transitioned object content locally on this cluster. // This is similar to PostObjectRestore from AWS GLACIER // storage class. When PostObjectRestore API is called, a temporary copy of the object // is restored locally to the bucket on source cluster until the restore expiry date.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/erasure-server-pool.go
// - Cohesity // - Actifio, Splunk etc. // which send ListObjects requests where the actual object // itself is the prefix and max-keys=1 in such scenarios // we can simply verify locally if such an object exists // to avoid the need for ListObjects(). objInfo, err := z.GetObjectInfo(ctx, bucket, prefix, ObjectOptions{NoLock: true}) if err == nil { if opts.Lifecycle != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K 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
// "aws4_request" is the valid request version. { inputCredentialStr: generateCredentialStr( "LOCALKEY/DEV/1", sampleTimeStr, "us-west-1", "s3", "aws4_request"), expectedCredentials: generateCredentials( t, "LOCALKEY/DEV/1", sampleTimeStr, "us-west-1", "s3", "aws4_request"), expectedErrCode: ErrNone, },
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) -
tests/helper_test.go
} for i := 0; i < config.Team; i++ { user.Team = append(user.Team, *GetUser(name+"_team_"+strconv.Itoa(i+1), Config{})) } for i := 0; i < config.Languages; i++ { name := name + "_locale_" + strconv.Itoa(i+1) language := Language{Code: name, Name: name} user.Languages = append(user.Languages, language) } for i := 0; i < config.Friends; i++ {
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Tue Mar 19 03:50:28 GMT 2024 - 8K bytes - Viewed (0) -
internal/store/queuestore.go
} } return nil } // Len returns the entry count. func (store *QueueStore[_]) Len() int { store.RLock() l := len(store.entries) defer store.RUnlock() return l } // lockless call func (store *QueueStore[_]) del(key string) error { err := os.Remove(filepath.Join(store.directory, key+store.fileExt)) // Delete as entry no matter the result delete(store.entries, key) return err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 7.1K bytes - Viewed (0) -
misc/go_android_exec/main.go
out, err = cmd.Output() if err != nil { return fmt.Errorf("%v: %w", cmd, err) } platformBin := filepath.Dir(string(bytes.TrimSpace(out))) if platformBin == "." { return errors.New("failed to locate cmd/go for target platform") } if err := adb("push", platformBin, path.Join(deviceGoroot, "bin")); err != nil { return err } // Copy only the relevant subdirectories from pkg: pkg/include and the
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Aug 21 17:46:57 GMT 2023 - 15.3K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
// 2. Only the node hosting the disk is responsible to perform the heal func monitorLocalDisksAndHeal(ctx context.Context, z *erasureServerPools) { // Perform automatic disk healing when a disk is replaced locally. diskCheckTimer := time.NewTimer(defaultMonitorNewDiskInterval) defer diskCheckTimer.Stop() for { select { case <-ctx.Done(): return case <-diskCheckTimer.C:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.7K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig.go
} pl, err := client.PodsForSelector(context.TODO(), ctx.NamespaceOrDefault(ctx.IstioNamespace()), istiodLabelSelector) if err != nil { return fmt.Errorf("not able to locate pod with selector %s: %v", istiodLabelSelector, err) } if len(pl.Items) < 1 { return errors.New("no pods found") } if len(pl.Items) > 1 {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 13.5K bytes - Viewed (0)