Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 91 for MarshalMsg (0.08 sec)

  1. cmd/bucket-replication-utils_gen.go

    	if err != nil {
    		return
    	}
    	err = en.WriteTime(z.LastUpdate)
    	if err != nil {
    		err = msgp.WrapError(err, "LastUpdate")
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z *BucketReplicationResyncStatus) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 4
    	// string "v"
    	o = append(o, 0x84, 0xa1, 0x76)
    	o = msgp.AppendInt(o, z.Version)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 61.1K bytes
    - Viewed (0)
  2. cmd/xl-storage-format-v1_gen.go

    func (z BitrotAlgorithm) EncodeMsg(en *msgp.Writer) (err error) {
    	err = en.WriteUint(uint(z))
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  3. cmd/xl-storage-format-v2_gen.go

    func (z ChecksumAlgo) EncodeMsg(en *msgp.Writer) (err error) {
    	err = en.WriteUint8(uint8(z))
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  4. cmd/bootstrap-peer-server_gen.go

    	if err != nil {
    		return
    	}
    	err = en.WriteString(z.Checksum)
    	if err != nil {
    		err = msgp.WrapError(err, "Checksum")
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z *ServerSystemConfig) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 4
    	// string "NEndpoints"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 14:49:49 UTC 2024
    - 7K bytes
    - Viewed (0)
  5. cmd/metacache_gen.go

    	if err != nil {
    		return
    	}
    	err = en.WriteUint8(z.dataVersion)
    	if err != nil {
    		err = msgp.WrapError(err, "dataVersion")
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z *metacache) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 13
    	// string "end"
    	o = append(o, 0x8d, 0xa3, 0x65, 0x6e, 0x64)
    	o = msgp.AppendTime(o, z.ended)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Nov 08 18:26:08 UTC 2021
    - 10K bytes
    - Viewed (0)
  6. cmd/mrf_gen.go

    	if err != nil {
    		return
    	}
    	err = en.WriteBool(z.BitrotScan)
    	if err != nil {
    		err = msgp.WrapError(err, "BitrotScan")
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z *PartialOperation) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 8
    	// string "Bucket"
    	o = append(o, 0x88, 0xa6, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  7. cmd/metacache-walk_gen.go

    	if err != nil {
    		return
    	}
    	err = en.WriteString(z.DiskID)
    	if err != nil {
    		err = msgp.WrapError(err, "DiskID")
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z *WalkDirOptions) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 8
    	// string "Bucket"
    	o = append(o, 0x88, 0xa6, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 7K bytes
    - Viewed (0)
  8. internal/grid/connection.go

    			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())
    	dst, err := msg.MarshalMsg(dst)
    	if err != nil {
    		return err
    	}
    	if msg.Flags&FlagCRCxxh3 != 0 {
    		h := xxh3.Hash(dst)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  9. internal/grid/handlers.go

    			r := RemoteErr(err.Error())
    			return nil, &r
    		}
    		resp, rerr := handle(req)
    		h.recycleReq(req)
    
    		if rerr != nil {
    			PutByteBuffer(payload)
    			return nil, rerr
    		}
    		payload, err = resp.MarshalMsg(payload[:0])
    		if !h.sharedResp {
    			h.PutResponse(resp)
    		}
    		if err != nil {
    			PutByteBuffer(payload)
    			r := RemoteErr(err.Error())
    			return nil, &r
    		}
    		return payload, 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)
  10. internal/dsync/dsync-client_test.go

    	}
    	return err
    }
    
    // Call makes a REST call to the remote endpoint using the msgp codec
    func (restClient *ReconnectRESTClient) Call(method string, args LockArgs) (status bool, err error) {
    	buf, err := args.MarshalMsg(nil)
    	if err != nil {
    		return false, err
    	}
    	body := bytes.NewReader(buf)
    	respBody, err := restClient.rest.Call(context.Background(), method,
    		url.Values{}, body, body.Size())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 20 17:36:09 UTC 2022
    - 4.4K bytes
    - Viewed (0)
Back to top