Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for DELETING (0.14 sec)

  1. cmd/test-utils_test.go

    	return makeTestTargetURL(endPoint, bucketName, objectName, url.Values{})
    }
    
    // return URL for deleting the object from the bucket.
    func getDeleteObjectURL(endPoint, bucketName, objectName string) string {
    	return makeTestTargetURL(endPoint, bucketName, objectName, url.Values{})
    }
    
    // return URL for deleting multiple objects from a bucket.
    func getMultiDeleteObjectURL(endPoint, bucketName string) string {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 76.9K bytes
    - Viewed (0)
  2. cmd/erasure-healing_test.go

    	}
    
    	err = firstDisk.Delete(context.Background(), bucket, pathJoin(object, fi.DataDir, "part.1"), DeleteOptions{
    		Recursive: false,
    		Immediate: false,
    	})
    	if err != nil {
    		t.Errorf("Failure during deleting part.1 - %v", err)
    	}
    
    	err = firstDisk.WriteAll(context.Background(), bucket, pathJoin(object, fi.DataDir, "part.1"), []byte{})
    	if err != nil {
    		t.Errorf("Failure during creating part.1 - %v", err)
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  3. cmd/xl-storage.go

    	} else {
    		err = Rename(filePath, targetPath)
    	}
    
    	var targetPath2 string
    	if immediatePurge && HasSuffix(filePath, SlashSeparator) {
    		// With immediate purge also attempt deleting for `__XL_DIR__` folder/directory objects.
    		targetPath2 = pathutil.Join(s.drivePath, minioMetaTmpDeletedBucket, mustGetUUID())
    		renameAll(encodeDirObject(filePath), targetPath2, pathutil.Join(s.drivePath, minioMetaBucket))
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (0)
  4. pkg/proxy/nftables/proxier.go

    				tx.Delete(&knftables.Chain{
    					Name: chain,
    				})
    				delete(proxier.staleChains, chain)
    				deleted++
    			}
    		}
    		if deleted > 0 {
    			proxier.logger.Info("Deleting stale nftables chains", "numChains", deleted)
    			err := proxier.nftables.Run(context.TODO(), tx)
    			if err != nil {
    				// We already deleted the entries from staleChains, but if
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  5. cmd/iam-store.go

    		}
    		gset.Remove(group)
    		cache.iamUserGroupMemberships[member] = gset
    	}
    
    	cache.updatedAt = time.Now()
    	return gi.UpdatedAt, nil
    }
    
    // RemoveUsersFromGroup - removes users from group, deleting it if it is empty.
    func (store *IAMStoreSys) RemoveUsersFromGroup(ctx context.Context, group string, members []string) (updatedAt time.Time, err error) {
    	if group == "" {
    		return updatedAt, errInvalidArgument
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 75.8K bytes
    - Viewed (0)
  6. cmd/erasure-object.go

    		}(index, disk)
    	}
    	wg.Wait()
    
    	// Reduce errors for each object
    	for objIndex := range objects {
    		diskErrs := make([]error, len(storageDisks))
    		// Iterate over disks to fetch the error
    		// of deleting of the current object
    		for i := range delObjErrs {
    			// delObjErrs[i] is not nil when disks[i] is also not nil
    			if delObjErrs[i] != nil {
    				diskErrs[i] = delObjErrs[i][objIndex]
    			}
    		}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 78.6K bytes
    - Viewed (0)
  7. pkg/controller/job/job_controller.go

    	if err != nil {
    		utilruntime.HandleError(fmt.Errorf("Couldn't get key for job %#v: %v", job, err))
    		return 0, metrics.JobSyncActionTracking, nil
    	}
    
    	if jobSuspended(job) {
    		logger.V(4).Info("Deleting all active pods in suspended job", "job", klog.KObj(job), "active", active)
    		podsToDelete := activePodsForRemoval(job, jobCtx.activePods, int(active))
    		jm.expectations.ExpectDeletions(logger, jobKey, len(podsToDelete))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go

    	deletedPod := &example.Pod{}
    	if err := store.Delete(ctx, key, deletedPod, nil, storage.ValidateAllObjectFunc, originalPod); err != nil {
    		t.Errorf("Unexpected failure during deletion: %v", err)
    	}
    
    	// Now try deleting with stale object.
    	out := &example.Pod{}
    	if err := store.Delete(ctx, key, out, nil, storage.ValidateAllObjectFunc, originalPod); !storage.IsNotFound(err) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 91.4K bytes
    - Viewed (0)
Back to top