Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for DelPodFromMesh (0.19 sec)

  1. cni/pkg/nodeagent/informers.go

    		// If we did, remove it from ztunnel
    		if util.PodRedirectionActive(pod) {
    			log.Debugf("pod %s is deleted and was annotated, removing from ztunnel", pod.Name)
    			err := s.dataplane.DelPodFromMesh(s.ctx, pod)
    			if err != nil {
    				log.Warnf("DelPodFromMesh(%s) returned %v", pod.Name, err)
    			}
    		} else {
    			log.Debugf("skipped deleting from mesh for pod (%s), pod not in mesh", pod.Name)
    		}
    	}
    	return nil
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 21:31:35 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/net.go

    		log.Errorf("failed to delete pod from ztunnel: %v", err)
    	}
    	return nil
    }
    
    // Delete pod from mesh: pod is deleted. iptables rules will die with it, we just need to update ztunnel
    func (s *NetServer) DelPodFromMesh(ctx context.Context, pod *corev1.Pod) error {
    	log := log.WithLabels("ns", pod.Namespace, "name", pod.Name)
    	log.Debug("Pod is now stopped... cleaning up.")
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 05:10:23 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/net_test.go

    	closed := fakens.closed
    	workload := WorkloadInfo{
    		Workload: podToWorkload(pod),
    		Netns:    fakens,
    	}
    	fixture.podNsMap.UpsertPodCacheWithNetns(string(pod.UID), workload)
    	err := netServer.DelPodFromMesh(ctx, pod)
    	assert.NoError(t, err)
    	assert.Equal(t, ztunnelServer.deletedPods.Load(), 1)
    	// with delete iptables is not called, as there is no need to delete the iptables rules
    	// from a pod that's gone from the cluster.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 05:10:23 UTC 2024
    - 17.8K bytes
    - Viewed (0)
Back to top