Method Start

pkg/operator/operator.go:223–333

(ctx context.Context)

}

func (o *operator) Start(ctx context.Context) error {
	log.Info("Dapr Operator is starting")

	/*
		Make sure to set `ENABLE_WEBHOOKS=false` when we run locally.
	*/
	enableConversionWebhooks := !strings.EqualFold(os.Getenv("ENABLE_WEBHOOKS"), "false")
	if enableConversionWebhooks {
		err := ctrl.NewWebhookManagedBy(o.mgr).
			For(&subscriptionsapiV1alpha1.Subscription{}).
			Complete()
		if err != nil {
			return fmt.Errorf("unable to create webhook Subscriptions v1alpha1: %w", err)
		}
		err = ctrl.NewWebhookManagedBy(o.mgr).
			For(&subapi.Subscription{}).
			Complete()
		if err != nil {
			return fmt.Errorf("unable to create webhook Subscriptions v2alpha1: %w", err)
		}
	}

	caBundleCh := make(chan []byte)

	runner := concurrency.NewRunnerManager(
		o.secProvider.Run,
		func(ctx context.Context) error {
			// Wait for webhook certificates to be ready before starting the manager.
			_, rErr := o.secProvider.Handler(ctx)
			if rErr != nil {
				return rErr
			}
			o.secHealthz.Ready()
			return o.mgr.Start(ctx)
		},
		func(ctx context.Context) error {
			if rErr := o.apiServer.Ready(ctx); rErr != nil {
				return fmt.Errorf("API server did not become ready in time: %w", rErr)
			}
			o.apiServerHealthz.Ready()
			log.Infof("Dapr Operator started")
			<-ctx.Done()
			return nil
		},
		func(ctx context.Context) error {
			if !enableConversionWebhooks {
				<-ctx.Done()
				return nil
			}
			sec, rErr := o.secProvider.Handler(ctx)
			if rErr != nil {
				return rErr
			}
			sec.WatchTrustAnchors(ctx, caBundleCh)
			return nil
		},
		func(ctx context.Context) error {
			if !enableConversionWebhooks {