MessageSet is an implementation of the RecordReader interface representing regular message sets (v1).
| 309 | // MessageSet is an implementation of the RecordReader interface representing |
| 310 | // regular message sets (v1). |
| 311 | type MessageSet struct { |
| 312 | Attributes Attributes |
| 313 | BaseOffset int64 |
| 314 | Records RecordReader |
| 315 | } |
| 316 | |
| 317 | func (m *MessageSet) ReadRecord() (*Record, error) { |
| 318 | return m.Records.ReadRecord() |
nothing calls this directly
no outgoing calls
no test coverage detected