| 292 | } |
| 293 | |
| 294 | type walBlock struct { |
| 295 | meta *backend.BlockMeta |
| 296 | path string |
| 297 | ingestionSlack time.Duration |
| 298 | dedcolsRes dedicatedColumnMapping |
| 299 | dedcolsSpan dedicatedColumnMapping |
| 300 | |
| 301 | // Unflushed data |
| 302 | buffer *Trace |
| 303 | ids *common.IDMap[int64] |
| 304 | file *os.File |
| 305 | writer *parquet.GenericWriter[*Trace] |
| 306 | decoder model.ObjectDecoder |
| 307 | unflushedSize int64 |
| 308 | |
| 309 | // Flushed data |
| 310 | flushed []*walBlockFlush |
| 311 | flushedSize int64 |
| 312 | mtx sync.Mutex |
| 313 | } |
| 314 | |
| 315 | func (b *walBlock) readFlushes() []*walBlockFlush { |
| 316 | b.mtx.Lock() |
nothing calls this directly
no outgoing calls
no test coverage detected