| package fluent |
| |
| // NOTE: THIS FILE WAS PRODUCED BY THE |
| // MSGP CODE GENERATION TOOL (github.com/tinylib/msgp) |
| // DO NOT EDIT |
| |
| import ( |
| "github.com/tinylib/msgp/msgp" |
| ) |
| |
| // DecodeMsg implements msgp.Decodable |
| func (z *TestMessage) DecodeMsg(dc *msgp.Reader) (err error) { |
| var field []byte |
| _ = field |
| var zxvk uint32 |
| zxvk, err = dc.ReadMapHeader() |
| if err != nil { |
| return |
| } |
| for zxvk > 0 { |
| zxvk-- |
| field, err = dc.ReadMapKeyPtr() |
| if err != nil { |
| return |
| } |
| switch msgp.UnsafeString(field) { |
| case "foo": |
| z.Foo, err = dc.ReadString() |
| if err != nil { |
| return |
| } |
| case "hoge": |
| z.Hoge, err = dc.ReadString() |
| if err != nil { |
| return |
| } |
| default: |
| err = dc.Skip() |
| if err != nil { |
| return |
| } |
| } |
| } |
| return |
| } |
| |
| // EncodeMsg implements msgp.Encodable |
| func (z TestMessage) EncodeMsg(en *msgp.Writer) (err error) { |
| // map header, size 2 |
| // write "foo" |
| err = en.Append(0x82, 0xa3, 0x66, 0x6f, 0x6f) |
| if err != nil { |
| return err |
| } |
| err = en.WriteString(z.Foo) |
| if err != nil { |
| return |
| } |
| // write "hoge" |
| err = en.Append(0xa4, 0x68, 0x6f, 0x67, 0x65) |
| if err != nil { |
| return err |
| } |
| err = en.WriteString(z.Hoge) |
| if err != nil { |
| return |
| } |
| return |
| } |
| |
| // MarshalMsg implements msgp.Marshaler |
| func (z TestMessage) MarshalMsg(b []byte) (o []byte, err error) { |
| o = msgp.Require(b, z.Msgsize()) |
| // map header, size 2 |
| // string "foo" |
| o = append(o, 0x82, 0xa3, 0x66, 0x6f, 0x6f) |
| o = msgp.AppendString(o, z.Foo) |
| // string "hoge" |
| o = append(o, 0xa4, 0x68, 0x6f, 0x67, 0x65) |
| o = msgp.AppendString(o, z.Hoge) |
| return |
| } |
| |
| // UnmarshalMsg implements msgp.Unmarshaler |
| func (z *TestMessage) UnmarshalMsg(bts []byte) (o []byte, err error) { |
| var field []byte |
| _ = field |
| var zbzg uint32 |
| zbzg, bts, err = msgp.ReadMapHeaderBytes(bts) |
| if err != nil { |
| return |
| } |
| for zbzg > 0 { |
| zbzg-- |
| field, bts, err = msgp.ReadMapKeyZC(bts) |
| if err != nil { |
| return |
| } |
| switch msgp.UnsafeString(field) { |
| case "foo": |
| z.Foo, bts, err = msgp.ReadStringBytes(bts) |
| if err != nil { |
| return |
| } |
| case "hoge": |
| z.Hoge, bts, err = msgp.ReadStringBytes(bts) |
| if err != nil { |
| return |
| } |
| default: |
| bts, err = msgp.Skip(bts) |
| if err != nil { |
| return |
| } |
| } |
| } |
| o = bts |
| return |
| } |
| |
| // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message |
| func (z TestMessage) Msgsize() (s int) { |
| s = 1 + 4 + msgp.StringPrefixSize + len(z.Foo) + 5 + msgp.StringPrefixSize + len(z.Hoge) |
| return |
| } |