- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for getOpts (0.07 sec)
-
cmd/object-api-options.go
opts.ServerSideEncryption = encrypt.NewSSE() } return } // get ObjectOptions for GET calls from encryption headers func getOpts(ctx context.Context, r *http.Request, bucket, object string) (ObjectOptions, error) { var opts ObjectOptions var partNumber int var err error if pn := r.Form.Get(xhttp.PartNumber); pn != "" {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 21 21:13:59 UTC 2024 - 14.4K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
return } srcOpts.VersionID = vid // convert copy src and dst encryption options for GET/PUT calls getOpts := ObjectOptions{VersionID: srcOpts.VersionID} if srcOpts.ServerSideEncryption != nil { getOpts.ServerSideEncryption = encrypt.SSE(srcOpts.ServerSideEncryption) } dstOpts, err = copyDstOpts(ctx, r, dstBucket, dstObject, nil) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Aug 31 18:25:48 UTC 2024 - 39.2K bytes - Viewed (0) -
cmd/s3-zip-handlers.go
return } zipPath, object, err := splitZipExtensionPath(object) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } opts, err := getOpts(ctx, r, bucket, zipPath) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } getObjectInfo := objectAPI.GetObjectInfo // Check for auth type to return S3 compatible error.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 15.8K bytes - Viewed (0) -
cmd/bucket-object-lock.go
} // If this not a WORM enabled bucket, we should return right here. return mode, retainDate, legalHold, ErrNone } opts, err := getOpts(ctx, rq, bucket, object) if err != nil { return mode, retainDate, legalHold, toAPIErrorCode(ctx, err) } replica := rq.Header.Get(xhttp.AmzBucketReplicationStatus) == replication.Replica.String()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 13.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/rank/fusion/DefaultSearcher.java
final SearchResultBuilder builder = SearchResult.create(); searchResponseOpt.ifPresent(searchResponse -> { final SearchHits searchHits = searchResponse.getHits(); builder.allRecordCount(searchHits.getTotalHits().value); builder.allRecordCountRelation(searchHits.getTotalHits().relation.toString()); builder.queryTime(searchResponse.getTook().millis());
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Mon Jul 22 06:56:21 UTC 2024 - 10.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/settings/ArraySettings.java
String scrollId = response.getScrollId(); final Map<String, Object>[] array = new Map[(int) response.getHits().getTotalHits().value]; int count = 0; try { while (scrollId != null) { final SearchHit[] hits = response.getHits().getHits(); if (hits.length == 0) { break; }
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Sat Oct 12 00:10:39 UTC 2024 - 10.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/request/suggest/SuggestRequest.java
return functionScoreQueryBuilder; } protected SuggestResponse createResponse(final SearchResponse searchResponse) { final SearchHit[] hits = searchResponse.getHits().getHits(); final List<String> words = new ArrayList<>(); final List<String> firstWords = new ArrayList<>(); final List<String> secondWords = new ArrayList<>();
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Sat Oct 12 00:10:39 UTC 2024 - 13.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java
String scrollId = response.getScrollId(); try { while (scrollId != null) { final SearchHit[] hits = response.getHits().getHits(); if (hits.length == 0) { break; } for (final SearchHit hit : hits) {
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Sat Oct 12 00:10:39 UTC 2024 - 26.1K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
}); String scrollId = response.getScrollId(); try { while (scrollId != null) { final SearchHits searchHits = response.getHits(); if (searchHits.getHits().length == 0) { break; } final BulkResponse bulkResponse = getClient().get(c -> {
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 23.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java
String scrollId = response.getScrollId(); try { while (scrollId != null) { final SearchHit[] hits = response.getHits().getHits(); if (hits.length == 0) { break; } final BulkRequestBuilder bulkRequestBuiler = client.prepareBulk();
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Sat Oct 12 00:10:39 UTC 2024 - 11.7K bytes - Viewed (0)