Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for volInfos (0.06 sec)

  1. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  2. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  4. cmd/storage-rest-client.go

    }
    
    // ListVols - List all volumes on a remote disk.
    func (client *storageRESTClient) ListVols(ctx context.Context) (vols []VolInfo, err error) {
    	return nil, errInvalidArgument
    }
    
    // StatVol - get volume info over the network.
    func (client *storageRESTClient) StatVol(ctx context.Context, volume string) (vol VolInfo, err error) {
    	v, err := storageStatVolRPC.Call(ctx, client.gridConn, grid.NewMSSWith(map[string]string{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  6. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  7. cmd/peer-rest-server.go

    	headBucketRPC                  = grid.NewSingleHandler[*grid.MSS, *VolInfo](grid.HandlerHeadBucket, grid.NewMSS, func() *VolInfo { return &VolInfo{} })
    	healBucketRPC                  = grid.NewSingleHandler[*grid.MSS, grid.NoPayload](grid.HandlerHealBucket, grid.NewMSS, grid.NewNoPayload)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  8. cmd/storage-datatypes_gen.go

    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z VolInfo) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// array header, size 2
    	o = append(o, 0x92)
    	o = msgp.AppendString(o, z.Name)
    	o = msgp.AppendTime(o, z.Created)
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *VolInfo) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var zb0001 uint32
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 150.2K bytes
    - Viewed (0)
  9. cmd/erasure-sets.go

    	return s.sets[s.getHashedSetIndex(input)]
    }
    
    // listDeletedBuckets lists deleted buckets from all disks.
    func listDeletedBuckets(ctx context.Context, storageDisks []StorageAPI, delBuckets map[string]VolInfo, readQuorum int) error {
    	g := errgroup.WithNErrs(len(storageDisks))
    	var mu sync.Mutex
    	for index := range storageDisks {
    		index := index
    		g.Go(func() error {
    			if storageDisks[index] == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
Back to top