| 303 | } |
| 304 | |
| 305 | type walBlock struct { |
| 306 | meta *backend.BlockMeta |
| 307 | path string |
| 308 | ingestionSlack time.Duration |
| 309 | dedcolsRes dedicatedColumnMapping |
| 310 | dedcolsSpan dedicatedColumnMapping |
| 311 | dedcolsEvent dedicatedColumnMapping |
| 312 | |
| 313 | // Unflushed data |
| 314 | buffer *Trace |
| 315 | ids *common.IDMap[int64] |
| 316 | file *os.File |
| 317 | writer *parquet.GenericWriter[*Trace] |
| 318 | decoder model.ObjectDecoder |
| 319 | unflushedSize int64 |
| 320 | |
| 321 | // Flushed data |
| 322 | flushed []*walBlockFlush |
| 323 | flushedSize int64 |
| 324 | mtx sync.Mutex |
| 325 | } |
| 326 | |
| 327 | func (b *walBlock) readFlushes() []*walBlockFlush { |
| 328 | b.mtx.Lock() |
nothing calls this directly
no outgoing calls
no test coverage detected