Refactor egress watcher related logs

v2/controllers/egress_watcher.go

@@ -34,7 +34,6 @@ type EgressWatcher struct {
 func (r *EgressWatcher) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
 	logger := log.FromContext(ctx)
 
-	logger.Info("start reconciling egress")
 	eg := &coilv2.Egress{}
 	if err := r.Get(ctx, req.NamespacedName, eg); err != nil {
 		if apierrors.IsNotFound(err) {
@@ -90,10 +89,8 @@ func (r *EgressWatcher) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.R
 	return ctrl.Result{}, nil
 }
 
-func (r *EgressWatcher) reconcileEgressClient(ctx context.Context, eg *coilv2.Egress, pod *corev1.Pod, l *logr.Logger) error {
-	logger := l.WithValues("pod_name", pod.Name, "pod_namespace", pod.Namespace)
-	logger.Info("reconcile egress client")
-	hook, err := r.getHook(ctx, eg, &logger)
+func (r *EgressWatcher) reconcileEgressClient(ctx context.Context, eg *coilv2.Egress, pod *corev1.Pod, logger *logr.Logger) error {
+	hook, err := r.getHook(ctx, eg, logger)
 	if err != nil {
 		return fmt.Errorf("failed to setup NAT hook: %w", err)
 	}
@@ -185,7 +182,6 @@ func (r *EgressWatcher) hook(gwn gwNets, log *logr.Logger) func(ipv4, ipv6 net.I
 			return fmt.Errorf("natClient hasn't been initialized: %w", err)
 		}
 
-		log.Info("add a fou device by EgressWatcher", "gateway", gwn.gateway.String())
 		link, err := ft.AddPeer(gwn.gateway, gwn.sportAuto)
 		if errors.Is(err, founat.ErrIPFamilyMismatch) {
 			// ignore unsupported IP family link

v2/pkg/founat/fou.go

@@ -100,9 +100,6 @@ func (t *fouTunnel) Init() error {
 		if err := modProbe("fou"); err != nil {
 			return fmt.Errorf("failed to load fou module: %w", err)
 		}
-		if t.logFunc != nil {
-			t.logFunc("add FoU devide for IPv4")
-		}
 		err := netlink.FouAdd(netlink.Fou{
 			Family:    netlink.FAMILY_V4,
 			Protocol:  4, // IPv4 over IPv4 (so-called IPIP)
@@ -259,6 +256,9 @@ func (t *fouTunnel) addOrRecreatePeer4(addr net.IP, sportAuto bool) (string, err
 		Local:      t.local4,
 	}
 
+	if t.logFunc != nil {
+		t.logFunc(fmt.Sprintf("add a new FoU device: %s", linkName))
+	}
 	if err := netlink.LinkAdd(link); err != nil {
 		return "", fmt.Errorf("netlink: failed to add fou link: %w", err)
 	}
@@ -325,6 +325,9 @@ func (t *fouTunnel) addOrRecreatePeer6(addr net.IP, sportAuto bool) (string, err
 		Remote:     addr,
 		Local:      t.local6,
 	}
+	if t.logFunc != nil {
+		t.logFunc(fmt.Sprintf("add a new FoU device: %s", linkName))
+	}
 	if err := netlink.LinkAdd(link); err != nil {
 		return "", fmt.Errorf("netlink: failed to add fou6 link: %w", err)
 	}

v2/pkg/nodenet/pod.go

@@ -443,7 +443,6 @@ func (pn *podNetwork) Update(podIPv4, podIPv6 net.IP, hook SetupHook) error {
 	defer containerNS.Close()
 
 	err = containerNS.Do(func(ns.NetNS) error {
-		pn.log.Info("do the hook function", "netns", netNsPath, "pod_address", podIPv4)
 		if hook != nil {
 			return hook(podIPv4, podIPv6)
 		}