Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for DelPodFromMesh (0.25 sec)

  1. cni/pkg/nodeagent/server_test.go

    	server := &fakeServer{}
    	server.Start(fakeCtx)
    
    	server.On("DelPodFromMesh",
    		fakeCtx,
    		pod,
    	).Return(nil)
    
    	fakeClientSet := fake.NewSimpleClientset()
    	m := meshDataplane{
    		kubeClient: fakeClientSet,
    		netServer:  server,
    	}
    
    	// pod is not in fake client, so if this will try to remove annotation, it will fail.
    	err := m.DelPodFromMesh(fakeCtx, pod)
    	assert.NoError(t, err)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/server.go

    	return err
    }
    
    // Delete pod from mesh: pod is deleted. iptables rules will die with it, we just need to update ztunnel
    func (s *meshDataplane) DelPodFromMesh(ctx context.Context, pod *corev1.Pod) error {
    	log := log.WithLabels("ns", pod.Namespace, "name", pod.Name)
    	err := s.netServer.DelPodFromMesh(ctx, pod)
    	if err != nil {
    		log.Errorf("failed to delete pod from mesh: %v", err)
    		return err
    	}
    	return nil
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 21:45:18 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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