Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for listDirs (0.21 sec)

  1. cmd/xl-storage-disk-id-check.go

    }
    
    func (p *xlStorageDiskIDCheck) ListDir(ctx context.Context, origvolume, volume, dirPath string, count int) (s []string, err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricListDir, volume, dirPath)
    	if err != nil {
    		return nil, err
    	}
    	defer done(&err)
    
    	return p.storage.ListDir(ctx, origvolume, volume, dirPath, count)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  2. cmd/erasure-object_test.go

    	_, err = obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader(buf), int64(len(buf)), "", ""), opts)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	for _, disk := range xl.getDisks() {
    		files, _ := disk.ListDir(ctx, "", bucket, object, -1)
    		for _, file := range files {
    			if file != "xl.meta" {
    				disk.Delete(ctx, bucket, pathJoin(object, file), DeleteOptions{
    					Recursive: true,
    					Immediate: false,
    				})
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 36.8K bytes
    - Viewed (0)
  3. cmd/tier.go

    	if config == nil {
    		return true
    	}
    	return len(config.ListTiers()) == 0
    }
    
    // TierType returns the type of tier
    func (config *TierConfigMgr) TierType(name string) string {
    	config.RLock()
    	defer config.RUnlock()
    
    	cfg, ok := config.Tiers[name]
    	if !ok {
    		return "internal"
    	}
    	return cfg.Type.String()
    }
    
    // ListTiers lists remote tiers configured in this deployment.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  4. cmd/storage-rest-client.go

    	if err != nil {
    		return 0, err
    	}
    	defer xhttp.DrainBody(respBody)
    	n, err := io.ReadFull(respBody, buf)
    	return int64(n), toStorageErr(err)
    }
    
    // ListDir - lists a directory.
    func (client *storageRESTClient) ListDir(ctx context.Context, origvolume, volume, dirPath string, count int) (entries []string, err error) {
    	values := grid.NewMSS()
    	values.Set(storageRESTVolume, volume)
    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)
  5. cmd/storage-datatypes.go

    }
    
    // LocalDiskIDs - GetLocalIDs response.
    type LocalDiskIDs struct {
    	IDs []string
    }
    
    // ListDirResult - ListDir()'s response.
    type ListDirResult struct {
    	Entries []string `msg:"e"`
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 15.3K bytes
    - Viewed (0)
  6. cmd/storage-rest-server.go

    	origvolume := params.Get(storageRESTOrigVolume)
    	count, err := strconv.Atoi(params.Get(storageRESTCount))
    	if err != nil {
    		return grid.NewRemoteErr(err)
    	}
    
    	entries, err := s.getStorage().ListDir(ctx, origvolume, volume, dirPath, count)
    	if err != nil {
    		return grid.NewRemoteErr(err)
    	}
    	out <- &ListDirResult{Entries: entries}
    	return nil
    }
    
    // DeleteFileHandler - delete a file.
    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)
  7. cmd/metacache-walk.go

    		if contextCanceled(ctx) {
    			return ctx.Err()
    		}
    		if opts.Limit > 0 && objsReturned >= opts.Limit {
    			return nil
    		}
    
    		if s.walkMu != nil {
    			s.walkMu.Lock()
    		}
    		entries, err := s.ListDir(ctx, "", opts.Bucket, current, -1)
    		if s.walkMu != nil {
    			s.walkMu.Unlock()
    		}
    		if err != nil {
    			// Folder could have gone away in-between
    			if err != errVolumeNotFound && err != errFileNotFound {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  8. cmd/ftp-server-driver.go

    	}
    
    	isDir := strings.HasSuffix(objInfo.Key, SlashSeparator)
    	return &minioFileInfo{
    		p:     pathClean(object),
    		info:  objInfo,
    		isDir: isDir,
    	}, nil
    }
    
    // ListDir implements ftpDriver
    func (driver *ftpDriver) ListDir(ctx *ftp.Context, objPath string, callback func(os.FileInfo) error) (err error) {
    	stopFn := globalFtpMetrics.log(ctx, objPath)
    	defer stopFn(err)
    
    	clnt, err := driver.getMinIOClient(ctx)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 12:23:42 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  9. cmd/erasure-multipart.go

    		disks = er.getOnlineDisks()
    	}
    	for _, disk = range disks {
    		if disk == nil {
    			continue
    		}
    		if !disk.IsOnline() {
    			continue
    		}
    		uploadIDs, err = disk.ListDir(ctx, bucket, minioMetaMultipartBucket, er.getMultipartSHADir(bucket, object), -1)
    		if err != nil {
    			if errors.Is(err, errDiskNotFound) {
    				continue
    			}
    			if errors.Is(err, errFileNotFound) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  10. cmd/storage-rest_test.go

    		expectErr      bool
    	}{
    		{"foo", "path", []string{"to/"}, false},
    		// prefix not found error.
    		{"foo", "nodir", nil, true},
    	}
    
    	for i, testCase := range testCases {
    		result, err := storage.ListDir(context.Background(), "", testCase.volumeName, testCase.prefix, -1)
    		expectErr := (err != nil)
    
    		if expectErr != testCase.expectErr {
    			t.Fatalf("case %v: error: expected: %v, got: %v", i+1, testCase.expectErr, expectErr)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 11.4K bytes
    - Viewed (0)
Back to top