Struct localCompleteBlockLifecycle

modules/livestore/complete_block_lifecycle.go:114–124

The local implementation is used in the single-binary / monolithic mode for flushing blocks to the backend storage

// The local implementation is used in the single-binary / monolithic mode for flushing blocks to the backend storage
type localCompleteBlockLifecycle struct {
	flusher completeBlockFlusher
	logger  log.Logger

	flushConcurrency   int
	retryDelay         time.Duration
	completeBlockQueue *flushqueues.ExclusiveQueues[*localCompleteBlockOp]
	wg                 sync.WaitGroup
	ctx                context.Context
	cancel             context.CancelFunc
}

type localCompleteBlockOp struct {
	tenantID string