Function newStore

modules/blockbuilder/blockbuilder_test.go:946–962

(ctx context.Context, t testing.TB)

func (o *ownEverythingSharder) Owns(string) bool { return true }

func newStore(ctx context.Context, t testing.TB) storage.Store {
	// The store is never started as a dskit service, so StopAndAwaitTerminated
	// transitions New→Terminated without calling stopping()/Shutdown(). cancel()
	// signals the blocklist polling goroutine (started by EnablePolling) to
	// exit, and store.Shutdown() blocks until it actually has. Both are needed:
	// without cancel() the goroutine never exits; without Shutdown() we don't
	// wait for it, and it races with t.TempDir() cleanup, writing tenant index
	// files while os.RemoveAll runs.
	ctx, cancel := context.WithCancel(ctx)
	store := newStoreWithLogger(ctx, t, testLogger(t), false)
	t.Cleanup(func() {
		cancel()
		store.Shutdown()
		require.NoError(t, services.StopAndAwaitTerminated(context.Background(), store))
	})
	return store
}

func newStoreWithLogger(ctx context.Context, t testing.TB, log log.Logger, skipNoCompactBlocks bool) storage.Store {
	tmpDir := t.TempDir()