| 284 | } |
| 285 | |
| 286 | type walBlock struct { |
| 287 | meta *backend.BlockMeta |
| 288 | path string |
| 289 | ingestionSlack time.Duration |
| 290 | |
| 291 | // Unflushed data |
| 292 | buffer *Trace |
| 293 | ids *common.IDMap[int64] |
| 294 | file *os.File |
| 295 | writer *parquet.GenericWriter[*Trace] |
| 296 | decoder model.ObjectDecoder |
| 297 | unflushedSize int64 |
| 298 | |
| 299 | // Flushed data |
| 300 | flushed []*walBlockFlush |
| 301 | flushedSize int64 |
| 302 | mtx sync.Mutex |
| 303 | } |
| 304 | |
| 305 | func (b *walBlock) readFlushes() []*walBlockFlush { |
| 306 | b.mtx.Lock() |
nothing calls this directly
no outgoing calls
no test coverage detected