- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for xBuckets (0.19 sec)
-
samples/addons/grafana.yaml
:"datasource","uid":"-- Mixed --"},"description":"Count of active and pending proxies managed by each instance.\nPending is expected to converge to zero.\n","gridPos":{"h":10,"w":8,"x":8,"y":14},"id":13,"interval":"1m","options":{"calculation":{"xBuckets":{"mode":"size","value":"1min"}},"cellGap":0,"color":{"mode":"scheme","scheme":"Spectral","steps":128},"yAxis":{"decimals":0,"unit":"s"}},"pluginVersion":"v11.0.0","targets":[{"datasource":{"type":"prometheus","uid":"$datasource"},"expr":"sum(ra...
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 20:46:28 UTC 2024 - 242.3K bytes - Viewed (0) -
cmd/site-replication.go
} return info, errSRBackendIssue(err) } buckets = append(buckets, bi) } else { buckets, err = objAPI.ListBuckets(ctx, BucketOptions{Deleted: opts.ShowDeleted}) if err != nil { return info, errSRBackendIssue(err) } } info.Buckets = make(map[string]madmin.SRBucketInfo, len(buckets)) for _, bucketInfo := range buckets { bucket := bucketInfo.Name
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 184.3K bytes - Viewed (0) -
cmd/admin-handlers.go
servers = append(servers, local) var poolsInfo map[int]map[int]madmin.ErasureSetInfo var backend madmin.ErasureBackend mode := madmin.ItemInitializing buckets := madmin.Buckets{} objects := madmin.Objects{} versions := madmin.Versions{} deleteMarkers := madmin.DeleteMarkers{} usage := madmin.Usage{} objectAPI := newObjectLayerFn() if objectAPI != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
cmd/bucket-replication.go
} // initResync - initializes bucket replication resync for all buckets. func (p *ReplicationPool) initResync(ctx context.Context, buckets []BucketInfo, objAPI ObjectLayer) error { if objAPI == nil { return errServerNotInitialized } // Load bucket metadata sys in background go p.startResyncRoutine(ctx, buckets, objAPI) return nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0) -
cmd/server_test.go
0, nil, s.accessKey, s.secretKey, s.signer) c.Assert(err, nil) // execute the HTTP request to list buckets. response, err := s.client.Do(request) c.Assert(err, nil) c.Assert(response.StatusCode, http.StatusOK) // create HTTP request for listing buckets. request, err = newTestSignedRequest(http.MethodGet, getListBucketURL(s.endPoint), 0, nil, s.accessKey, s.secretKey, s.signer)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 115.3K bytes - Viewed (0) -
cmd/object-handlers.go
rcfg, _ := globalBucketObjectLockSys.Get(bucket) if rcfg.LockEnabled && opts.DeletePrefix { apiErr := toAPIError(ctx, errInvalidArgument) apiErr.Description = "force-delete is forbidden on Object Locking enabled buckets" writeErrorResponse(ctx, w, apiErr, r.URL) return } os := newObjSweeper(bucket, object).WithVersion(opts.VersionID).WithVersioning(opts.Versioned, opts.VersionSuspended)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 124.2K bytes - Viewed (0) -
cmd/metrics-v2.go
} func getClusterBucketsTotalMD() MetricDescription { return MetricDescription{ Namespace: clusterMetricNamespace, Subsystem: bucketsSubsystem, Name: total, Help: "Total number of buckets in the cluster", Type: gaugeMetric, } } func getClusterCapacityTotalBytesMD() MetricDescription { return MetricDescription{ Namespace: clusterMetricNamespace, Subsystem: capacityRawSubsystem,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:54 UTC 2024 - 131.9K bytes - Viewed (0) -
src/reflect/value.go
// without doing any allocations. type hiter struct { key unsafe.Pointer elem unsafe.Pointer t unsafe.Pointer h unsafe.Pointer buckets unsafe.Pointer bptr unsafe.Pointer overflow *[]unsafe.Pointer oldoverflow *[]unsafe.Pointer startBucket uintptr offset uint8 wrapped bool B uint8
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:17:41 UTC 2024 - 119.9K bytes - Viewed (0) -
cluster/gce/util.sh
local node_binary_tar_urls=() for region in "${PREFERRED_REGION[@]}"; do suffix="-${region}" local staging_bucket="gs://kubernetes-staging-${project_hash}${suffix}" # Ensure the buckets are created if ! gsutil ls "${staging_bucket}" >/dev/null; then echo "Creating ${staging_bucket}" gsutil mb -l "${region}" -p "${PROJECT}" "${staging_bucket}" fi
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 21:47:17 UTC 2024 - 161.6K bytes - Viewed (0) -
src/reflect/all_test.go
val := ValueOf(&tmp).Elem() allocs = testing.AllocsPerRun(100, func() { mv := MakeMapWithSize(TypeOf(map[int]int{}), size) // Only adding half of the capacity to not trigger re-allocations due too many overloaded buckets. for i := 0; i < size/2; i++ { val.SetInt(int64(i)) mv.SetMapIndex(val, val) } }) if allocs > 10 { t.Errorf("allocs per map assignment: want at most 10 got %f", allocs) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 218.8K bytes - Viewed (0)