- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewNodeUntainter (0.15 sec)
-
pilot/pkg/controllers/untaint/nodeuntainter_test.go
} } func newNodeUntainterTestServer(t *testing.T) *nodeTainterTestServer { stop := make(chan struct{}) t.Cleanup(func() { close(stop) }) client := kubelib.NewFakeClient() nodeUntainter := NewNodeUntainter(stop, client, systemNS, systemNS) go nodeUntainter.Run(stop) client.RunAndWait(stop) kubelib.WaitForCacheSync("test", stop, nodeUntainter.HasSynced) pc := clienttest.Wrap(t, nodeUntainter.podsClient)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 00:50:31 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/controllers/untaint/nodeuntainter.go
return func(obj any) bool { object := controllers.ExtractObject(obj) if object == nil { return false } return ns == object.GetNamespace() } } func NewNodeUntainter(stop <-chan struct{}, kubeClient kubelib.Client, cniNs, sysNs string) *NodeUntainter { log.Debugf("starting node untainter with labels %v", istioCniLabels) ns := cniNs if ns == "" { ns = sysNs }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 00:50:31 UTC 2024 - 6.9K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
go leaderelection. NewLeaderElection(args.Namespace, args.PodName, leaderelection.NodeUntaintController, args.Revision, s.kubeClient). AddRunFunction(func(leaderStop <-chan struct{}) { nodeUntainter := untaint.NewNodeUntainter(leaderStop, s.kubeClient, args.CniNamespace, args.Namespace) nodeUntainter.Run(leaderStop) }).Run(stop) return nil }) } func (s *Server) initMulticluster(args *PilotArgs) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0)