fix: operator defaults

components/backends/sglang/deploy/agg.yaml

@@ -27,7 +27,7 @@ spec:
         timeoutSeconds: 30
         failureThreshold: 10
       dynamoNamespace: sglang-agg
-      componentType: main
+      componentType: frontend
       replicas: 1
       resources:
         requests:

components/backends/sglang/deploy/agg_router.yaml

@@ -27,7 +27,7 @@ spec:
         timeoutSeconds: 30
         failureThreshold: 10
       dynamoNamespace: sglang-agg-router
-      componentType: main
+      componentType: frontend
       replicas: 1
       resources:
         requests:

components/backends/sglang/deploy/disagg.yaml

@@ -27,7 +27,7 @@ spec:
         timeoutSeconds: 30
         failureThreshold: 10
       dynamoNamespace: sglang-disagg
-      componentType: main
+      componentType: frontend
       replicas: 1
       resources:
         requests:

components/backends/trtllm/deploy/agg.yaml

@@ -9,7 +9,7 @@ spec:
   services:
     Frontend:
       dynamoNamespace: trtllm-agg
-      componentType: main
+      componentType: frontend
       livenessProbe:
         exec:
           command:

components/backends/trtllm/deploy/agg_router.yaml

@@ -28,7 +28,7 @@ spec:
         timeoutSeconds: 3
         failureThreshold: 5
       dynamoNamespace: trtllm-agg-router
-      componentType: main
+      componentType: frontend
       replicas: 1
       resources:
         requests:

components/backends/trtllm/deploy/disagg.yaml

@@ -9,7 +9,7 @@ spec:
   services:
     Frontend:
       dynamoNamespace: trtllm-disagg
-      componentType: main
+      componentType: frontend
       livenessProbe:
         exec:
           command:

components/backends/trtllm/deploy/disagg_router.yaml

@@ -9,7 +9,7 @@ spec:
   services:
     Frontend:
       dynamoNamespace: trtllm-v1-disagg-router
-      componentType: main
+      componentType: frontend
       livenessProbe:
         exec:
           command:

components/backends/vllm/deploy/agg.yaml

@@ -27,7 +27,7 @@ spec:
         timeoutSeconds: 5
         failureThreshold: 3
       dynamoNamespace: vllm-agg
-      componentType: main
+      componentType: frontend
       replicas: 1
       resources:
         requests:

components/backends/vllm/deploy/agg_router.yaml

@@ -27,7 +27,7 @@ spec:
         timeoutSeconds: 30
         failureThreshold: 10
       dynamoNamespace: vllm-agg-router
-      componentType: main
+      componentType: frontend
       replicas: 1
       resources:
         requests:

components/backends/vllm/deploy/disagg.yaml

@@ -9,7 +9,7 @@ spec:
   services:
     Frontend:
       dynamoNamespace: vllm-disagg
-      componentType: main
+      componentType: frontend
       replicas: 1
       livenessProbe:
         httpGet:

components/backends/vllm/deploy/disagg_planner.yaml

@@ -16,7 +16,7 @@ spec:
   services:
     Frontend:
       dynamoNamespace: vllm-disagg-planner
-      componentType: main
+      componentType: frontend
       replicas: 1
       livenessProbe:
         httpGet:
@@ -101,7 +101,7 @@ spec:
             - --profile-results-dir=/workspace/profiling_results
     Prometheus:
       dynamoNamespace: vllm-disagg-planner
-      componentType: main
+      componentType: default
       replicas: 1
       envs:
         - name: PYTHONPATH

components/backends/vllm/deploy/disagg_router.yaml

@@ -9,7 +9,7 @@ spec:
   services:
     Frontend:
       dynamoNamespace: vllm-v1-disagg-router
-      componentType: main
+      componentType: frontend
       replicas: 1
       livenessProbe:
         httpGet:

deploy/cloud/operator/api/v1alpha1/dynamocomponentdeployment_types.go

@@ -181,8 +181,8 @@ func (s *DynamoComponentDeployment) SetSpec(spec any) {
 	s.Spec = spec.(DynamoComponentDeploymentSpec)
 }
 
-func (s *DynamoComponentDeployment) IsMainComponent() bool {
-	return strings.HasSuffix(s.Spec.DynamoTag, s.Spec.ServiceName) || s.Spec.ComponentType == commonconsts.ComponentTypeMain
+func (s *DynamoComponentDeployment) IsFrontendComponent() bool {
+	return strings.HasSuffix(s.Spec.DynamoTag, s.Spec.ServiceName) || s.Spec.ComponentType == commonconsts.ComponentTypeFrontend
 }
 
 func (s *DynamoComponentDeployment) GetDynamoDeploymentConfig() []byte {

deploy/cloud/operator/api/v1alpha1/dynamocomponentdeployment_types_test.go

@@ -28,7 +28,7 @@ import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )
 
-func TestDynamoComponentDeployment_IsMainComponent(t *testing.T) {
+func TestDynamoComponentDeployment_IsFrontendComponent(t *testing.T) {
 	type fields struct {
 		TypeMeta   metav1.TypeMeta
 		ObjectMeta metav1.ObjectMeta
@@ -73,8 +73,8 @@ func TestDynamoComponentDeployment_IsMainComponent(t *testing.T) {
 				Spec:       tt.fields.Spec,
 				Status:     tt.fields.Status,
 			}
-			if got := s.IsMainComponent(); got != tt.want {
-				t.Errorf("DynamoComponentDeployment.IsMainComponent() = %v, want %v", got, tt.want)
+			if got := s.IsFrontendComponent(); got != tt.want {
+				t.Errorf("DynamoComponentDeployment.IsFrontendComponent() = %v, want %v", got, tt.want)
 			}
 		})
 	}

deploy/cloud/operator/internal/consts/consts.go

@@ -38,8 +38,9 @@ const (
 	DynamoDeploymentConfigEnvVar = "DYN_DEPLOYMENT_CONFIG"
 
 	ComponentTypePlanner      = "planner"
-	ComponentTypeMain         = "main"
+	ComponentTypeFrontend     = "frontend"
 	ComponentTypeWorker       = "worker"
+	ComponentTypeDefault      = "default"
 	PlannerServiceAccountName = "planner-serviceaccount"
 
 	DefaultIngressSuffix = "local"

deploy/cloud/operator/internal/controller/dynamocomponentdeployment_controller.go

@@ -1341,7 +1341,7 @@ func (r *DynamoComponentDeploymentReconciler) generateService(opt generateResour
 		},
 	}
 
-	if !opt.dynamoComponentDeployment.IsMainComponent() || (!opt.isGenericService && !opt.containsStealingTrafficDebugModeEnabled) {
+	if !opt.dynamoComponentDeployment.IsFrontendComponent() || (!opt.isGenericService && !opt.containsStealingTrafficDebugModeEnabled) {
 		// if it's not the main component or if it's not a generic service and not contains stealing traffic debug mode enabled, we don't need to create the service
 		return kubeService, true, nil
 	}

deploy/cloud/operator/internal/controller/dynamographdeployment_controller.go

@@ -179,7 +179,7 @@ func (r *DynamoGraphDeploymentReconciler) reconcileGroveResources(ctx context.Co
 	})
 	resources := []Resource{groveGangSetAsResource}
 	for componentName, component := range dynamoDeployment.Spec.Services {
-		if component.ComponentType == consts.ComponentTypeMain {
+		if component.ComponentType == consts.ComponentTypeFrontend {
 			// generate the main component service
 			mainComponentService, err := dynamo.GenerateComponentService(ctx, dynamo.GetDynamoComponentName(dynamoDeployment, componentName), dynamoDeployment.Namespace)
 			if err != nil {

deploy/cloud/operator/internal/dynamo/component_common.go

@@ -0,0 +1,45 @@
+/*
+ * SPDX-FileCopyrightText: Copyright (c) 2025 NVIDIA CORPORATION & AFFILIATES. All rights reserved.
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package dynamo
+
+import (
+	commonconsts "github.com/ai-dynamo/dynamo/deploy/cloud/operator/internal/consts"
+	corev1 "k8s.io/api/core/v1"
+)
+
+// ComponentDefaults interface defines how defaults should be provided
+type ComponentDefaults interface {
+	// GetBaseContainer returns the base container configuration for this component type
+	// The backendFramework parameter may be empty for components that don't need backend-specific config
+	GetBaseContainer(backendFramework BackendFramework) (corev1.Container, error)
+}
+
+// ComponentDefaultsFactory creates appropriate defaults based on component type
+func ComponentDefaultsFactory(componentType string) ComponentDefaults {
+	switch componentType {
+	case commonconsts.ComponentTypeFrontend:
+		return NewFrontendDefaults()
+	case commonconsts.ComponentTypeWorker:
+		return NewWorkerDefaults()
+	default:
+		return &BaseComponentDefaults{}
+	}
+}
+
+// BaseComponentDefaults provides common defaults shared by all components
+type BaseComponentDefaults struct{}
+
+func (b *BaseComponentDefaults) GetBaseContainer(backendFramework BackendFramework) (corev1.Container, error) {
+	return b.getCommonContainer(), nil
+}
+
+func (b *BaseComponentDefaults) getCommonContainer() corev1.Container {
+	container := corev1.Container{
+		Name: "main",
+	}
+
+	return container
+}

deploy/cloud/operator/internal/dynamo/component_frontend.go

@@ -0,0 +1,89 @@
+/*
+ * SPDX-FileCopyrightText: Copyright (c) 2025 NVIDIA CORPORATION & AFFILIATES. All rights reserved.
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package dynamo
+
+import (
+	"fmt"
+
+	commonconsts "github.com/ai-dynamo/dynamo/deploy/cloud/operator/internal/consts"
+	corev1 "k8s.io/api/core/v1"
+	"k8s.io/apimachinery/pkg/api/resource"
+	"k8s.io/apimachinery/pkg/util/intstr"
+)
+
+// FrontendDefaults implements ComponentDefaults for Frontend components
+type FrontendDefaults struct {
+	*BaseComponentDefaults
+}
+
+func NewFrontendDefaults() *FrontendDefaults {
+	return &FrontendDefaults{&BaseComponentDefaults{}}
+}
+
+func (f *FrontendDefaults) GetBaseContainer(backendFramework BackendFramework) (corev1.Container, error) {
+	// Frontend doesn't need backend-specific config
+	container := f.getCommonContainer()
+
+	// Add HTTP port
+	container.Ports = []corev1.ContainerPort{
+		{
+			Protocol:      corev1.ProtocolTCP,
+			Name:          commonconsts.DynamoContainerPortName,
+			ContainerPort: int32(commonconsts.DynamoServicePort),
+		},
+	}
+
+	// Add frontend-specific defaults
+	container.LivenessProbe = &corev1.Probe{
+		ProbeHandler: corev1.ProbeHandler{
+			HTTPGet: &corev1.HTTPGetAction{
+				Path: "/health",
+				Port: intstr.FromString(commonconsts.DynamoContainerPortName),
+			},
+		},
+		InitialDelaySeconds: 60,
+		PeriodSeconds:       60,
+		TimeoutSeconds:      30,
+		FailureThreshold:    10,
+	}
+
+	container.ReadinessProbe = &corev1.Probe{
+		ProbeHandler: corev1.ProbeHandler{
+			Exec: &corev1.ExecAction{
+				Command: []string{
+					"/bin/sh",
+					"-c",
+					"curl -s http://localhost:${DYNAMO_PORT}/health | jq -e \".status == \\\"healthy\\\"\"",
+				},
+			},
+		},
+		InitialDelaySeconds: 60,
+		PeriodSeconds:       60,
+		TimeoutSeconds:      30,
+		FailureThreshold:    10,
+	}
+
+	container.Resources = corev1.ResourceRequirements{
+		Requests: corev1.ResourceList{
+			corev1.ResourceCPU:    resource.MustParse("1"),
+			corev1.ResourceMemory: resource.MustParse("2Gi"),
+		},
+		Limits: corev1.ResourceList{
+			corev1.ResourceCPU:    resource.MustParse("1"),
+			corev1.ResourceMemory: resource.MustParse("2Gi"),
+		},
+	}
+
+	// Add standard environment variables
+	container.Env = []corev1.EnvVar{
+		{
+			Name:  commonconsts.EnvDynamoServicePort,
+			Value: fmt.Sprintf("%d", commonconsts.DynamoServicePort),
+		},
+	}
+
+	return container, nil
+}