Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for UnmarshalMsg (0.27 sec)

  1. cmd/data-usage-cache_gen_test.go

    func TestMarshalUnmarshalallTierStats(t *testing.T) {
    	v := allTierStats{}
    	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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 19K bytes
    - Viewed (0)
  2. cmd/data-usage-cache_gen.go

    		o = msgp.AppendInt(o, za0002.NumVersions)
    		// string "no"
    		o = append(o, 0xa2, 0x6e, 0x6f)
    		o = msgp.AppendInt(o, za0002.NumObjects)
    	}
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *allTierStats) 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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 75K bytes
    - Viewed (0)
  3. cmd/object-api-interface_gen.go

    	// string "NoMetadata"
    	o = append(o, 0xaa, 0x4e, 0x6f, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61)
    	o = msgp.AppendBool(o, z.NoMetadata)
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *BucketOptions) 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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  4. cmd/storage-datatypes_gen.go

    func (z BaseOptions) 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 *BaseOptions) 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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 150.2K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-v1_gen.go

    func (z BitrotAlgorithm) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	o = msgp.AppendUint(o, uint(z))
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *BitrotAlgorithm) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	{
    		var zb0001 uint
    		zb0001, bts, err = msgp.ReadUintBytes(bts)
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  6. cmd/xl-storage-format-v2_gen.go

    func (z ChecksumAlgo) 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 *ChecksumAlgo) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	{
    		var zb0001 uint8
    		zb0001, bts, err = msgp.ReadUint8Bytes(bts)
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  7. internal/grid/handlers.go

    	}
    	if h.newResp == nil {
    		return errors.New("newResp nil in NewSingleHandler")
    	}
    	return m.RegisterSingleHandler(h.id, func(payload []byte) ([]byte, *RemoteErr) {
    		req := h.NewRequest()
    		_, err := req.UnmarshalMsg(payload)
    		if err != nil {
    			PutByteBuffer(payload)
    			r := RemoteErr(err.Error())
    			return nil, &r
    		}
    		resp, rerr := handle(req)
    		h.recycleReq(req)
    
    		if rerr != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  8. docs/debugging/xl-meta/main.go

    	ModTime   int64
    	Signature [4]byte
    	Type      uint8
    	Flags     uint8
    	EcN, EcM  uint8 // Note that these will be 0/0 for non-v2 objects and older xl.meta
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *xlMetaV2VersionHeaderV2) UnmarshalMsg(bts []byte, hdrVer uint) (o []byte, err error) {
    	var zb0001 uint32
    	zb0001, bts, err = msgp.ReadArrayHeaderBytes(bts)
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 05 11:57:44 UTC 2024
    - 40.3K bytes
    - Viewed (0)
  9. cmd/bucket-metadata_gen.go

    	o = msgp.AppendTime(o, z.BucketTargetsConfigMetaUpdatedAt)
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *BucketMetadata) 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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 25.4K bytes
    - Viewed (0)
  10. cmd/bucket-metadata.go

    	}
    	switch binary.LittleEndian.Uint16(data[2:4]) {
    	case bucketMetadataVersion:
    	default:
    		return b, fmt.Errorf("loadBucketMetadata: unknown version: %d", binary.LittleEndian.Uint16(data[2:4]))
    	}
    	_, err = b.UnmarshalMsg(data[4:])
    	return b, err
    }
    
    func loadBucketMetadataParse(ctx context.Context, objectAPI ObjectLayer, bucket string, parse bool) (BucketMetadata, error) {
    	b, err := readBucketMetadata(ctx, objectAPI, bucket)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 18.2K bytes
    - Viewed (0)
Back to top