Function startServer

pkg/kwok/cmd/root.go:317–459

(ctx context.Context, flags *flagpole, ctr *controllers.Controller, typedKwokClient versioned.Interface, tracingProvider tracing.TracerProvider)

}

func startServer(ctx context.Context, flags *flagpole, ctr *controllers.Controller, typedKwokClient versioned.Interface, tracingProvider tracing.TracerProvider) (err error) {
	logger := log.FromContext(ctx)

	serverAddress := flags.Options.ServerAddress
	if serverAddress == "" && flags.Options.NodePort != 0 {
		serverAddress = "0.0.0.0:" + format.String(flags.Options.NodePort)
	}

	if serverAddress != "" {
		clusterPortForwards := config.FilterWithTypeFromContext[*internalversion.ClusterPortForward](ctx)
		err = checkConfigOrCRD(flags.Options.EnableCRDs, v1alpha1.ClusterPortForwardKind, clusterPortForwards)
		if err != nil {
			return err
		}

		portForwards := config.FilterWithTypeFromContext[*internalversion.PortForward](ctx)
		err = checkConfigOrCRD(flags.Options.EnableCRDs, v1alpha1.PortForwardKind, portForwards)
		if err != nil {
			return err
		}

		clusterExecs := config.FilterWithTypeFromContext[*internalversion.ClusterExec](ctx)
		err = checkConfigOrCRD(flags.Options.EnableCRDs, v1alpha1.ClusterExecKind, clusterExecs)
		if err != nil {
			return err
		}

		execs := config.FilterWithTypeFromContext[*internalversion.Exec](ctx)
		err = checkConfigOrCRD(flags.Options.EnableCRDs, v1alpha1.ExecKind, execs)
		if err != nil {
			return err
		}

		clusterLogs := config.FilterWithTypeFromContext[*internalversion.ClusterLogs](ctx)
		err = checkConfigOrCRD(flags.Options.EnableCRDs, v1alpha1.ClusterLogsKind, clusterLogs)
		if err != nil {
			return err
		}

		logs := config.FilterWithTypeFromContext[*internalversion.Logs](ctx)
		err = checkConfigOrCRD(flags.Options.EnableCRDs, v1alpha1.LogsKind, logs)
		if err != nil {
			return err
		}

		clusterAttaches := config.FilterWithTypeFromContext[*internalversion.ClusterAttach](ctx)
		err = checkConfigOrCRD(flags.Options.EnableCRDs, v1alpha1.ClusterAttachKind, clusterAttaches)
		if err != nil {
			return err
		}

		attaches := config.FilterWithTypeFromContext[*internalversion.Attach](ctx)
		err = checkConfigOrCRD(flags.Options.EnableCRDs, v1alpha1.AttachKind, attaches)
		if err != nil {
			return err
		}

		clusterResourceUsages := config.FilterWithTypeFromContext[*internalversion.ClusterResourceUsage](ctx)