- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for RemovePodFromMesh (0.11 sec)
-
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) -
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) -
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) -
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) -
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) -
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)