(r *bufio.Reader, sz int)
| 270 | } |
| 271 | |
| 272 | func (p *partitionOffsetV1) readFrom(r *bufio.Reader, sz int) (remain int, err error) { |
| 273 | if remain, err = readInt32(r, sz, &p.Partition); err != nil { |
| 274 | return |
| 275 | } |
| 276 | if remain, err = readInt16(r, remain, &p.ErrorCode); err != nil { |
| 277 | return |
| 278 | } |
| 279 | if remain, err = readInt64(r, remain, &p.Timestamp); err != nil { |
| 280 | return |
| 281 | } |
| 282 | if remain, err = readInt64(r, remain, &p.Offset); err != nil { |
| 283 | return |
| 284 | } |
| 285 | return |
| 286 | } |
no test coverage detected