Function New

modules/blockbuilder/blockbuilder.go:156–181

(
	cfg Config,
	logger log.Logger,
	partitionRing ring.PartitionRingReader,
	overrides Overrides,
	store storage.Store,
)

}

func New(
	cfg Config,
	logger log.Logger,
	partitionRing ring.PartitionRingReader,
	overrides Overrides,
	store storage.Store,
) (*BlockBuilder, error) {
	if err := cfg.Validate(); err != nil {
		return nil, err
	}

	b := &BlockBuilder{
		logger:         logger,
		cfg:            cfg,
		partitionRing:  partitionRing,
		decoder:        ingest.NewDecoder(),
		overrides:      overrides,
		reader:         store,
		writer:         store,
		compactor:      store,
		consumeStopped: make(chan struct{}),
	}

	b.Service = services.NewBasicService(b.starting, b.running, b.stopping)
	return b, nil
}

func (b *BlockBuilder) starting(ctx context.Context) (err error) {
	level.Info(b.logger).Log("msg", "block builder starting")