Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 537 for msgs (0.02 seconds)

  1. 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)
  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()
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jul 12 16:23:16 GMT 2024
    - 6K bytes
    - Click Count (0)
  3. 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"
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 45.7K bytes
    - Click Count (0)
  4. 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)
  5. 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"`
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  6. 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()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.1K bytes
    - Click Count (0)
  7. 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)
  8. 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)
  9. 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)
  10. cmd/batch-replicate.go

    package cmd
    
    import (
    	"time"
    
    	miniogo "github.com/minio/minio-go/v7"
    	"github.com/minio/minio/internal/auth"
    	"github.com/minio/pkg/v3/xtime"
    )
    
    //go:generate msgp -file $GOFILE
    
    // replicate:
    //   # source of the objects to be replicated
    //   source:
    //     type: "minio"
    //     bucket: "testbucket"
    //     prefix: "spark/"
    //
    //   # optional flags based filtering criteria
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 01 12:53:30 GMT 2024
    - 6.3K bytes
    - Click Count (0)
Back to Top