- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 183 for bucketOf (0.52 sec)
-
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/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) -
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) -
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) -
cmd/erasure-healing.go
dirQuorum: 1, objQuorum: 1, bucket: bucket, strict: false, // Allow less strict matching. } path := baseDirFromPrefix(prefix) filterPrefix := strings.Trim(strings.TrimPrefix(prefix, path), slashSeparator) if path == prefix { filterPrefix = "" } lopts := listPathRawOptions{ disks: disks, fallbackDisks: fallbackDisks, bucket: bucket, path: path,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 33.8K bytes - Viewed (0) -
cmd/data-usage-cache.go
return nil } return dst } // bucketsUsageInfo returns the buckets usage info as a map, with // key as bucket name func (d *dataUsageCache) bucketsUsageInfo(buckets []BucketInfo) map[string]BucketUsageInfo { dst := make(map[string]BucketUsageInfo, len(buckets)) for _, bucket := range buckets { e := d.find(bucket.Name) if e == nil { continue } flat := d.flatten(*e)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 10 14:49:50 UTC 2024 - 42.8K bytes - Viewed (0) -
cmd/post-policy_test.go
func newPostPolicyBytesV4(credential, bucketName, objectKey string, expiration time.Time) []byte { t := UTCNow() // Add the expiration date. expirationStr := fmt.Sprintf(`"expiration": "%s"`, expiration.Format(iso8601TimeFormat)) // Add the bucket condition, only accept buckets equal to the one passed. bucketConditionStr := fmt.Sprintf(`["eq", "$bucket", "%s"]`, bucketName)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 30.2K bytes - Viewed (0) -
cmd/metacache-server-pool.go
fi, err := obj.fileInfo(o.Bucket) if err != nil { return } objInfo := fi.ToObjectInfo(o.Bucket, obj.name, versioned) if o.Lifecycle != nil { act := evalActionFromLifecycle(ctx, *o.Lifecycle, o.Retention, o.Replication.Config, objInfo).Action skip = act.Delete() && !act.DeleteRestored() } } fiv, err := obj.fileInfoVersions(o.Bucket) if err != nil { return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 23 01:12:23 UTC 2024 - 12.9K bytes - Viewed (0) -
cmd/generic-handlers.go
} return } h.ServeHTTP(w, r) }) } // setBucketForwardingMiddleware middleware forwards the path style requests // on a bucket to the right bucket location, bucket to IP configuration // is obtained from centralized etcd configuration service. func setBucketForwardingMiddleware(h http.Handler) http.Handler {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 06 01:01:15 UTC 2024 - 20.4K bytes - Viewed (0) -
docs/metrics/prometheus/list.md
| `minio_bucket_objects_version_distribution` | Distribution of object sizes in a bucket, by number of versions | ## Replication Metrics
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:54 UTC 2024 - 43.3K bytes - Viewed (0)