(r *bufio.Reader, size int)
| 189 | } |
| 190 | |
| 191 | func (t *offsetFetchResponseV1PartitionResponse) readFrom(r *bufio.Reader, size int) (remain int, err error) { |
| 192 | if remain, err = readInt32(r, size, &t.Partition); err != nil { |
| 193 | return |
| 194 | } |
| 195 | if remain, err = readInt64(r, remain, &t.Offset); err != nil { |
| 196 | return |
| 197 | } |
| 198 | if remain, err = readString(r, remain, &t.Metadata); err != nil { |
| 199 | return |
| 200 | } |
| 201 | if remain, err = readInt16(r, remain, &t.ErrorCode); err != nil { |
| 202 | return |
| 203 | } |
| 204 | return |
| 205 | } |
| 206 | |
| 207 | type offsetFetchResponseV1Response struct { |
| 208 | // Topic name |
nothing calls this directly
no test coverage detected