- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for load3 (0.23 sec)
-
cmd/metrics-v2.go
} httpStats := globalBucketHTTPStats.load(bucket) for k, v := range httpStats.currentS3Requests.Load(true) { metrics = append(metrics, MetricV2{ Description: getBucketS3RequestsInFlightMD(), Value: float64(v), VariableLabels: map[string]string{"bucket": bucket, "api": k}, }) } for k, v := range httpStats.totalS3Requests.Load(true) { metrics = append(metrics, MetricV2{
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) -
cmd/object-handlers.go
func setRemoteInstanceTransport(tr http.RoundTripper) { remoteInstanceTransport.Store(tr) } func getRemoteInstanceTransport() http.RoundTripper { rt, ok := remoteInstanceTransport.Load().(http.RoundTripper) if ok { return rt } return nil } // Returns a minio-go Client configured to access remote host described by destDNSRecord // Applicable only in a federated deployment
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cmd/bucket-replication.go
if duration < time.Second { // Make sure to sleep at least a second to avoid high CPU ticks. duration = time.Second } time.Sleep(duration) } } // Loads bucket replication resync statuses into memory. func (p *ReplicationPool) loadResync(ctx context.Context, buckets []BucketInfo, objAPI ObjectLayer) error { // Make sure only one node running resync on the cluster.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/site-replication.go
_, ok1 := err.(BucketExists) _, ok2 := err.(BucketAlreadyExists) if !ok1 && !ok2 { return wrapSRErr(c.annotateErr(makeBucketWithVersion, err)) } } else { // Load updated bucket metadata into memory as new // bucket was created. globalNotificationSys.LoadBucketMetadata(GlobalContext, bucket) } meta, err := globalBucketMetadataSys.Get(bucket) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
cmd/admin-handlers.go
if !ok { poolInfo = make(map[int]madmin.ErasureSetInfo) } erasureSet, ok := poolInfo[d.SetIndex] if !ok { erasureSet.ID = d.SetIndex cache := dataUsageCache{} if err := cache.load(ctx, z.serverPools[d.PoolIndex].sets[d.SetIndex], dataUsageCacheName); err == nil { dataUsageInfo := cache.dui(dataUsageRoot, nil) erasureSet.ObjectsCount = dataUsageInfo.ObjectsTotalCount
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 29 17:39:04 GMT 2024 - 97.8K bytes - Viewed (2)