- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for PodController (0.1 sec)
-
pkg/test/framework/components/echo/kube/pod_controller.go
}) }, }) return &podController{ q: q, informer: informer, } } func (c *podController) Run(stop <-chan struct{}) { go c.informer.Run(stop) kube.WaitForCacheSync("pod controller", stop, c.informer.HasSynced) c.q.Run(stop) } func (c *podController) HasSynced() bool { return c.q.HasSynced() } func (c *podController) WaitForSync(stopCh <-chan struct{}) bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 09 02:22:47 UTC 2023 - 2.6K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/workload_manager.go
) type workloadHandler interface { WorkloadReady(w *workload) WorkloadNotReady(w *workload) } type workloadManager struct { workloads []*workload mutex sync.Mutex podController *podController cfg echo.Config ctx resource.Context grpcPort uint16 tls *echoCommon.TLSSettings closing bool stopCh chan struct{} handler workloadHandler }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 02:12:37 UTC 2023 - 6.4K bytes - Viewed (0)