Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 91 for UnmarshalMsg (0.14 seconds)

  1. cmd/local-locker_gen.go

    			o, err = zb0007[zb0008].MarshalMsg(o)
    			if err != nil {
    				err = msgp.WrapError(err, zb0006, zb0008)
    				return
    			}
    		}
    	}
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *localLockMap) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var zb0004 uint32
    	zb0004, bts, err = msgp.ReadMapHeaderBytes(bts)
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.6K bytes
    - Click Count (0)
  2. cmd/batch-replicate_gen.go

    		case "Filter":
    			bts, err = z.Filter.UnmarshalMsg(bts)
    			if err != nil {
    				err = msgp.WrapError(err, "Filter")
    				return
    			}
    		case "Notify":
    			bts, err = z.Notify.UnmarshalMsg(bts)
    			if err != nil {
    				err = msgp.WrapError(err, "Notify")
    				return
    			}
    		case "Retry":
    			bts, err = z.Retry.UnmarshalMsg(bts)
    			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
    - 40.7K bytes
    - Click Count (0)
  3. cmd/erasure-server-pool-rebalance_gen.go

    func (z rebalSaveOpts) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	o = msgp.AppendUint8(o, uint8(z))
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *rebalSaveOpts) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	{
    		var zb0001 uint8
    		zb0001, bts, err = msgp.ReadUint8Bytes(bts)
    		if err != nil {
    			err = msgp.WrapError(err)
    			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)
  4. cmd/site-replication-metrics_gen.go

    	o = msgp.AppendInt64(o, z.Count)
    	// string "Bytes"
    	o = append(o, 0xa5, 0x42, 0x79, 0x74, 0x65, 0x73)
    	o = msgp.AppendInt64(o, z.Bytes)
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *RStat) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, bts, err = msgp.ReadMapHeaderBytes(bts)
    	if err != nil {
    		err = msgp.WrapError(err)
    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)
  5. cmd/batch-handlers_gen.go

    	o = msgp.Require(b, z.Msgsize())
    	o = msgp.AppendArrayHeader(o, uint32(len(z)))
    	for zb0003 := range z {
    		o = msgp.AppendString(o, z[zb0003])
    	}
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *BatchJobPrefix) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var zb0002 uint32
    	zb0002, bts, err = msgp.ReadArrayHeaderBytes(bts)
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    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)
  6. cmd/tier_gen_test.go

    func TestMarshalUnmarshalTierConfigMgr(t *testing.T) {
    	v := TierConfigMgr{}
    	bts, err := v.MarshalMsg(nil)
    	if err != nil {
    		t.Fatal(err)
    	}
    	left, err := v.UnmarshalMsg(bts)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left)
    	}
    
    	left, err = msgp.Skip(bts)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 2.3K bytes
    - Click Count (0)
  7. cmd/site-replication-utils_gen.go

    	o, err = z.TargetReplicationResyncStatus.MarshalMsg(o)
    	if err != nil {
    		err = msgp.WrapError(err, "TargetReplicationResyncStatus")
    		return
    	}
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *SiteResyncStatus) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, bts, err = msgp.ReadMapHeaderBytes(bts)
    	if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  8. cmd/bootstrap-peer-server_gen_test.go

    	v := ServerSystemConfig{}
    	bts, err := v.MarshalMsg(nil)
    	if err != nil {
    		t.Fatal(err)
    	}
    	left, err := v.UnmarshalMsg(bts)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left)
    	}
    
    	left, err = msgp.Skip(bts)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  9. cmd/bucket-metadata_gen_test.go

    	v := BucketMetadata{}
    	bts, err := v.MarshalMsg(nil)
    	if err != nil {
    		t.Fatal(err)
    	}
    	left, err := v.UnmarshalMsg(bts)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left)
    	}
    
    	left, err = msgp.Skip(bts)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 2.3K bytes
    - Click Count (0)
  10. internal/bucket/bandwidth/monitor_gen.go

    func (z BucketBandwidthReport) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 0
    	_ = z
    	o = append(o, 0x80)
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *BucketBandwidthReport) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, bts, err = msgp.ReadMapHeaderBytes(bts)
    	if err != nil {
    		err = msgp.WrapError(err)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.4K bytes
    - Click Count (0)
Back to Top