@@ -316,19 +316,18 @@ func (p *KubeRuntime) Start(ctx context.Context) error {
316
316
zap .String ("statefulSet" , statefulSetName ),
317
317
)
318
318
319
- // Create Service for the node (prefix with 's-' for DNS compatibility)
320
- serviceName := "s-" + statefulSetName
321
- if err := p .createNodeService (ctx , serviceName ); err != nil {
322
- return fmt .Errorf ("failed to create Service for node: %w" , err )
323
- }
319
+ if ! IsRunningInCluster () {
320
+ // If running outside the cluster, ensure the node's API port is accessible via ingress
324
321
325
- // Create Ingress for the node
326
- if err := p .createNodeIngress (ctx , serviceName ); err != nil {
327
- return fmt .Errorf ("failed to create Ingress for node: %w" , err )
328
- }
322
+ serviceName := "s-" + statefulSetName // The 's-' prefix ensures DNS compatibility
323
+ if err := p .createNodeService (ctx , serviceName ); err != nil {
324
+ return fmt .Errorf ("failed to create Service for node: %w" , err )
325
+ }
326
+
327
+ if err := p .createNodeIngress (ctx , serviceName ); err != nil {
328
+ return fmt .Errorf ("failed to create Ingress for node: %w" , err )
329
+ }
329
330
330
- // Wait for ingress to be ready if running outside cluster
331
- if ! IsRunningInCluster () {
332
331
if err := p .waitForIngressReadiness (ctx , serviceName ); err != nil {
333
332
return fmt .Errorf ("failed to wait for Ingress readiness: %w" , err )
334
333
}
0 commit comments