@@ -52,24 +52,19 @@ func GetDiscoverableServicesForEndpoints(endpoints map[string]controllerv1alpha1
5252
5353 if endpoint .Attributes .GetBoolean (string (controllerv1alpha1 .DiscoverableAttribute ), nil ) {
5454 serviceName := common .EndpointName (endpoint .Name )
55- log .Info ("Checking for existing service for discoverable endpoint" , "serviceName" , serviceName )
5655 existingService := & corev1.Service {}
5756 err := cl .Get (context .TODO (), client.ObjectKey {Name : serviceName , Namespace : meta .Namespace }, existingService )
5857 if err != nil {
5958 if ! errors .IsNotFound (err ) {
6059 log .Error (err , "Failed to get service from cluster" , "serviceName" , serviceName )
6160 return nil , err
6261 }
63- log .Info ("No existing service found" , "serviceName" , serviceName )
6462 } else {
65- log .Info ("Found existing service" , "serviceName" , serviceName )
6663 if existingService .Labels [constants .DevWorkspaceIDLabel ] != meta .DevWorkspaceId {
67- log .Info ("Service conflict detected" , "serviceName" , serviceName , "existingWorkspaceId" , existingService .Labels [constants .DevWorkspaceIDLabel ], "currentWorkspaceId" , meta .DevWorkspaceId )
6864 return nil , & ServiceConflictError {
6965 Reason : fmt .Sprintf ("discoverable endpoint %s conflicts with existing service" , endpoint .Name ),
7066 }
7167 }
72- log .Info ("Existing service is owned by the same workspace" , "serviceName" , serviceName )
7368 }
7469
7570 servicePort := corev1.ServicePort {
0 commit comments