Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 655 for msgs (0.28 sec)

  1. cmd/bucket-replication-metrics.go

    	PutTagTotal       uint64 `json:"putTaggingProxyTotal" msg:"ptc"`
    	GetTagTotal       uint64 `json:"getTaggingProxyTotal" msg:"gtc"`
    	RmvTagTotal       uint64 `json:"removeTaggingProxyTotal" msg:"rtc"`
    	GetTotal          uint64 `json:"getProxyTotal" msg:"gc"`
    	HeadTotal         uint64 `json:"headProxyTotal" msg:"hc"`
    	PutTagFailedTotal uint64 `json:"putTaggingProxyFailed" msg:"ptf"`
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  2. cmd/metacache.go

    	bucket       string     `msg:"b"`
    	filter       string     `msg:"flt"`
    	id           string     `msg:"id"`
    	error        string     `msg:"err"`
    	root         string     `msg:"root"`
    	fileNotFound bool       `msg:"fnf"`
    	status       scanStatus `msg:"stat"`
    	recursive    bool       `msg:"rec"`
    	dataVersion  uint8      `msg:"v"`
    }
    
    func (m *metacache) finished() bool {
    	return !m.ended.IsZero()
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. 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
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 10 18:57:03 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  4. internal/grid/connection.go

    	msg.Flags.Clear(FlagSubroute)
    	if payload != nil {
    		if sz := payload.Msgsize(); cap(msg.Payload) < sz {
    			PutByteBuffer(msg.Payload)
    			msg.Payload = GetByteBufferCap(sz)
    		}
    		var err error
    		msg.Payload, err = payload.MarshalMsg(msg.Payload[:0])
    		msg.Op = payload.Op()
    		if err != nil {
    			return err
    		}
    	}
    	defer PutByteBuffer(msg.Payload)
    	dst := GetByteBufferCap(msg.Msgsize())
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 46.9K bytes
    - Viewed (0)
  5. cmd/storage-rest-server.go

    	"io"
    	"net/http"
    	"os/user"
    	"path"
    	"runtime/debug"
    	"strconv"
    	"strings"
    	"sync"
    	"time"
    
    	"github.com/minio/minio/internal/bpool"
    	"github.com/minio/minio/internal/grid"
    	"github.com/tinylib/msgp/msgp"
    
    	jwtreq "github.com/golang-jwt/jwt/v4/request"
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/config"
    	xhttp "github.com/minio/minio/internal/http"
    	xioutil "github.com/minio/minio/internal/ioutil"
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (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
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 55.8K bytes
    - Viewed (0)
  7. internal/grid/grid_test.go

    	// 1: Echo
    	h1 := NewSingleHandler[*MSS, *MSS](handlerTest, NewMSS, NewMSS)
    	// Handles incoming requests, returns a response
    	handler1 := func(req *MSS) (resp *MSS, err *RemoteErr) {
    		resp = h1.NewResponse()
    		maps.Copy((*resp), *req)
    		return resp, nil
    	}
    	// Return error
    	h2 := NewSingleHandler[*MSS, *MSS](handlerTest2, NewMSS, NewMSS)
    	handler2 := func(req *MSS) (resp *MSS, err *RemoteErr) {
    		defer req.Recycle()
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 36.1K bytes
    - Viewed (0)
  8. cmd/site-replication-utils.go

    	"github.com/minio/madmin-go/v3"
    )
    
    //go:generate msgp -file=$GOFILE
    
    // SiteResyncStatus captures current replication resync status for a target site
    type SiteResyncStatus struct {
    	Version int `json:"version" msg:"v"`
    	// Overall site status
    	Status                        ResyncStatusType            `json:"st" msg:"ss"`
    	DeplID                        string                      `json:"dId" msg:"did"`
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  9. 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"`
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  10. 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 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 14.7K bytes
    - Viewed (0)
Back to top