Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 48 for deleteAll (0.05 seconds)

  1. 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)
  2. 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)
  3. internal/bucket/lifecycle/lifecycle_test.go

    	lc := Lifecycle{
    		Rules: []Rule{
    			{
    				ID:     "ExpiredObjectDeleteAllVersions-20",
    				Status: "Enabled",
    				Expiration: Expiration{
    					set:       true,
    					DeleteAll: Boolean{val: true, set: true},
    					Days:      20,
    				},
    			},
    			{
    				ID:     "Transition-10",
    				Status: "Enabled",
    				Transition: Transition{
    					set:          true,
    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)
  4. 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)
  5. 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)
  6. 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)
  7. 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/"));
        }
    
        @Test
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Wed Jan 14 23:48:16 GMT 2026
    - 15.7K bytes
    - Click Count (0)
  8. 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)
  9. 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)
  10. 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)
Back to Top