Function newLifecycleManagerForTest

internal/processing/manager_test.go:38–50

()

}

func newLifecycleManagerForTest() *LifecycleManager {
	settings := config.DefaultSettings()
	settings.Categories.CategoryEnabled.Value = false
	sem := make(chan struct{}, maxConcurrentProbes)
	for i := 0; i < maxConcurrentProbes; i++ {
		sem <- struct{}{}
	}
	return &LifecycleManager{
		settings:            settings,
		settingsRefreshedAt: time.Now(),
		probeSem:            sem,
	}
}

func TestLifecycleManager_Enqueue_PrecreatesWorkingFileBeforeDispatch(t *testing.T) {
	server := newProbeTestServer(t, 1234)