()
| 472 | } |
| 473 | |
| 474 | func (i *instance) resetHeadBlock() error { |
| 475 | dedicatedColumns := i.getDedicatedColumns() |
| 476 | |
| 477 | meta := &backend.BlockMeta{ |
| 478 | BlockID: backend.NewUUID(), |
| 479 | TenantID: i.tenantID, |
| 480 | DedicatedColumns: dedicatedColumns, |
| 481 | ReplicationFactor: backend.LiveStoreReplicationFactor, |
| 482 | } |
| 483 | block, err := i.wal.NewBlock(meta, model.CurrentEncoding) |
| 484 | if err != nil { |
| 485 | return err |
| 486 | } |
| 487 | i.blocks.Store(i.blocks.Load().withHeadBlock(block)) |
| 488 | i.lastCutTime = time.Now() |
| 489 | return nil |
| 490 | } |
| 491 | |
| 492 | type cutReason int |
| 493 |
no test coverage detected