- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for GetActiveAmbientPodSnapshot (0.2 sec)
-
cni/pkg/nodeagent/informers.go
"nodeagent_reconcile_events_total", "The total number of node agent reconcile events.", ) ) type K8sHandlers interface { GetPodIfAmbient(podName, podNamespace string) (*corev1.Pod, error) GetActiveAmbientPodSnapshot() []*corev1.Pod Start() } type InformerHandlers struct { ctx context.Context dataplane MeshDataplane systemNamespace string queue controllers.Queue
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 11.8K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
} func (s *Server) Start() { log.Info("CNI ambient server starting") s.kubeClient.RunAndWait(s.ctx.Done()) log.Info("CNI ambient server kubeclient started") pods := s.handlers.GetActiveAmbientPodSnapshot() err := s.dataplane.ConstructInitialSnapshot(pods) if err != nil { log.Warnf("failed to construct initial snapshot: %v", err) } log.Info("CNI ambient server marking ready") s.Ready()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:18 UTC 2024 - 7.2K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
server := &meshDataplane{ kubeClient: client.Kube(), netServer: fs, } handlers := setupHandlers(ctx, client, server, "istio-system") client.RunAndWait(ctx.Done()) pods := handlers.GetActiveAmbientPodSnapshot() // Should only return pods with the annotation indicating they are actually redirected at this time, // not pods that are just scheduled to be enrolled. assert.Equal(t, len(pods), 1)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 22.2K bytes - Viewed (0)