Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for volInfos (0.13 sec)

  1. cmd/xl-storage_test.go

    	if err != nil {
    		t.Fatalf("Unable to create xlStorage test setup, %s", err)
    	}
    
    	var volInfos []VolInfo
    	// TestXLStorage empty list vols.
    	if volInfos, err = xlStorage.ListVols(context.Background()); err != nil {
    		t.Fatalf("expected: <nil>, got: %s", err)
    	} else if len(volInfos) != 1 {
    		t.Fatalf("expected: one entry, got: %s", volInfos)
    	}
    
    	// TestXLStorage non-empty list vols.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Apr 11 17:45:28 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  2. cmd/peer-s3-server.go

    	buckets = make([]BucketInfo, 0, 32)
    	healBuckets := map[string]VolInfo{}
    
    	// lists all unique buckets across drives.
    	if err := listAllBuckets(ctx, localDrives, healBuckets, quorum); err != nil {
    		return nil, err
    	}
    
    	// include deleted buckets in listBuckets output
    	deletedBuckets := map[string]VolInfo{}
    
    	if opts.Deleted {
    		// lists all deleted buckets across drives.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  3. cmd/naughty-disk_test.go

    }
    
    func (d *naughtyDisk) ListVols(ctx context.Context) (vols []VolInfo, err error) {
    	if err := d.calcError(); err != nil {
    		return nil, err
    	}
    	return d.disk.ListVols(ctx)
    }
    
    func (d *naughtyDisk) StatVol(ctx context.Context, volume string) (vol VolInfo, err error) {
    	if err := d.calcError(); err != nil {
    		return VolInfo{}, err
    	}
    	return d.disk.StatVol(ctx, volume)
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  4. cmd/storage-interface.go

    	// Volume operations.
    	MakeVol(ctx context.Context, volume string) (err error)
    	MakeVolBulk(ctx context.Context, volumes ...string) (err error)
    	ListVols(ctx context.Context) (vols []VolInfo, err error)
    	StatVol(ctx context.Context, volume string) (vol VolInfo, err error)
    	DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error)
    
    	// WalkDir will walk a directory on disk and return a metacache stream on wr.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 5K bytes
    - Viewed (0)
  5. cmd/storage-datatypes.go

    }
    
    // VolsInfo is a collection of volume(bucket) information
    type VolsInfo []VolInfo
    
    // VolInfo - represents volume stat information.
    // The above means that any added/deleted fields are incompatible.
    //
    // The above means that any added/deleted fields are incompatible.
    //
    //msgp:tuple VolInfo
    type VolInfo struct {
    	// Name of the volume.
    	Name string
    
    	// Date and time when the volume was created.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  6. cmd/erasure-healing.go

    				return err
    			}
    			for _, volInfo := range volsInfo {
    				// StorageAPI can send volume names which are
    				// incompatible with buckets - these are
    				// skipped, like the meta-bucket.
    				if isReservedOrInvalidBucket(volInfo.Name, false) {
    					continue
    				}
    				mu.Lock()
    				if _, ok := healBuckets[volInfo.Name]; !ok {
    					healBuckets[volInfo.Name] = volInfo
    				}
    				mu.Unlock()
    			}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 33.8K bytes
    - Viewed (0)
  7. cmd/peer-s3-client.go

    	})
    
    	ctx, cancel := context.WithTimeout(ctx, globalDriveConfig.GetMaxTimeout())
    	defer cancel()
    
    	volInfo, err := headBucketRPC.Call(ctx, conn, mss)
    	if err != nil {
    		return BucketInfo{}, toStorageErr(err)
    	}
    
    	return BucketInfo{
    		Name:    volInfo.Name,
    		Created: volInfo.Created,
    	}, nil
    }
    
    // MakeBucket creates bucket across all peers
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  8. cmd/storage-datatypes_gen_test.go

    	}
    }
    
    func BenchmarkMarshalMsgVolInfo(b *testing.B) {
    	v := VolInfo{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgVolInfo(b *testing.B) {
    	v := VolInfo{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    	b.SetBytes(int64(len(bts)))
    	b.ReportAllocs()
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 62.6K bytes
    - Viewed (0)
  9. cmd/xl-storage.go

    		case isSysErrIO(err):
    			return VolInfo{}, errFaultyDisk
    		default:
    			return VolInfo{}, err
    		}
    	}
    	// As os.Lstat() doesn't carry other than ModTime(), use ModTime()
    	// as CreatedTime.
    	createdTime := st.ModTime()
    	return VolInfo{
    		Name:    volume,
    		Created: createdTime,
    	}, nil
    }
    
    // DeleteVol - delete a volume.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (2)
  10. cmd/xl-storage-disk-id-check.go

    }
    
    func (p *xlStorageDiskIDCheck) ListVols(ctx context.Context) (vi []VolInfo, err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricListVols, "/")
    	if err != nil {
    		return nil, err
    	}
    	defer done(0, &err)
    
    	return p.storage.ListVols(ctx)
    }
    
    func (p *xlStorageDiskIDCheck) StatVol(ctx context.Context, volume string) (vol VolInfo, err error) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 33.4K bytes
    - Viewed (0)
Back to top