Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for DeleteBulk (0.04 sec)

  1. cmd/naughty-disk_test.go

    		return nil, err
    	}
    	return d.disk.CheckParts(ctx, volume, path, fi)
    }
    
    func (d *naughtyDisk) DeleteBulk(ctx context.Context, volume string, paths ...string) (err error) {
    	if err := d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.DeleteBulk(ctx, volume, paths...)
    }
    
    func (d *naughtyDisk) Delete(ctx context.Context, volume string, path string, deleteOpts DeleteOptions) (err error) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 10.1K bytes
    - Viewed (0)
  2. cmd/xl-storage-disk-id-check.go

    }
    
    func (p *xlStorageDiskIDCheck) DeleteBulk(ctx context.Context, volume string, paths ...string) (err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricDeleteBulk, append([]string{volume}, paths...)...)
    	if err != nil {
    		return err
    	}
    	defer done(0, &err)
    
    	return p.storage.DeleteBulk(ctx, volume, paths...)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  3. cmd/storage-rest-client.go

    	verifyResp := CheckPartsResp{}
    	err = verifyResp.DecodeMsg(dec)
    	if err != nil {
    		return nil, toStorageErr(err)
    	}
    
    	return &verifyResp, nil
    }
    
    func (client *storageRESTClient) DeleteBulk(ctx context.Context, volume string, paths ...string) (err error) {
    	values := make(url.Values)
    	values.Set(storageRESTVolume, volume)
    
    	req := &DeleteBulkReq{Paths: paths}
    	body, err := req.MarshalMsg(nil)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  4. cmd/erasure-multipart.go

    	g := errgroup.WithNErrs(len(storageDisks))
    	for index, disk := range storageDisks {
    		if disk == nil {
    			continue
    		}
    		index := index
    		g.Go(func() error {
    			_ = storageDisks[index].DeleteBulk(ctx, minioMetaMultipartBucket, paths...)
    			return nil
    		}, index)
    	}
    	g.Wait()
    }
    
    // Clean-up the old multipart uploads. Should be run in a Go routine.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  5. cmd/storage-rest-server.go

    	if err := req.DecodeMsg(mr); err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    
    	volume := r.Form.Get(storageRESTVolume)
    	keepHTTPResponseAlive(w)(s.getStorage().DeleteBulk(r.Context(), volume, req.Paths...))
    }
    
    // ReadMultiple returns multiple files
    func (s *storageRESTServer) ReadMultiple(w http.ResponseWriter, r *http.Request) {
    	if !s.IsValid(w, r) {
    		return
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
Back to top