- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for NewNodeUntainter (0.14 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)