- Sort Score
- Result 10 results
- Languages All
Results 241 - 250 of 613 for Bucket (0.03 sec)
-
cmd/warm-backend-minio.go
// Validation of credentials if conf.AccessKey == "" || conf.SecretKey == "" { return nil, errors.New("both access and secret keys are required") } if conf.Bucket == "" { return nil, errors.New("no bucket name was provided") } u, err := url.Parse(conf.Endpoint) if err != nil { return nil, err } creds := credentials.NewStaticV4(conf.AccessKey, conf.SecretKey, "")
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 4K bytes - Viewed (1) -
cmd/metacache.go
} m.fileNotFound = m.fileNotFound || update.fileNotFound } // delete all cache data on disks. func (m *metacache) delete(ctx context.Context) { if m.bucket == "" || m.id == "" { bugLogIf(ctx, fmt.Errorf("metacache.delete: bucket (%s) or id (%s) empty", m.bucket, m.id)) return } objAPI := newObjectLayerFn() if objAPI == nil { internalLogIf(ctx, errors.New("metacache.delete: no object layer")) return }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 6K bytes - Viewed (0) -
cmd/metacache-set_gen.go
switch msgp.UnsafeString(field) { case "ID": z.ID, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "ID") return } case "Bucket": z.Bucket, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Bucket") return } case "BaseDir": z.BaseDir, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "BaseDir") return }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Mar 19 20:23:12 UTC 2024 - 13.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/config/cbean/ca/bs/BsCrawlingInfoParamCA.java
import org.opensearch.search.aggregations.bucket.filter.FilterAggregationBuilder; import org.opensearch.search.aggregations.bucket.global.GlobalAggregationBuilder; import org.opensearch.search.aggregations.bucket.histogram.HistogramAggregationBuilder; import org.opensearch.search.aggregations.bucket.missing.MissingAggregationBuilder; import org.opensearch.search.aggregations.bucket.range.IpRangeAggregationBuilder;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 28.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/config/cbean/ca/bs/BsBoostDocumentRuleCA.java
import org.opensearch.search.aggregations.bucket.filter.FilterAggregationBuilder; import org.opensearch.search.aggregations.bucket.global.GlobalAggregationBuilder; import org.opensearch.search.aggregations.bucket.histogram.HistogramAggregationBuilder; import org.opensearch.search.aggregations.bucket.missing.MissingAggregationBuilder; import org.opensearch.search.aggregations.bucket.range.IpRangeAggregationBuilder;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 50.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/config/cbean/ca/bs/BsDuplicateHostCA.java
import org.opensearch.search.aggregations.bucket.filter.FilterAggregationBuilder; import org.opensearch.search.aggregations.bucket.global.GlobalAggregationBuilder; import org.opensearch.search.aggregations.bucket.histogram.HistogramAggregationBuilder; import org.opensearch.search.aggregations.bucket.missing.MissingAggregationBuilder; import org.opensearch.search.aggregations.bucket.range.IpRangeAggregationBuilder;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 50.7K bytes - Viewed (0) -
.teamcity/src/main/kotlin/model/BucketExtensions.kt
return bucketsOfFirstElement + bucketsOfRestElements } else { val buckets = arrayListOf(largestElement) var restCapacity = roughSizeOfEachBucket - toIntFunction(largestElement) while (restCapacity > 0 && list.isNotEmpty() && buckets.size < maxNumberInBucket) { val smallestElement = list.findLast { searched -> buckets.all { canRunTogether(it, searched) } } ?: break list.remove(smallestElement)
Registered: Wed Sep 10 11:36:15 UTC 2025 - Last Modified: Wed Feb 12 09:12:03 UTC 2025 - 5.7K bytes - Viewed (0) -
cmd/batch-rotate_gen.go
} default: err = dc.Skip() if err != nil { err = msgp.WrapError(err, "Flags") return } } } case "Bucket": z.Bucket, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Bucket") return } case "Prefix": z.Prefix, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Prefix") return }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sat Dec 02 10:51:33 UTC 2023 - 27.1K bytes - Viewed (0) -
cmd/metrics-v3-scanner.go
scannerLastActivitySeconds = "last_activity_seconds" ) var ( scannerBucketScansFinishedMD = NewCounterMD(scannerBucketScansFinished, "Total number of bucket scans finished since server start") scannerBucketScansStartedMD = NewCounterMD(scannerBucketScansStarted, "Total number of bucket scans started since server start") scannerDirectoriesScannedMD = NewCounterMD(scannerDirectoriesScanned, "Total number of directories scanned since server start")
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri May 24 19:29:25 UTC 2024 - 2.8K bytes - Viewed (0) -
cmd/object-api-options_test.go
// it is intended to be expanded when the function is worked on in the future. func TestGetAndValidateAttributesOpts(t *testing.T) { globalBucketVersioningSys = &BucketVersioningSys{} bucket := minioMetaBucket ctx := t.Context() testCases := []struct { name string headers http.Header wantObjectAttrs map[string]struct{} }{ { name: "empty header",
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 2.4K bytes - Viewed (0)