Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 71 for DecodeMsg (0.05 seconds)

  1. cmd/bucket-stats_gen.go

    			}
    		case "ActiveWorkers":
    			err = z.ActiveWorkers.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "ActiveWorkers")
    				return
    			}
    		case "QStats":
    			err = z.QStats.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "QStats")
    				return
    			}
    		case "MRFStats":
    			err = z.MRFStats.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "MRFStats")
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 57.3K bytes
    - Click Count (0)
  2. cmd/batch-expire_gen.go

    				return
    			}
    		case "Prefix":
    			err = z.Prefix.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "Prefix")
    				return
    			}
    		case "NotificationCfg":
    			err = z.NotificationCfg.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "NotificationCfg")
    				return
    			}
    		case "Retry":
    			err = z.Retry.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "Retry")
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 19.9K bytes
    - Click Count (0)
  3. cmd/storage-datatypes_gen_test.go

    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    func TestMarshalUnmarshalCheckPartsHandlerParams(t *testing.T) {
    	v := CheckPartsHandlerParams{}
    	bts, err := v.MarshalMsg(nil)
    	if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 73.9K bytes
    - Click Count (0)
  4. cmd/batch-handlers_gen.go

    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    package cmd
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *BatchJobPrefix) DecodeMsg(dc *msgp.Reader) (err error) {
    	var zb0002 uint32
    	zb0002, err = dc.ReadArrayHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	if cap((*z)) >= int(zb0002) {
    		(*z) = (*z)[:zb0002]
    	} else {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 20.4K bytes
    - Click Count (0)
  5. cmd/tier_gen.go

    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    package cmd
    
    import (
    	"github.com/minio/madmin-go/v3"
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *TierConfigMgr) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 3.9K bytes
    - Click Count (0)
  6. internal/grid/msg_gen.go

    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    package grid
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *Flags) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 uint8
    		zb0001, err = dc.ReadUint8()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = Flags(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  7. cmd/batch-replicate_gen.go

    		}
    		switch msgp.UnsafeString(field) {
    		case "Filter":
    			err = z.Filter.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "Filter")
    				return
    			}
    		case "Notify":
    			err = z.Notify.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "Notify")
    				return
    			}
    		case "Retry":
    			err = z.Retry.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "Retry")
    				return
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 40.7K bytes
    - Click Count (0)
  8. cmd/erasure-server-pool-rebalance_gen.go

    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    package cmd
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *rebalSaveOpts) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 uint8
    		zb0001, err = dc.ReadUint8()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = rebalSaveOpts(zb0001)
    	}
    	return
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.8K bytes
    - Click Count (0)
  9. cmd/bucket-stats_gen_test.go

    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    func TestMarshalUnmarshalBucketReplicationStats(t *testing.T) {
    	v := BucketReplicationStats{}
    	bts, err := v.MarshalMsg(nil)
    	if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 20.5K bytes
    - Click Count (0)
  10. cmd/site-replication-metrics_gen.go

    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    package cmd
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *RStat) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 40.3K bytes
    - Click Count (0)
Back to Top