Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 346 for msgs (0.02 seconds)

  1. cmd/iam.go

    	}
    	var arns []string
    	for arn := range sys.rolesMap {
    		arns = append(arns, arn.String())
    	}
    	sort.Strings(arns)
    	msgs := make([]string, 0, len(arns))
    	for _, arn := range arns {
    		msgs = append(msgs, color.Bold(arn))
    	}
    
    	logger.Info(fmt.Sprintf("%s %s", color.Blue("IAM Roles:"), strings.Join(msgs, " ")))
    }
    
    // HasWatcher - returns if the IAM system has a watcher to be notified of
    // changes.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 76.5K bytes
    - Click Count (0)
  2. cmd/site-replication.go

    		keys = append(keys, d)
    	}
    	sort.Strings(keys)
    
    	var success int
    	msgs := []string{}
    	for _, d := range keys {
    		name := c.state.Peers[d].Name
    		err := errMap[d]
    		if err == nil {
    			msgs = append(msgs, fmt.Sprintf("'%s' on site %s (%s): succeeded", actionName, name, d))
    			success++
    		} else {
    			msgs = append(msgs, fmt.Sprintf("'%s' on site %s (%s): failed(%v)", actionName, name, d, err))
    		}
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 184.8K bytes
    - Click Count (1)
  3. internal/grid/types.go

    func (m *MSS) Msgsize() int {
    	if m == nil || *m == nil {
    		return msgp.NilSize
    	}
    	s := msgp.MapHeaderSize
    	for za0001, za0002 := range *m {
    		s += msgp.StringPrefixSize + len(za0001) + msgp.StringPrefixSize + len(za0002)
    	}
    	return s
    }
    
    // NewMSS returns a new MSS.
    func NewMSS() *MSS {
    	m := MSS(mssPool.Get())
    	clear(m)
    	return &m
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.5K bytes
    - Click Count (0)
  4. cmd/data-usage-cache.go

    type dataUsageEntry struct {
    	Children dataUsageHashMap `msg:"ch"`
    	// These fields do no include any children.
    	Size          int64             `msg:"sz"`
    	Objects       uint64            `msg:"os"`
    	Versions      uint64            `msg:"vs"` // Versions that are not delete markers.
    	DeleteMarkers uint64            `msg:"dms"`
    	ObjSizes      sizeHistogram     `msg:"szs"`
    	ObjVersions   versionsHistogram `msg:"vh"`
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  5. internal/grid/README.md

    ### Typed handlers
    
    Typed handlers are handlers that have a specific type for the request and response payloads.
    These must provide `msgp` serialization and deserialization.
    
    In the examples we use a `MSS` type, which is a `map[string]string` that is `msgp` serializable.
    
    ```go
        handler := func(request *grid.MSS) (*grid.MSS, *grid.RemoteErr) {
            fmt.Println("Got request with field", request["myfield"])
            // Do something with payload
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  6. cmd/xl-storage-format-v2_gen.go

    package cmd
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *ChecksumAlgo) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 uint8
    		zb0001, err = dc.ReadUint8()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = ChecksumAlgo(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 55.8K bytes
    - Click Count (0)
  7. cmd/storage-datatypes.go

    	DiskID   string   `msg:"id"`
    	Volume   string   `msg:"v"`
    	FilePath string   `msg:"fp"`
    	FI       FileInfo `msg:"fi"`
    }
    
    // DeleteFileHandlerParams are parameters for DeleteFileHandler
    type DeleteFileHandlerParams struct {
    	DiskID   string        `msg:"id"`
    	Volume   string        `msg:"v"`
    	FilePath string        `msg:"fp"`
    	Opts     DeleteOptions `msg:"do"`
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 17.4K bytes
    - Click Count (0)
  8. cmd/endpoint-ellipses.go

    	for _, totalSize := range totalSizes {
    		// Check if totalSize has minimum range upto setSize
    		if totalSize < setSizes[0] || totalSize < setDriveCount {
    			msg := fmt.Sprintf("Incorrect number of endpoints provided %s", args)
    			return nil, config.ErrInvalidNumberOfErasureEndpoints(nil).Msg(msg)
    		}
    	}
    
    	commonSize := getDivisibleSize(totalSizes)
    	possibleSetCounts := func(setSize uint64) (ss []uint64) {
    		for _, s := range setSizes {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  9. cmd/erasure-server-pool-rebalance.go

    	RebalancedBuckets []string      `json:"rebalancedBuckets" msg:"rbs"` // buckets rebalanced
    	Bucket            string        `json:"bucket" msg:"bu"`             // Last rebalanced bucket
    	Object            string        `json:"object" msg:"ob"`             // Last rebalanced object
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 28.7K bytes
    - Click Count (0)
  10. cmd/bucket-replication-utils.go

    	// Total number of failed operations
    	FailedCount int64 `json:"failedReplicationCount"  msg:"frc"`
    	// Completed size in bytes
    	ReplicatedSize int64 `json:"completedReplicationSize"  msg:"rs"`
    	// Total number of failed operations
    	ReplicatedCount int64 `json:"replicationCount"  msg:"rrc"`
    	// Last bucket/object replicated.
    	Bucket string `json:"-" msg:"bkt"`
    	Object string `json:"-" msg:"obj"`
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
Back to Top