Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 40 for DeleteAll (0.16 sec)

  1. 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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java

            return new SuggestDeleteResponse(result.getFailures(), System.currentTimeMillis() - start);
        }
    
        public SuggestDeleteResponse deleteAll() {
            final SuggestDeleteResponse response = deleteByQuery(QueryBuilders.matchAllQuery());
            restoreElevateWord();
            return response;
        }
    
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  3. cmd/data-scanner.go

    	var action lifecycle.Action
    	action, size = i.applyLifecycle(ctx, o, oi)
    	done()
    
    	// Note: objDeleted is true if and only if action ==
    	// lifecycle.DeleteAllVersionsAction
    	if action.DeleteAll() {
    		return true, 0
    	}
    
    	// For instance, an applied lifecycle means we remove/transitioned an object
    	// from the current deployment, which means we don't have to call healing
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/web/admin/searchlist/AdminSearchlistAction.java

            }
            return asListHtml();
        }
    
        @Execute
        @Secured({ ROLE, ROLE + VIEW })
        public HtmlResponse deleteall(final ListForm form) {
            validate(form, messages -> {}, this::asListHtml);
            verifyToken(this::asListHtml);
            try {
                searchHelper.deleteByQuery(request, form);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Wed Jul 24 09:03:45 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  5. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java

            }
        }
    
        protected void deleteBySessionId(final String sessionId) {
            delete(builder -> builder.setQuery(QueryBuilders.termQuery(SESSION_ID, sessionId)));
        }
    
        public void deleteAll() {
            delete(builder -> builder.setQuery(QueryBuilders.matchAllQuery()));
        }
    
        public void delete(final Consumer<SearchRequestBuilder> callback) {
            SearchResponse response = 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)
  6. 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,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/suggest/SuggesterTest.java

            assertEquals(2, suggester.getAllWordsNum());
            assertEquals(2, suggester.getDocumentWordsNum());
            assertEquals(1, suggester.getQueryWordsNum());
    
            suggester.indexer().deleteAll();
            suggester.refresh();
            assertEquals(0, suggester.getAllWordsNum());
            assertEquals(0, suggester.getDocumentWordsNum());
            assertEquals(0, suggester.getQueryWordsNum());
        }
    
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 37K bytes
    - Viewed (0)
  8. cmd/erasure-healing.go

    			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
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  9. 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,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 55.1K bytes
    - Viewed (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) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
Back to top