fix ep log

snapp-incubator · Sep 7, 2024 · 7d1f787 · 7d1f787
1 parent 3a489c2
commit 7d1f787
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/internal/controller/service/helpers.go b/internal/controller/service/helpers.go
@@ -64,7 +64,7 @@ func (re *ReconcilerExtended) buildCNP() (cnp *ciliumv2.CiliumNetworkPolicy, err
 		cilium_policy_api.EntityWorld,
 	}
 
-	endpointSelector, err := getEndponitSelector(re.service.Spec.Selector)
+	endpointSelector, err := re.getEndponitSelector(re.service.Spec.Selector)
 	if err == nil {
 		cnp = &ciliumv2.CiliumNetworkPolicy{
 			ObjectMeta: metav1.ObjectMeta{
@@ -92,10 +92,10 @@ func (re *ReconcilerExtended) buildCNP() (cnp *ciliumv2.CiliumNetworkPolicy, err
 // getEndponitSelector is used to filter and extract cilium endpoint selector from service labels.
 //
 //nolint:wsl
-func getEndponitSelector(serviceSlector map[string]string) (ciliumEndPointSelector cilium_policy_api.EndpointSelector, err error) {
+func (re *ReconcilerExtended) getEndponitSelector(serviceSlector map[string]string) (ciliumEndPointSelector cilium_policy_api.EndpointSelector, err error) {
 	identityLabels, informationLabels := cilium_labelsfilter.Filter(cilium_labels.Map2Labels(serviceSlector, cilium_labels.LabelSourceK8s))
 	if len(informationLabels.K8sStringMap()) != 0 {
-		log.Log.Info("excluded_labels", "information labels", informationLabels.String())
+		re.logger.Info("excluded_labels", "information labels", informationLabels.String())
 	}
 
 	identityLabelSelector := cilium_slim_metav1.LabelSelector{MatchLabels: identityLabels.K8sStringMap()}

diff --git a/internal/controller/service/helpers_test.go b/internal/controller/service/helpers_test.go
@@ -106,7 +106,8 @@ func Test_getEndponitSelector(t *testing.T) {
 	}
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
-			gotCiliumEndPointSelector, err := getEndponitSelector(tt.given)
+			re := &ReconcilerExtended{}
+			gotCiliumEndPointSelector, err := re.getEndponitSelector(tt.given)
 			if (err != nil) != tt.wantErr {
 				t.Errorf("getEndponitSelector() error = %v, wantErr %v", err, tt.wantErr)
 				return