- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 581 for bucketCh (1.98 sec)
-
cmd/erasure.go
Cache: make(map[string]dataUsageEntry, len(oldCache.Cache)), } // Put all buckets into channel. bucketCh := make(chan BucketInfo, len(buckets)) // Shuffle buckets to ensure total randomness of buckets, being scanned. // Otherwise same set of buckets get scanned across erasure sets always. // at any given point in time. This allows different buckets to be scanned // in different order per erasure set, this wider spread is needed when
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 16K bytes - Viewed (1) -
cmd/object_api_suite_test.go
} if len(buckets) != 2 { t.Errorf("%s: Expected number of bucket to be `%d`, but instead found `%d`", instanceType, 2, len(buckets)) } if buckets[0].Name != "bucket1" { t.Errorf("%s: Expected bucket name to be `%s`, but instead found `%s`", instanceType, "bucket1", buckets[0].Name) } if buckets[1].Name != "bucket2" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 32.3K bytes - Viewed (0) -
cmd/object-api-deleteobject_test.go
// that has been deleted. { "bucket1", []objectUpload{{"object0", "content"}, {"object1", "content"}}, "object0", []string{"object1"}, }, // Test 2: remove an object inside a directory and checks it is deleted // with its parent since this former becomes empty { "bucket2", []objectUpload{{"object0", "content"}, {"dir/object1", "content"}}, "dir/object1",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 23 15:46:00 GMT 2022 - 3.9K bytes - Viewed (0) -
.teamcity/src/main/kotlin/model/bucket-extensions.kt
bucketsOfFirstElement + bucketsOfRestElements } else { val buckets = arrayListOf(largestElement) var restCapacity = expectedBucketSize - toIntFunction(largestElement) while (restCapacity > 0 && list.isNotEmpty() && buckets.size < maxNumberInBucket) { val smallestElement = list.findLast { searched -> buckets.all { canRunTogether(it, searched) } } ?: break list.remove(smallestElement)
Plain Text - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Thu Nov 17 05:17:44 GMT 2022 - 4K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
if err != nil { rpt.SetStatus(bucket, fileName, err) continue } v, _ := globalBucketMetadataSys.Get(bucket) bucketMap[bucket] = &v } bucketMap[bucket].ObjectLockConfigXML = configData bucketMap[bucket].ObjectLockConfigUpdatedAt = updatedAt rpt.SetStatus(bucket, fileName, nil) } } // import versioning metadata
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 32.5K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
// Load bucket metadata sys. sys.init(ctx, buckets) return nil } // concurrently load bucket metadata to speed up loading bucket metadata. func (sys *BucketMetadataSys) concurrentLoad(ctx context.Context, buckets []BucketInfo, failedBuckets map[string]struct{}) { g := errgroup.WithNErrs(len(buckets)) bucketMetas := make([]BucketMetadata, len(buckets)) for index := range buckets { index := index
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 19.8K bytes - Viewed (0) -
docs/federation/lookup/README.md
example, if the domain is set to `domain.com`, the buckets `bucket1`, `bucket2` will be accessible as `bucket1.domain.com` and `bucket2.domain.com`. #### MINIO_PUBLIC_IPS This is comma separated list of IP addresses to which buckets created on this MinIO instance will resolve to. For example, a bucket `bucket1` created on current MinIO instance will be accessible as `bucket1.domain.com`, and the DNS entry for
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 29 04:28:45 GMT 2022 - 4K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
s3LogIf(ctx, err) return opts, InvalidVersionID{ Bucket: bucket, Object: object, VersionID: vid, } } if !versioned && !versionSuspended { return opts, InvalidArgument{ Bucket: bucket, Object: object, Err: fmt.Errorf("version-id specified %s but versioning is not enabled on %s", opts.VersionID, bucket), } } } return ObjectOptions{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/bucket-targets.go
} // RemoveTarget - removes a remote bucket target for this source bucket. func (sys *BucketTargetSys) RemoveTarget(ctx context.Context, bucket, arnStr string) error { if arnStr == "" { return BucketRemoteArnInvalid{Bucket: bucket} } arn, err := madmin.ParseARN(arnStr) if err != nil { return BucketRemoteArnInvalid{Bucket: bucket} }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0) -
cmd/bucket-handlers.go
return } } for _, bucket := range bucketsInConflict.ToSlice() { dnsLogIf(ctx, fmt.Errorf("Unable to add bucket DNS entry for bucket %s, an entry exists for the same bucket by a different tenant. This local bucket will be ignored. Bucket names are globally unique in federated deployments. Use path style requests on following addresses '%v' to access this bucket", bucket, globalDomainIPs.ToSlice())) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 16:27:27 GMT 2024 - 61.6K bytes - Viewed (0)