Function newCompleteBlockLifecycle

modules/livestore/complete_block_lifecycle.go:75–91

(cfg Config, flusher completeBlockFlusher, logger log.Logger)

}

func newCompleteBlockLifecycle(cfg Config, flusher completeBlockFlusher, logger log.Logger) (completeBlockLifecycle, error) {
	if cfg.ConsumeFromKafka {
		return kafkaCompleteBlockLifecycle{}, nil
	}

	if flusher == nil {
		return nil, fmt.Errorf("complete block flusher is required when kafka consumption is disabled")
	}

	return &localCompleteBlockLifecycle{
		flusher:            flusher,
		logger:             logger,
		flushConcurrency:   cfg.CompleteBlockConcurrency,
		retryDelay:         cfg.initialBackoff,
		completeBlockQueue: flushqueues.New[*localCompleteBlockOp](nil),
	}, nil
}

// The lifecycle for Kafka mode is noop