- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for ConstructInitialSnapshot (0.24 sec)
-
cni/pkg/nodeagent/net.go
return s.ztunnelServer.PodAdded(ctx, pod, netns) } // ConstructInitialSnapshot takes a "snapshot" of current ambient pods and // // 1. Constructs a ztunnel state message to initialize ztunnel // 2. Syncs the host ipset func (s *NetServer) ConstructInitialSnapshot(ambientPods []*corev1.Pod) error { var consErr []error if err := s.syncHostIPSets(ambientPods); err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
cni/pkg/nodeagent/net_test.go
} pod := &corev1.Pod{ObjectMeta: podMeta} fixture.ipsetDeps.On("listEntriesByIP", "foo-v4", ).Return([]netip.Addr{}, nil) err := netServer.ConstructInitialSnapshot([]*corev1.Pod{pod}) assert.NoError(t, err) if fixture.podNsMap.Get("863b91d4-4b68-4efa-917f-4b560e3e86aa") == nil { t.Fatal("expected pod to be in cache") } }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0)