Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for volInfos (0.04 sec)

  1. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  2. 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.JSON[madmin.HealResultItem]](grid.HandlerHealBucket, grid.NewMSS, madminHealResultItem.NewJSON)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 53.4K bytes
    - Viewed (0)
  3. cmd/storage-rest-server.go

    	storageStatVolRPC          = grid.NewSingleHandler[*grid.MSS, *VolInfo](grid.HandlerStatVol, grid.NewMSS, func() *VolInfo { return &VolInfo{} })
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
  4. cmd/storage-datatypes_test.go

    package cmd
    
    import (
    	"bytes"
    	"encoding/gob"
    	"io"
    	"testing"
    	"time"
    
    	"github.com/tinylib/msgp/msgp"
    )
    
    func BenchmarkDecodeVolInfoMsgp(b *testing.B) {
    	v := VolInfo{
    		Name:    "uuid",
    		Created: time.Now(),
    	}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.Log("Size:", buf.Len(), "bytes")
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.1K bytes
    - Viewed (0)
  5. cmd/storage-datatypes_gen.go

    // MarshalMsg implements msgp.Marshaler
    func (z VolInfo) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// array header, size 3
    	o = append(o, 0x93)
    	o = msgp.AppendString(o, z.Name)
    	o = msgp.AppendTime(o, z.Created)
    	o = msgp.AppendTime(o, z.Deleted)
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *VolInfo) UnmarshalMsg(bts []byte) (o []byte, err error) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 152K bytes
    - Viewed (0)
  6. 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 *xsync.MapOf[string, VolInfo], readQuorum int) error {
    	g := errgroup.WithNErrs(len(storageDisks))
    	for index := range storageDisks {
    		g.Go(func() error {
    			if storageDisks[index] == nil {
    				// we ignore disk not found errors
    				return nil
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
Back to top