()
| 261 | } |
| 262 | |
| 263 | func (c *ControlBatch) ReadControlRecord() (*ControlRecord, error) { |
| 264 | r, err := c.ReadRecord() |
| 265 | if err != nil { |
| 266 | return nil, err |
| 267 | } |
| 268 | if r.Key != nil { |
| 269 | defer r.Key.Close() |
| 270 | } |
| 271 | if r.Value != nil { |
| 272 | defer r.Value.Close() |
| 273 | } |
| 274 | return ReadControlRecord(r) |
| 275 | } |
| 276 | |
| 277 | func (c *ControlBatch) Offset() int64 { |
| 278 | return c.BaseOffset |