Function newDetectorTestEnv

coderd/jobreaper/detector_test.go:48–66

newDetectorTestEnv creates a new test environment with a started detector.

(ctx context.Context, t *testing.T)

// newDetectorTestEnv creates a new test environment with a started detector.
func newDetectorTestEnv(ctx context.Context, t *testing.T) *detectorTestEnv {
	t.Helper()
	db, ps := dbtestutil.NewDB(t)
	log := testutil.Logger(t)
	tickCh := make(chan time.Time)
	statsCh := make(chan jobreaper.Stats)

	detector := jobreaper.New(ctx, wrapDBAuthz(db, log), ps, log, tickCh).WithStatsChannel(statsCh)
	detector.Start()

	return &detectorTestEnv{
		t:        t,
		DB:       db,
		Pubsub:   ps,
		detector: detector,
		tickCh:   tickCh,
		statsCh:  statsCh,
	}
}

// tick sends a tick with the given time and returns the stats from the
// detector run. It respects context cancellation to avoid blocking forever