Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 69 for EncodeMsg (0.19 sec)

  1. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 8.1K bytes
    - Viewed (0)
  2. cmd/site-replication-metrics_gen.go

    				return
    			}
    		}
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z *RTimedMetrics) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 4
    	// write "LastHour"
    	err = en.Append(0x84, 0xa8, 0x4c, 0x61, 0x73, 0x74, 0x48, 0x6f, 0x75, 0x72)
    	if err != nil {
    		return
    	}
    	err = z.LastHour.EncodeMsg(en)
    	if err != nil {
    		err = msgp.WrapError(err, "LastHour")
    		return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 40.6K bytes
    - Viewed (0)
  3. cmd/site-replication-metrics_gen_test.go

    	v := RStat{}
    	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 BenchmarkDecodeRStat(b *testing.B) {
    	v := RStat{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 30 08:00:59 UTC 2023
    - 12.9K bytes
    - Viewed (0)
  4. internal/grid/msg_gen_test.go

    	v := connectReq{}
    	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 BenchmarkDecodeconnectReq(b *testing.B) {
    	v := connectReq{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jul 25 21:07:21 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  5. cmd/storage-datatypes_gen.go

    				return
    			}
    		}
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z *RenameDataInlineHandlerParams) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 1
    	// write "p"
    	err = en.Append(0x81, 0xa1, 0x70)
    	if err != nil {
    		return
    	}
    	err = z.RenameDataHandlerParams.EncodeMsg(en)
    	if err != nil {
    		err = msgp.WrapError(err, "RenameDataHandlerParams")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 150.2K bytes
    - Viewed (0)
  6. cmd/last-minute_gen.go

    				return
    			}
    		default:
    			err = dc.Skip()
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z AccElem) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 3
    	// write "Total"
    	err = en.Append(0x83, 0xa5, 0x54, 0x6f, 0x74, 0x61, 0x6c)
    	if err != nil {
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 05 21:45:49 UTC 2022
    - 17.2K bytes
    - Viewed (0)
  7. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  8. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  9. cmd/data-usage-cache_gen.go

    				return
    			}
    		}
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z *dataUsageCache) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 2
    	// write "Info"
    	err = en.Append(0x82, 0xa4, 0x49, 0x6e, 0x66, 0x6f)
    	if err != nil {
    		return
    	}
    	err = z.Info.EncodeMsg(en)
    	if err != nil {
    		err = msgp.WrapError(err, "Info")
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 75K bytes
    - Viewed (0)
  10. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Nov 14 15:16:40 UTC 2022
    - 7.2K bytes
    - Viewed (0)
Back to top