Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for bulk_5 (0.17 sec)

  1. docs/debugging/xattr/main.go

    			if err != nil {
    				data = append(data, []string{attr, errors.Unwrap(err).Error()})
    			} else {
    				data = append(data, []string{attr, fmt.Sprintf("%d", value)})
    			}
    		}
    		table.AppendBulk(data) // Add Bulk Data
    		table.Render()
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 29 23:52:41 GMT 2023
    - 3.2K bytes
    - Viewed (0)
  2. cmd/erasure-object.go

    	return reduceWriteQuorumErrs(ctx, g.Wait(), objectOpIgnoredErrs, writeQuorum)
    }
    
    // DeleteObjects deletes objects/versions in bulk, this function will still automatically split objects list
    // into smaller bulks if some object names are found to be duplicated in the delete list, splitting
    // into smaller bulks will avoid holding twice the write lock of the duplicated object names.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  3. cmd/erasure-server-pool.go

    		objects[i].ObjectName = encodeDirObject(objects[i].ObjectName)
    
    		derrs[i] = checkDelObjArgs(ctx, bucket, objects[i].ObjectName)
    		objSets.Add(objects[i].ObjectName)
    	}
    
    	// Acquire a bulk write lock across 'objects'
    	multiDeleteLock := z.NewNSLock(bucket, objSets.ToSlice()...)
    	lkctx, err := multiDeleteLock.GetLock(ctx, globalOperationTimeout)
    	if err != nil {
    		for i := range derrs {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  4. cmd/encryption-v1.go

    // Further, it decrypts all single-part SSE-S3 encrypted objects
    // and formats ETags of SSE-C / SSE-KMS encrypted objects to
    // be AWS S3 compliant.
    //
    // DecryptETags uses a KMS bulk decryption API, if available, which
    // is more efficient than decrypting ETags sequentually.
    func DecryptETags(ctx context.Context, k kms.KMS, objects []ObjectInfo) error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 36.5K bytes
    - Viewed (0)
  5. cmd/storage-rest-server.go

    	}
    	volume := r.Form.Get(storageRESTVolume)
    	err := s.getStorage().MakeVol(r.Context(), volume)
    	if err != nil {
    		s.writeErrorResponse(w, err)
    	}
    }
    
    // MakeVolBulkHandler - create multiple volumes as a bulk operation.
    func (s *storageRESTServer) MakeVolBulkHandler(w http.ResponseWriter, r *http.Request) {
    	if !s.IsValid(w, r) {
    		return
    	}
    	volumes := strings.Split(r.Form.Get(storageRESTVolumes), ",")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  6. cmd/storage-rest-client.go

    			if info.Error != "" {
    				return info, toStorageErr(errors.New(info.Error))
    			}
    			return info, nil
    		},
    	)
    
    	return client.diskInfoCache.Get()
    }
    
    // MakeVolBulk - create multiple volumes in a bulk operation.
    func (client *storageRESTClient) MakeVolBulk(ctx context.Context, volumes ...string) (err error) {
    	return errInvalidArgument
    }
    
    // MakeVol - create a volume on a remote disk.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  7. cmd/admin-router.go

    			adminRouter.Methods(http.MethodPut).Path(adminVersion+"/restore-config-history-kv").HandlerFunc(adminMiddleware(adminAPI.RestoreConfigHistoryKVHandler)).Queries("restoreId", "{restoreId:.*}")
    		}
    
    		// Config import/export bulk operations
    		if enableConfigOps {
    			// Get config
    			adminRouter.Methods(http.MethodGet).Path(adminVersion + "/config").HandlerFunc(adminMiddleware(adminAPI.GetConfigHandler))
    			// Set config
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 21:09:36 GMT 2024
    - 25.5K bytes
    - Viewed (0)
  8. cmd/xl-storage_test.go

    			t.Fatalf("TestXLStorage %d:  Expected the error to be : \"%v\", got: \"%v\".", i+1, testCase.expectedErr, err)
    		}
    	}
    }
    
    // TestXLStorageDeleteVersion will test if version deletes and bulk deletes work as expected.
    func TestXLStorageDeleteVersion(t *testing.T) {
    	// create xlStorage test setup
    	xl, _, err := newXLStorageTestSetup(t)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 11 17:45:28 GMT 2024
    - 66.7K bytes
    - Viewed (0)
  9. cmd/erasure-sets.go

    		return ObjectInfo{}, err
    	}
    	set := s.getHashedSet(object)
    	return set.DeleteObject(ctx, bucket, object, opts)
    }
    
    // DeleteObjects - bulk delete of objects
    // Bulk delete is only possible within one set. For that purpose
    // objects are group by set first, and then bulk delete is invoked
    // for each set, the error response of each delete will be returned
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 37.7K bytes
    - Viewed (5)
  10. cmd/erasure-healing.go

    	errs := statAllDirs(ctx, storageDisks, bucket, object)
    	danglingObject := isObjectDirDangling(errs)
    	if danglingObject {
    		if !dryRun && remove {
    			var wg sync.WaitGroup
    			// Remove versions in bulk for each disk
    			for index, disk := range storageDisks {
    				if disk == nil {
    					continue
    				}
    				wg.Add(1)
    				go func(index int, disk StorageAPI) {
    					defer wg.Done()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
Back to top