- Sort Score
- Num 10 results
- Language All
Results 31 - 40 of 48 for deleteAll (0.05 seconds)
-
cmd/erasure-server-pool.go
} } if err == nil { // Purge the entire bucket metadata entirely. z.deleteAll(context.Background(), minioMetaBucket, pathJoin(bucketMetaPrefix, bucket)) } return toObjectErr(err, bucket) } // deleteAll will rename bucket+prefix unconditionally across all disks to // minioMetaTmpDeletedBucket + unique uuid,Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 89.2K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/failureurl/ApiAdminFailureurlAction.java
* Deletes all failure URL logs. * * @return JSON response with result status */ @Execute public JsonResponse<ApiResult> delete$all() { try { failureUrlService.deleteAll(failureUrlPager); failureUrlPager.clear(); saveInfo(messages -> messages.addSuccessFailureUrlDeleteAll(GLOBAL)); } catch (final Exception e) {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 6.2K bytes - Click Count (0) -
internal/bucket/lifecycle/lifecycle_test.go
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 55.5K bytes - Click Count (0) -
cmd/metacache.go
return } ez, ok := objAPI.(deleteAllStorager) if !ok { bugLogIf(ctx, errors.New("metacache.delete: expected objAPI to be 'deleteAllStorager'")) return } ez.deleteAll(ctx, minioMetaBucket, metacachePrefixForID(m.bucket, m.id))Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Jul 12 16:23:16 GMT 2024 - 6K bytes - Click Count (0) -
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueServiceTest.java
.execute() .actionGet() .getHits() .getTotalHits() .value() > 0); urlQueueService.deleteAll(); assertFalse(fesenClient.prepareSearch("fess_crawler.queue") .setQuery(QueryBuilders.termQuery("sessionId", "id1")) .execute() .actionGet()
Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Wed Jan 14 23:48:16 GMT 2026 - 14.5K bytes - Click Count (0) -
cmd/test-utils_test.go
func ExecObjectLayerTest(t TestErrHandler, objTest objTestType) { { ctx, cancel := context.WithCancel(context.Background()) if localMetacacheMgr != nil { localMetacacheMgr.deleteAll() } objLayer, fsDir, err := prepareFS(ctx) if err != nil { t.Fatalf("Initialization of object layer failed for single node setup: %s", err) } setObjectLayer(objLayer)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 77K bytes - Click Count (0) -
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataServiceTest.java
dataService.store(accessResult1); assertNotNull(dataService.getAccessResult("id1", "http://www.id1.com/")); dataService.deleteAll(); assertNull(dataService.getAccessResult("id1", "http://www.id1.com/")); assertNull(dataService.getAccessResult("id2", "http://www.id2.com/")); } @TestCreated: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Wed Jan 14 23:48:16 GMT 2026 - 15.7K bytes - Click Count (0) -
cmd/data-scanner.go
} opts.Versioned = globalBucketVersioningSys.PrefixEnabled(obj.Bucket, obj.Name) opts.VersionSuspended = globalBucketVersioningSys.PrefixSuspended(obj.Bucket, obj.Name) if lcEvent.Action.DeleteAll() { opts.DeletePrefix = true // use prefix delete on exact object (this is an optimization to avoid fan-out calls) opts.DeletePrefixObject = true } var ( dobj ObjectInfo err error )
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 45.5K bytes - Click Count (0) -
cmd/erasure-healing.go
// If all disks are having errors, we give up. if disksToHealCount == 0 { return result, fmt.Errorf("all drives had write errors, unable to heal %s/%s", bucket, object) } } } defer er.deleteAll(context.Background(), minioMetaTmpBucket, tmpID) // Rename from tmp location to the actual location. for i, disk := range outDatedDisks { if disk == OfflineDisk { continue }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 34.7K bytes - Click Count (0) -
cmd/erasure-object.go
} if len(buffer) > int(fi.Erasure.BlockSize) { buffer = buffer[:fi.Erasure.BlockSize] } partName := "part.1" tempErasureObj := pathJoin(uniqueID, fi.DataDir, partName) defer er.deleteAll(context.Background(), minioMetaTmpBucket, tempObj) var inlineBuffers []*bytes.Buffer if globalStorageClass.ShouldInline(erasure.ShardFileSize(data.ActualSize()), opts.Versioned) {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 80.4K bytes - Click Count (0)