- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 378 for bucketOf (0.32 sec)
-
cmd/admin-handlers-site-replication.go
} // SRPeerBucketOps - PUT /minio/admin/v3/site-replication/bucket-ops?bucket=x&operation=y func (a adminAPIHandlers) SRPeerBucketOps(w http.ResponseWriter, r *http.Request) { ctx := r.Context() objectAPI, _ := validateAdminReq(ctx, w, r, policy.SiteReplicationOperationAction) if objectAPI == nil { return } vars := mux.Vars(r) bucket := vars["bucket"] operation := madmin.BktOp(vars["operation"])
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.4K bytes - Viewed (0) -
guava/src/com/google/common/hash/Hashing.java
*/ public static int consistentHash(long input, int buckets) { checkArgument(buckets > 0, "buckets must be positive: %s", buckets); LinearCongruentialGenerator generator = new LinearCongruentialGenerator(input); int candidate = 0; int next; // Jump from bucket to bucket until we go out of range while (true) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 09 00:37:15 UTC 2024 - 32.3K bytes - Viewed (0) -
cmd/veeam-sos-api.go
} func veeamSOSAPIHeadObject(ctx context.Context, bucket, object string, opts ObjectOptions) (ObjectInfo, error) { gr, err := veeamSOSAPIGetObject(ctx, bucket, object, nil, opts) if gr != nil { gr.Close() return gr.ObjInfo, nil } return ObjectInfo{}, err } func veeamSOSAPIGetObject(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, opts ObjectOptions) (gr *GetObjectReader, err error) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 20 18:54:52 UTC 2024 - 8.9K bytes - Viewed (0) -
cmd/object-api-interface.go
// Bucket operations. MakeBucket(ctx context.Context, bucket string, opts MakeBucketOptions) error GetBucketInfo(ctx context.Context, bucket string, opts BucketOptions) (bucketInfo BucketInfo, err error) ListBuckets(ctx context.Context, opts BucketOptions) (buckets []BucketInfo, err error) DeleteBucket(ctx context.Context, bucket string, opts DeleteBucketOptions) error
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 06 20:27:52 UTC 2024 - 17K bytes - Viewed (0) -
cmd/peer-rest-server.go
buckets, err := listBucketsLocal(context.Background(), *opts) if err != nil { return nil, grid.NewRemoteErr(err) } res := aoBucketInfo.New() for i := range buckets { bucket := buckets[i] res.Append(&bucket) } return res, nil } // HeadBucketHandler implements peer BucketInfo call, returns bucket create date.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 52.1K bytes - Viewed (0) -
cmd/metrics.go
return } for bucket, usageInfo := range dataUsageInfo.BucketsUsage { stat := globalReplicationStats.getLatestReplicationStats(bucket) // Total space used by bucket ch <- prometheus.MustNewConstMetric( prometheus.NewDesc( prometheus.BuildFQName(bucketNamespace, "usage", "size"), "Total bucket size", []string{"bucket"}, nil), prometheus.GaugeValue,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 16.6K bytes - Viewed (0) -
guava/src/com/google/common/collect/ImmutableMapEntry.java
return null; } @CheckForNull ImmutableMapEntry<K, V> getNextInValueBucket() { return null; } /** * Returns true if this entry has no bucket links and can safely be reused as a terminal entry in * a bucket in another map. */ boolean isReusable() { return true; } static class NonTerminalImmutableMapEntry<K, V> extends ImmutableMapEntry<K, V> { /*
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 4.4K bytes - Viewed (0) -
cmd/admin-handlers-users_test.go
// Check that the service account can access the public bucket. buckets, err := svcClient.ListBuckets(ctx) if err != nil { c.Fatalf("err fetching buckets %s", err) } if len(buckets) != 1 || buckets[0].Name != "public" { c.Fatalf("service account should only have access to public bucket") } // Create an madmin client with the service account creds.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 45.7K bytes - Viewed (0) -
docs/ftp/README.md
rotating credentials. - Access to bucket(s) and object(s) are governed via IAM policies associated with the incoming login credentials. - Allows authentication and access for all - Built-in IDP users and their respective service accounts - LDAP/AD users and their respective service accounts - OpenID/OIDC service accounts - On versioned buckets, FTP/SFTP only operates on latest objects, if you need to retrieve
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 07 06:41:25 UTC 2024 - 7.8K bytes - Viewed (0) -
pkg/kubelet/metrics/metrics.go
// including the time spent in the waiting queue of image puller. // The metric is broken down by bucketed image size. ImagePullDuration = metrics.NewHistogramVec( &metrics.HistogramOpts{ Subsystem: KubeletSubsystem, Name: ImagePullDurationKey, Help: "Duration in seconds to pull an image.", Buckets: imagePullDurationBuckets, StabilityLevel: metrics.ALPHA, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 22 15:13:25 UTC 2024 - 45.6K bytes - Viewed (0)