fix reading
This commit is contained in:
parent
8779ce5f96
commit
ac4c53305e
|
@ -71,6 +71,7 @@ func (rd *msgpackReader) ReadInt8(v *int8, targetField string) error {
|
||||||
return errors.WithStack(err)
|
return errors.WithStack(err)
|
||||||
}
|
}
|
||||||
rd.curr.values[field] = raw
|
rd.curr.values[field] = raw
|
||||||
|
rd.curr.readCnt = i + 1
|
||||||
}
|
}
|
||||||
|
|
||||||
return FieldNotFound
|
return FieldNotFound
|
||||||
|
@ -101,6 +102,7 @@ func (rd *msgpackReader) ReadInt16(v *int16, targetField string) error {
|
||||||
return errors.WithStack(err)
|
return errors.WithStack(err)
|
||||||
}
|
}
|
||||||
rd.curr.values[field] = raw
|
rd.curr.values[field] = raw
|
||||||
|
rd.curr.readCnt = i + 1
|
||||||
}
|
}
|
||||||
|
|
||||||
return FieldNotFound
|
return FieldNotFound
|
||||||
|
@ -131,6 +133,7 @@ func (rd *msgpackReader) ReadInt32(v *int32, targetField string) error {
|
||||||
return errors.WithStack(err)
|
return errors.WithStack(err)
|
||||||
}
|
}
|
||||||
rd.curr.values[field] = raw
|
rd.curr.values[field] = raw
|
||||||
|
rd.curr.readCnt = i + 1
|
||||||
}
|
}
|
||||||
|
|
||||||
return FieldNotFound
|
return FieldNotFound
|
||||||
|
@ -161,6 +164,7 @@ func (rd *msgpackReader) ReadInt64(v *int64, targetField string) error {
|
||||||
return errors.WithStack(err)
|
return errors.WithStack(err)
|
||||||
}
|
}
|
||||||
rd.curr.values[field] = raw
|
rd.curr.values[field] = raw
|
||||||
|
rd.curr.readCnt = i + 1
|
||||||
}
|
}
|
||||||
|
|
||||||
return FieldNotFound
|
return FieldNotFound
|
||||||
|
@ -191,6 +195,7 @@ func (rd *msgpackReader) ReadUint8(v *uint8, targetField string) error {
|
||||||
return errors.WithStack(err)
|
return errors.WithStack(err)
|
||||||
}
|
}
|
||||||
rd.curr.values[field] = raw
|
rd.curr.values[field] = raw
|
||||||
|
rd.curr.readCnt = i + 1
|
||||||
}
|
}
|
||||||
|
|
||||||
return FieldNotFound
|
return FieldNotFound
|
||||||
|
@ -221,6 +226,7 @@ func (rd *msgpackReader) ReadUint16(v *uint16, targetField string) error {
|
||||||
return errors.WithStack(err)
|
return errors.WithStack(err)
|
||||||
}
|
}
|
||||||
rd.curr.values[field] = raw
|
rd.curr.values[field] = raw
|
||||||
|
rd.curr.readCnt = i + 1
|
||||||
}
|
}
|
||||||
|
|
||||||
return FieldNotFound
|
return FieldNotFound
|
||||||
|
@ -251,6 +257,7 @@ func (rd *msgpackReader) ReadUint32(v *uint32, targetField string) error {
|
||||||
return errors.WithStack(err)
|
return errors.WithStack(err)
|
||||||
}
|
}
|
||||||
rd.curr.values[field] = raw
|
rd.curr.values[field] = raw
|
||||||
|
rd.curr.readCnt = i + 1
|
||||||
}
|
}
|
||||||
|
|
||||||
return FieldNotFound
|
return FieldNotFound
|
||||||
|
@ -281,6 +288,7 @@ func (rd *msgpackReader) ReadUint64(v *uint64, targetField string) error {
|
||||||
return errors.WithStack(err)
|
return errors.WithStack(err)
|
||||||
}
|
}
|
||||||
rd.curr.values[field] = raw
|
rd.curr.values[field] = raw
|
||||||
|
rd.curr.readCnt = i + 1
|
||||||
}
|
}
|
||||||
|
|
||||||
return FieldNotFound
|
return FieldNotFound
|
||||||
|
@ -311,6 +319,7 @@ func (rd *msgpackReader) ReadBool(v *bool, targetField string) error {
|
||||||
return errors.WithStack(err)
|
return errors.WithStack(err)
|
||||||
}
|
}
|
||||||
rd.curr.values[field] = raw
|
rd.curr.values[field] = raw
|
||||||
|
rd.curr.readCnt = i + 1
|
||||||
}
|
}
|
||||||
|
|
||||||
return FieldNotFound
|
return FieldNotFound
|
||||||
|
@ -341,6 +350,7 @@ func (rd *msgpackReader) ReadFloat32(v *float32, targetField string) error {
|
||||||
return errors.WithStack(err)
|
return errors.WithStack(err)
|
||||||
}
|
}
|
||||||
rd.curr.values[field] = raw
|
rd.curr.values[field] = raw
|
||||||
|
rd.curr.readCnt = i + 1
|
||||||
}
|
}
|
||||||
|
|
||||||
return FieldNotFound
|
return FieldNotFound
|
||||||
|
@ -371,6 +381,7 @@ func (rd *msgpackReader) ReadFloat64(v *float64, targetField string) error {
|
||||||
return errors.WithStack(err)
|
return errors.WithStack(err)
|
||||||
}
|
}
|
||||||
rd.curr.values[field] = raw
|
rd.curr.values[field] = raw
|
||||||
|
rd.curr.readCnt = i + 1
|
||||||
}
|
}
|
||||||
|
|
||||||
return FieldNotFound
|
return FieldNotFound
|
||||||
|
@ -401,6 +412,7 @@ func (rd *msgpackReader) ReadString(v *string, targetField string) error {
|
||||||
return errors.WithStack(err)
|
return errors.WithStack(err)
|
||||||
}
|
}
|
||||||
rd.curr.values[field] = raw
|
rd.curr.values[field] = raw
|
||||||
|
rd.curr.readCnt = i + 1
|
||||||
}
|
}
|
||||||
|
|
||||||
return FieldNotFound
|
return FieldNotFound
|
||||||
|
@ -431,6 +443,7 @@ func (rd *msgpackReader) ReadBytes(v *[]byte, targetField string) error {
|
||||||
return errors.WithStack(err)
|
return errors.WithStack(err)
|
||||||
}
|
}
|
||||||
rd.curr.values[field] = raw
|
rd.curr.values[field] = raw
|
||||||
|
rd.curr.readCnt = i + 1
|
||||||
}
|
}
|
||||||
|
|
||||||
return FieldNotFound
|
return FieldNotFound
|
||||||
|
|
Loading…
Reference in New Issue