Function newTestService

internal/maintenance/queue_maintainer_test.go:31–38

(tb testing.TB)

}

func newTestService(tb testing.TB) *testService {
	tb.Helper()

	testSvc := baseservice.Init(riversharedtest.BaseServiceArchetype(tb), &testService{})
	testSvc.testSignals.Init(tb)

	return testSvc
}

func (s *testService) Start(ctx context.Context) error {
	ctx, shouldStart, started, stopped := s.StartInit(ctx)