Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for RemovePodFromMesh (0.11 sec)

  1. cni/pkg/nodeagent/server_test.go

    	err := m.RemovePodFromMesh(fakeCtx, pod, true)
    
    	fakeIPSetDeps.AssertExpectations(t)
    
    	assert.NoError(t, err)
    }
    
    func TestMeshDataplaneDelPodErrorDoesntPatchPod(t *testing.T) {
    	pod := podWithAnnotation()
    
    	fakeCtx := context.Background()
    	server := &fakeServer{}
    	server.Start(fakeCtx)
    
    	server.On("RemovePodFromMesh",
    		fakeCtx,
    		pod,
    		true,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  2. 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.RemovePodFromMesh(ctx, pod, false)
    	assert.NoError(t, err)
    	assert.Equal(t, ztunnelServer.deletedPods.Load(), 1)
    	assert.Equal(t, nlDeps.DelInpodMarkIPRuleCnt.Load(), 1)
    	assert.Equal(t, nlDeps.DelLoopbackRoutesCnt.Load(), 1)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jul 25 16:13:38 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/informers.go

    			//
    			// We will get subsequent events that append a new status with the IP put back, but it's simpler
    			// and safer to just check the old pod status for the IP.
    			err := s.dataplane.RemovePodFromMesh(s.ctx, oldPod, true)
    			log.Debugf("RemovePodFromMesh returned: %v", err)
    			return nil
    		}
    
    		if !changeNeeded {
    			log.Debugf("pod update event skipped: no change needed")
    			return nil
    		}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/informers_test.go

    	assertPodAnnotated(t, client, pod)
    
    	// Assert expected calls actually made
    	fs.AssertExpectations(t)
    
    	// unlabelling the namespace should cause only one RemovePodFromMesh to happen
    	fs.On("RemovePodFromMesh",
    		ctx,
    		mock.Anything,
    		false,
    	).Once().Return(nil)
    
    	// unlabel the namespace
    	labelsPatch := []byte(fmt.Sprintf(`{"metadata":{"labels":{"%s":null}}}`,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/net.go

    		HostFilesystemPodNetwork: true,
    		NetworkNamespace:         "",
    	}
    }
    
    // RemovePodFromMesh is called when a pod needs to be removed from the mesh
    func (s *NetServer) RemovePodFromMesh(ctx context.Context, pod *corev1.Pod, isDelete bool) error {
    	log := log.WithLabels("ns", pod.Namespace, "name", pod.Name)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 21 16:48:55 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/server.go

    	Start(ctx context.Context)
    
    	//	IsPodInMesh(ctx context.Context, pod *metav1.ObjectMeta, netNs string) (bool, error)
    	AddPodToMesh(ctx context.Context, pod *corev1.Pod, podIPs []netip.Addr, netNs string) error
    	RemovePodFromMesh(ctx context.Context, pod *corev1.Pod, isDelete bool) error
    
    	Stop()
    }
    
    type Server struct {
    	ctx        context.Context
    	kubeClient kube.Client
    
    	handlers  K8sHandlers
    	dataplane MeshDataplane
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Sep 25 20:54:34 UTC 2024
    - 13.4K bytes
    - Viewed (0)
Back to top