Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 28 for EncodeMsg (0.32 sec)

  1. cmd/storage-rest-common_gen.go

    			}
    		}
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z *nsScannerResp) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 2
    	// write "u"
    	err = en.Append(0x82, 0xa1, 0x75)
    	if err != nil {
    		return
    	}
    	if z.Update == nil {
    		err = en.WriteNil()
    		if err != nil {
    			return
    		}
    	} else {
    		err = z.Update.EncodeMsg(en)
    		if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  2. internal/bucket/replication/datatypes_gen.go

    	{
    		var zb0001 string
    		zb0001, err = dc.ReadString()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = StatusType(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z StatusType) EncodeMsg(en *msgp.Writer) (err error) {
    	err = en.WriteString(string(z))
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 3.4K bytes
    - Viewed (0)
  3. cmd/tier-last-day-stats_gen.go

    			default:
    				err = dc.Skip()
    				if err != nil {
    					err = msgp.WrapError(err, zb0001)
    					return
    				}
    			}
    		}
    		(*z)[zb0001] = zb0002
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z DailyAllTierStats) EncodeMsg(en *msgp.Writer) (err error) {
    	err = en.WriteMapHeader(uint32(len(z)))
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0007, zb0008 := range z {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  4. cmd/tier_gen.go

    				}
    				z.Tiers[za0001] = za0002
    			}
    		default:
    			err = dc.Skip()
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z *TierConfigMgr) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 1
    	// write "Tiers"
    	err = en.Append(0x81, 0xa5, 0x54, 0x69, 0x65, 0x72, 0x73)
    	if err != nil {
    		return
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 3.9K bytes
    - Viewed (0)
  5. internal/grid/grid_types_msgp_test.go

    				return
    			}
    		default:
    			err = dc.Skip()
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z testRequest) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 2
    	// write "Num"
    	err = en.Append(0x82, 0xa3, 0x4e, 0x75, 0x6d)
    	if err != nil {
    		return
    	}
    	err = en.WriteInt(z.Num)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  6. cmd/site-replication-utils_gen.go

    				return
    			}
    		default:
    			err = dc.Skip()
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z *SiteResyncStatus) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 6
    	// write "v"
    	err = en.Append(0x86, 0xa1, 0x76)
    	if err != nil {
    		return
    	}
    	err = en.WriteInt(z.Version)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  7. internal/bucket/bandwidth/monitor_gen.go

    		}
    		switch msgp.UnsafeString(field) {
    		default:
    			err = dc.Skip()
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z BucketBandwidthReport) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 0
    	_ = z
    	err = en.Append(0x80)
    	if err != nil {
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  8. cmd/batch-handlers_gen_test.go

    	v := BatchJobPrefix{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	en := msgp.NewWriter(msgp.Nowhere)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.EncodeMsg(en)
    	}
    	en.Flush()
    }
    
    func BenchmarkDecodeBatchJobPrefix(b *testing.B) {
    	v := BatchJobPrefix{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 6.7K bytes
    - Viewed (0)
  9. cmd/local-locker_gen_test.go

    	v := localLockMap{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	en := msgp.NewWriter(msgp.Nowhere)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.EncodeMsg(en)
    	}
    	en.Flush()
    }
    
    func BenchmarkDecodelocalLockMap(b *testing.B) {
    	v := localLockMap{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 6.7K bytes
    - Viewed (0)
  10. internal/dsync/lock-args_gen_test.go

    	v := LockArgs{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	en := msgp.NewWriter(msgp.Nowhere)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.EncodeMsg(en)
    	}
    	en.Flush()
    }
    
    func BenchmarkDecodeLockArgs(b *testing.B) {
    	v := LockArgs{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 4.4K bytes
    - Viewed (0)
Back to top