| 111 | } |
| 112 | |
| 113 | type RecordImpl struct { |
| 114 | payload []byte |
| 115 | schema string |
| 116 | commitFunc func() |
| 117 | } |
| 118 | |
| 119 | func NewRecordImpl(payload []byte, ackFunc func()) *RecordImpl { |
| 120 | return &RecordImpl{ |
nothing calls this directly
no outgoing calls
no test coverage detected