Function newController

workflow/controller/controller_test.go:256–363

(ctx context.Context, options ...interface{})

var testExporter *telemetry.TestMetricsExporter

func newController(ctx context.Context, options ...interface{}) (context.CancelFunc, *WorkflowController) {
	// get all the objects and add to the fake
	var objects, coreObjects []runtime.Object
	for _, opt := range options {
		switch v := opt.(type) {
		case *apiv1.ServiceAccount:
			coreObjects = append(coreObjects, v)
		case runtime.Object:
			objects = append(objects, v)
		}
	}
	wfclientset := fakewfclientset.NewSimpleClientset(objects...)
	dynamicClient := dynamicfake.NewSimpleDynamicClient(scheme.Scheme, objects...)
	informerFactory := wfextv.NewSharedInformerFactory(wfclientset, 0)
	ctx, cancel := context.WithCancel(ctx)
	kube := fake.NewSimpleClientset(coreObjects...)
	wfc := &WorkflowController{
		Config: config.Config{
			Images: map[string]config.Image{
				"my-image": {
					Entrypoint: []string{"my-entrypoint"},
					Cmd:        []string{"my-cmd"},
				},
				"argoproj/argosay:v2":    {Cmd: []string{""}},
				"docker/whalesay:latest": {Cmd: []string{""}},
				"busybox":                {Cmd: []string{""}},
			},
		},
		artifactRepositories: armocks.DummyArtifactRepositories(&wfv1.ArtifactRepository{
			S3: &wfv1.S3ArtifactRepository{
				S3Bucket: wfv1.S3Bucket{Endpoint: "my-endpoint", Bucket: "my-bucket"},
			},
		}),
		cliExecutorLogFormat:      "text",
		kubeclientset:             kube,
		dynamicInterface:          dynamicClient,
		wfclientset:               wfclientset,
		workflowKeyLock:           sync.NewKeyLock(),
		wfArchive:                 sqldb.NullWorkflowArchive,
		hydrator:                  hydratorfake.Noop,
		estimatorFactory:          estimation.DummyEstimatorFactory,
		eventRecorderManager:      &testEventRecorderManager{eventRecorder: record.NewFakeRecorder(64)},
		archiveLabelSelector:      labels.Everything(),
		cacheFactory:              controllercache.NewCacheFactory(kube, "default"),
		progressPatchTickDuration: envutil.LookupEnvDurationOr(ctx, common.EnvVarProgressPatchTickDuration, 1*time.Minute),
		progressFileTickDuration:  envutil.LookupEnvDurationOr(ctx, common.EnvVarProgressFileTickDuration, 3*time.Second),
		maxStackDepth:             maxAllowedStackDepth,
	}

	for _, opt := range options {
		switch v := opt.(type) {
		// any post-processing
		case func(workflowController *WorkflowController):
			v(wfc)
		}
	}

	// always compare to NewWorkflowController to see what this block of code should be doing