3756 lines · 84.8 KB · Go
RawDownload
package cmd // Code generated by github.com/tinylib/msgp DO NOT EDIT. import (	"time" 	"github.com/tinylib/msgp/msgp") // DecodeMsg implements msgp.Decodablefunc (z *allTierStats) DecodeMsg(dc *msgp.Reader) (err error) {	var field []byte	_ = field	var zb0001 uint32	zb0001, err = dc.ReadMapHeader()	if err != nil {		err = msgp.WrapError(err)		return	}	for zb0001 > 0 {		zb0001--		field, err = dc.ReadMapKeyPtr()		if err != nil {			err = msgp.WrapError(err)			return		}		switch msgp.UnsafeString(field) {		case "ts":			var zb0002 uint32			zb0002, err = dc.ReadMapHeader()			if err != nil {				err = msgp.WrapError(err, "Tiers")				return			}			if z.Tiers == nil {				z.Tiers = make(map[string]tierStats, zb0002)			} else if len(z.Tiers) > 0 {				for key := range z.Tiers {					delete(z.Tiers, key)				}			}			for zb0002 > 0 {				zb0002--				var za0001 string				var za0002 tierStats				za0001, err = dc.ReadString()				if err != nil {					err = msgp.WrapError(err, "Tiers")					return				}				var zb0003 uint32				zb0003, err = dc.ReadMapHeader()				if err != nil {					err = msgp.WrapError(err, "Tiers", za0001)					return				}				for zb0003 > 0 {					zb0003--					field, err = dc.ReadMapKeyPtr()					if err != nil {						err = msgp.WrapError(err, "Tiers", za0001)						return					}					switch msgp.UnsafeString(field) {					case "ts":						za0002.TotalSize, err = dc.ReadUint64()						if err != nil {							err = msgp.WrapError(err, "Tiers", za0001, "TotalSize")							return						}					case "nv":						za0002.NumVersions, err = dc.ReadInt()						if err != nil {							err = msgp.WrapError(err, "Tiers", za0001, "NumVersions")							return						}					case "no":						za0002.NumObjects, err = dc.ReadInt()						if err != nil {							err = msgp.WrapError(err, "Tiers", za0001, "NumObjects")							return						}					default:						err = dc.Skip()						if err != nil {							err = msgp.WrapError(err, "Tiers", za0001)							return						}					}				}				z.Tiers[za0001] = za0002			}		default:			err = dc.Skip()			if err != nil {				err = msgp.WrapError(err)				return			}		}	}	return} // EncodeMsg implements msgp.Encodablefunc (z *allTierStats) EncodeMsg(en *msgp.Writer) (err error) {	// map header, size 1	// write "ts"	err = en.Append(0x81, 0xa2, 0x74, 0x73)	if err != nil {		return	}	err = en.WriteMapHeader(uint32(len(z.Tiers)))	if err != nil {		err = msgp.WrapError(err, "Tiers")		return	}	for za0001, za0002 := range z.Tiers {		err = en.WriteString(za0001)		if err != nil {			err = msgp.WrapError(err, "Tiers")			return		}		// map header, size 3		// write "ts"		err = en.Append(0x83, 0xa2, 0x74, 0x73)		if err != nil {			return		}		err = en.WriteUint64(za0002.TotalSize)		if err != nil {			err = msgp.WrapError(err, "Tiers", za0001, "TotalSize")			return		}		// write "nv"		err = en.Append(0xa2, 0x6e, 0x76)		if err != nil {			return		}		err = en.WriteInt(za0002.NumVersions)		if err != nil {			err = msgp.WrapError(err, "Tiers", za0001, "NumVersions")			return		}		// write "no"		err = en.Append(0xa2, 0x6e, 0x6f)		if err != nil {			return		}		err = en.WriteInt(za0002.NumObjects)		if err != nil {			err = msgp.WrapError(err, "Tiers", za0001, "NumObjects")			return		}	}	return} // MarshalMsg implements msgp.Marshalerfunc (z *allTierStats) MarshalMsg(b []byte) (o []byte, err error) {	o = msgp.Require(b, z.Msgsize())	// map header, size 1	// string "ts"	o = append(o, 0x81, 0xa2, 0x74, 0x73)	o = msgp.AppendMapHeader(o, uint32(len(z.Tiers)))	for za0001, za0002 := range z.Tiers {		o = msgp.AppendString(o, za0001)		// map header, size 3		// string "ts"		o = append(o, 0x83, 0xa2, 0x74, 0x73)		o = msgp.AppendUint64(o, za0002.TotalSize)		// string "nv"		o = append(o, 0xa2, 0x6e, 0x76)		o = msgp.AppendInt(o, za0002.NumVersions)		// string "no"		o = append(o, 0xa2, 0x6e, 0x6f)		o = msgp.AppendInt(o, za0002.NumObjects)	}	return} // UnmarshalMsg implements msgp.Unmarshalerfunc (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)		return	}	for zb0001 > 0 {		zb0001--		field, bts, err = msgp.ReadMapKeyZC(bts)		if err != nil {			err = msgp.WrapError(err)			return		}		switch msgp.UnsafeString(field) {		case "ts":			var zb0002 uint32			zb0002, bts, err = msgp.ReadMapHeaderBytes(bts)			if err != nil {				err = msgp.WrapError(err, "Tiers")				return			}			if z.Tiers == nil {				z.Tiers = make(map[string]tierStats, zb0002)			} else if len(z.Tiers) > 0 {				for key := range z.Tiers {					delete(z.Tiers, key)				}			}			for zb0002 > 0 {				var za0001 string				var za0002 tierStats				zb0002--				za0001, bts, err = msgp.ReadStringBytes(bts)				if err != nil {					err = msgp.WrapError(err, "Tiers")					return				}				var zb0003 uint32				zb0003, bts, err = msgp.ReadMapHeaderBytes(bts)				if err != nil {					err = msgp.WrapError(err, "Tiers", za0001)					return				}				for zb0003 > 0 {					zb0003--					field, bts, err = msgp.ReadMapKeyZC(bts)					if err != nil {						err = msgp.WrapError(err, "Tiers", za0001)						return					}					switch msgp.UnsafeString(field) {					case "ts":						za0002.TotalSize, bts, err = msgp.ReadUint64Bytes(bts)						if err != nil {							err = msgp.WrapError(err, "Tiers", za0001, "TotalSize")							return						}					case "nv":						za0002.NumVersions, bts, err = msgp.ReadIntBytes(bts)						if err != nil {							err = msgp.WrapError(err, "Tiers", za0001, "NumVersions")							return						}					case "no":						za0002.NumObjects, bts, err = msgp.ReadIntBytes(bts)						if err != nil {							err = msgp.WrapError(err, "Tiers", za0001, "NumObjects")							return						}					default:						bts, err = msgp.Skip(bts)						if err != nil {							err = msgp.WrapError(err, "Tiers", za0001)							return						}					}				}				z.Tiers[za0001] = za0002			}		default:			bts, err = msgp.Skip(bts)			if err != nil {				err = msgp.WrapError(err)				return			}		}	}	o = bts	return} // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized messagefunc (z *allTierStats) Msgsize() (s int) {	s = 1 + 3 + msgp.MapHeaderSize	if z.Tiers != nil {		for za0001, za0002 := range z.Tiers {			_ = za0002			s += msgp.StringPrefixSize + len(za0001) + 1 + 3 + msgp.Uint64Size + 3 + msgp.IntSize + 3 + msgp.IntSize		}	}	return} // MarshalMsg implements msgp.Marshalerfunc (z *currentScannerCycle) MarshalMsg(b []byte) (o []byte, err error) {	o = msgp.Require(b, z.Msgsize())	// map header, size 4	// string "current"	o = append(o, 0x84, 0xa7, 0x63, 0x75, 0x72, 0x72, 0x65, 0x6e, 0x74)	o = msgp.AppendUint64(o, z.current)	// string "next"	o = append(o, 0xa4, 0x6e, 0x65, 0x78, 0x74)	o = msgp.AppendUint64(o, z.next)	// string "started"	o = append(o, 0xa7, 0x73, 0x74, 0x61, 0x72, 0x74, 0x65, 0x64)	o = msgp.AppendTime(o, z.started)	// string "cycleCompleted"	o = append(o, 0xae, 0x63, 0x79, 0x63, 0x6c, 0x65, 0x43, 0x6f, 0x6d, 0x70, 0x6c, 0x65, 0x74, 0x65, 0x64)	o = msgp.AppendArrayHeader(o, uint32(len(z.cycleCompleted)))	for za0001 := range z.cycleCompleted {		o = msgp.AppendTime(o, z.cycleCompleted[za0001])	}	return} // UnmarshalMsg implements msgp.Unmarshalerfunc (z *currentScannerCycle) 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)		return	}	for zb0001 > 0 {		zb0001--		field, bts, err = msgp.ReadMapKeyZC(bts)		if err != nil {			err = msgp.WrapError(err)			return		}		switch msgp.UnsafeString(field) {		case "current":			z.current, bts, err = msgp.ReadUint64Bytes(bts)			if err != nil {				err = msgp.WrapError(err, "current")				return			}		case "next":			z.next, bts, err = msgp.ReadUint64Bytes(bts)			if err != nil {				err = msgp.WrapError(err, "next")				return			}		case "started":			z.started, bts, err = msgp.ReadTimeBytes(bts)			if err != nil {				err = msgp.WrapError(err, "started")				return			}		case "cycleCompleted":			var zb0002 uint32			zb0002, bts, err = msgp.ReadArrayHeaderBytes(bts)			if err != nil {				err = msgp.WrapError(err, "cycleCompleted")				return			}			if cap(z.cycleCompleted) >= int(zb0002) {				z.cycleCompleted = (z.cycleCompleted)[:zb0002]			} else {				z.cycleCompleted = make([]time.Time, zb0002)			}			for za0001 := range z.cycleCompleted {				z.cycleCompleted[za0001], bts, err = msgp.ReadTimeBytes(bts)				if err != nil {					err = msgp.WrapError(err, "cycleCompleted", za0001)					return				}			}		default:			bts, err = msgp.Skip(bts)			if err != nil {				err = msgp.WrapError(err)				return			}		}	}	o = bts	return} // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized messagefunc (z *currentScannerCycle) Msgsize() (s int) {	s = 1 + 8 + msgp.Uint64Size + 5 + msgp.Uint64Size + 8 + msgp.TimeSize + 15 + msgp.ArrayHeaderSize + (len(z.cycleCompleted) * (msgp.TimeSize))	return} // DecodeMsg implements msgp.Decodablefunc (z *dataUsageCache) DecodeMsg(dc *msgp.Reader) (err error) {	var field []byte	_ = field	var zb0001 uint32	zb0001, err = dc.ReadMapHeader()	if err != nil {		err = msgp.WrapError(err)		return	}	for zb0001 > 0 {		zb0001--		field, err = dc.ReadMapKeyPtr()		if err != nil {			err = msgp.WrapError(err)			return		}		switch msgp.UnsafeString(field) {		case "Info":			err = z.Info.DecodeMsg(dc)			if err != nil {				err = msgp.WrapError(err, "Info")				return			}		case "Cache":			var zb0002 uint32			zb0002, err = dc.ReadMapHeader()			if err != nil {				err = msgp.WrapError(err, "Cache")				return			}			if z.Cache == nil {				z.Cache = make(map[string]dataUsageEntry, zb0002)			} else if len(z.Cache) > 0 {				for key := range z.Cache {					delete(z.Cache, key)				}			}			for zb0002 > 0 {				zb0002--				var za0001 string				var za0002 dataUsageEntry				za0001, err = dc.ReadString()				if err != nil {					err = msgp.WrapError(err, "Cache")					return				}				err = za0002.DecodeMsg(dc)				if err != nil {					err = msgp.WrapError(err, "Cache", za0001)					return				}				z.Cache[za0001] = za0002			}		default:			err = dc.Skip()			if err != nil {				err = msgp.WrapError(err)				return			}		}	}	return} // EncodeMsg implements msgp.Encodablefunc (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	}	// write "Cache"	err = en.Append(0xa5, 0x43, 0x61, 0x63, 0x68, 0x65)	if err != nil {		return	}	err = en.WriteMapHeader(uint32(len(z.Cache)))	if err != nil {		err = msgp.WrapError(err, "Cache")		return	}	for za0001, za0002 := range z.Cache {		err = en.WriteString(za0001)		if err != nil {			err = msgp.WrapError(err, "Cache")			return		}		err = za0002.EncodeMsg(en)		if err != nil {			err = msgp.WrapError(err, "Cache", za0001)			return		}	}	return} // MarshalMsg implements msgp.Marshalerfunc (z *dataUsageCache) MarshalMsg(b []byte) (o []byte, err error) {	o = msgp.Require(b, z.Msgsize())	// map header, size 2	// string "Info"	o = append(o, 0x82, 0xa4, 0x49, 0x6e, 0x66, 0x6f)	o, err = z.Info.MarshalMsg(o)	if err != nil {		err = msgp.WrapError(err, "Info")		return	}	// string "Cache"	o = append(o, 0xa5, 0x43, 0x61, 0x63, 0x68, 0x65)	o = msgp.AppendMapHeader(o, uint32(len(z.Cache)))

Lines 1–500 of 3756.

Keyboard shortcuts

General

Show keyboard shortcuts
?
Focus the current search
/

Issues and pull requests

Open filters
f

Issues, pull requests and Inbox

Select next item
j↓
Select previous item
k↑
Open selected item
Enter
Dismiss filters or clear selection
Esc

Repository code

Go to file
t