- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 106 for bucketOf (0.16 sec)
-
platforms/software/resources-gcs/src/main/java/org/gradle/internal/resource/transport/gcp/gcs/GcsClient.java
String bucket = destination.getHost(); String path = cleanResourcePath(destination); StorageObject objectMetadata = new StorageObject().setName(path); Storage.Objects.Insert putRequest = storage.objects().insert(bucket, objectMetadata, contentStream); LOGGER.debug("Attempting to put resource:[{}] into gcs bucket [{}]", putRequest.getName(), putRequest.getBucket());
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 22 11:17:20 UTC 2024 - 7.9K bytes - Viewed (0) -
internal/crypto/metadata.go
// object with SSE-KMS. A client may not send a context in which case the // MetaContext will not be present. // MetaContext only contains the bucket/object name if the client explicitly // added it. However, when decrypting an object the bucket/object name must // be part of the object. Therefore, the bucket/object name must be added // to the context, if not present, whenever a decryption is performed.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 17:40:33 UTC 2024 - 6.4K bytes - Viewed (0) -
cmd/erasure-sets_test.go
{"The Shining Script <v1>.pdf", 38}, {"Cost Benefit Analysis (2009-2010).pptx", 59}, {"117Gn8rfHL2ACARPAhaFd0AGzic9pUbIA/5OCn5A", 35}, {"SHØRT", 49}, {"There are far too many object names, and far too few bucket names!", 8}, {"a/b/c/", 159}, {"/a/b/c", 96}, {string([]byte{0xff, 0xfe, 0xfd}), 147}, } // Tests hashing order to be consistent. for i, testCase := range testCases {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Feb 12 07:21:56 UTC 2024 - 6.9K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/net/protocol/storage/Handler.java
if (minioClient == null) { throw new IOException("Access is not ready."); } try { final GetObjectArgs args = GetObjectArgs.builder().bucket(bucketName).object(objectName).build(); return minioClient.getObject(args); } catch (InvalidKeyException | ErrorResponseException | IllegalArgumentException | InsufficientDataException | InternalException
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/bootstrap/option/instances.go
return skipOption("load_stats_config_json_str") } type HistogramMatch struct { Prefix string `json:"prefix"` } type HistogramBucket struct { Match HistogramMatch `json:"match"` Buckets []float64 `json:"buckets"` } func EnvoyHistogramBuckets(value []HistogramBucket) Instance { return newOption("histogram_buckets", value) } func EnvoyStatsCompression(value string) Instance {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:02:38 UTC 2024 - 9K bytes - Viewed (0) -
cmd/metrics-v2_test.go
ttfbHist := prometheus.NewHistogramVec( prometheus.HistogramOpts{ Name: "s3_ttfb_seconds", Help: "Time taken by requests served by current MinIO server instance", Buckets: histBuckets, }, []string{"api"}, ) observations := []struct { val float64 label string }{ { val: 0.02, label: labels[0], }, { val: 0.07,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Mar 04 18:05:56 UTC 2024 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authorization/authorizerfactory/metrics.go
&compbasemetrics.HistogramOpts{ Name: "apiserver_delegated_authz_request_duration_seconds", Help: "Request latency in seconds. Broken down by status code.", Buckets: []float64{0.25, 0.5, 0.7, 1, 1.5, 3, 5, 10}, StabilityLevel: compbasemetrics.ALPHA, }, []string{"code"}, ) ) var _ = webhookmetrics.AuthorizerMetrics(delegatingAuthorizerMetrics{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:01:15 UTC 2024 - 2.8K bytes - Viewed (0) -
cmd/handler-utils_test.go
package cmd import ( "bytes" "context" "encoding/xml" "io" "net/http" "net/textproto" "os" "reflect" "testing" "github.com/minio/minio/internal/config" ) // Tests validate bucket LocationConstraint. func TestIsValidLocationConstraint(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() obj, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 6.1K bytes - Viewed (0) -
cmd/metrics-router.go
"github.com/minio/pkg/v3/env" ) const ( prometheusMetricsPathLegacy = "/prometheus/metrics" prometheusMetricsV2ClusterPath = "/v2/metrics/cluster" prometheusMetricsV2BucketPath = "/v2/metrics/bucket" prometheusMetricsV2NodePath = "/v2/metrics/node" prometheusMetricsV2ResourcePath = "/v2/metrics/resource" // Metrics v3 endpoints metricsV3Path = "/metrics/v3" ) // Standard env prometheus auth type
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 2.5K bytes - Viewed (0) -
cmd/data-usage.go
for _, er := range pool.sets { // Load bucket usage prefixes ctx, done := context.WithTimeout(ctx, 2*time.Second) ok := cache.load(ctx, er, bucket+slashSeparator+dataUsageCacheName) == nil done() if ok { root := cache.find(bucket) if root == nil { // We dont have usage information for this bucket in this // set, go to the next set continue }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 09 00:51:34 UTC 2024 - 5.6K bytes - Viewed (0)