- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 160 for xBuckets (0.1 sec)
-
manifests/addons/dashboards/lib/output.json
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Tue Jun 04 18:05:06 UTC 2024 - 25.2K bytes - Viewed (0) -
manifests/addons/dashboards/pilot-dashboard.gen.json
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Jul 26 23:54:32 UTC 2024 - 24.7K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
return sys.initialized } // Loads bucket metadata for all buckets into BucketMetadataSys. func (sys *BucketMetadataSys) init(ctx context.Context, buckets []string) { count := globalEndpoints.ESCount() * 10 for { if len(buckets) < count { sys.concurrentLoad(ctx, buckets) break } sys.concurrentLoad(ctx, buckets[:count]) buckets = buckets[count:] } sys.Lock() sys.initialized = true
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 28 15:32:18 UTC 2024 - 20.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/SearchLogService.java
}); final Terms agg = list.getAggregations().get(SearchLogPager.LOG_TYPE_CLICK_COUNT); final List<? extends Terms.Bucket> buckets = agg.getBuckets(); updatePagerByAgg(pager, buckets.size()); return buckets.stream().map(e -> { final Map<String, Object> map = new HashMap<>();
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 28.4K bytes - Viewed (0) -
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
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 22:23:33 UTC 2024 - 16.1K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/Hashing.java
*/ public static int consistentHash(HashCode hashCode, int buckets) { return consistentHash(hashCode.padToLong(), buckets); } /** * Assigns to {@code input} a "bucket" in the range {@code [0, buckets)}, in a uniform manner that * minimizes the need for remapping as {@code buckets} grows. That is, {@code consistentHash(h, * n)} equals: * * <ul>
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Jul 19 16:02:36 UTC 2024 - 29.3K bytes - Viewed (0) -
cmd/peer-s3-client.go
resultMap[bi.Name] = bi } } } // loop through buckets and see if some with lost quorum // these could be stale buckets lying around, queue a heal // of such a bucket. This is needed here as we identify such // buckets here while listing buckets. As part of regular // globalBucketMetadataSys.Init() call would get a valid // buckets only and not the quourum lost ones like this, so // explicit call
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 22:26:05 UTC 2024 - 15.4K bytes - Viewed (0) -
cmd/object_api_suite_test.go
if err != nil { t.Fatalf("%s: <ERROR> %s", instanceType, err) } buckets, err := obj.ListBuckets(context.Background(), BucketOptions{}) if err != nil { t.Fatalf("%s: <ERROR> %s", instanceType, err) } 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" {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 02 15:13:05 UTC 2024 - 33.3K bytes - Viewed (0) -
helm/minio/README.md
--set trustedCertsSecret=minio-trusted-certs ``` ### Create buckets after install Install the chart, specifying the buckets you want to create after install: ```bash helm install --set buckets[0].name=bucket1,buckets[0].policy=none,buckets[0].purge=false minio/minio ``` Description of the configuration parameters used above - - `buckets[].name` - name of the bucket to create, must be a string with length > 0
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jan 24 07:27:57 UTC 2024 - 10.9K bytes - Viewed (0) -
cmd/global-heal.go
func (er *erasureObjects) healErasureSet(ctx context.Context, buckets []string, tracker *healingTracker) error { bgSeq, found := globalBackgroundHealState.getHealSequenceByToken(bgHealingUUID) if !found { return errors.New("no local healing sequence initialized, unable to heal the drive") } scanMode := madmin.HealNormalScan // Make sure to copy since `buckets slice` // is modified in place by tracker.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.3K bytes - Viewed (0)