- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 655 for msgs (0.02 sec)
-
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) -
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) -
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 payloadRegistered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Oct 10 18:57:03 UTC 2025 - 9.4K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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)