- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for NewStatusSyncer (0.5 sec)
-
pilot/pkg/config/kube/ingress/status.go
func (s *StatusSyncer) Run(stopCh <-chan struct{}) { s.queue.Run(stopCh) controllers.ShutdownAll(s.services, s.nodes, s.pods, s.ingressClasses, s.ingresses) } // NewStatusSyncer creates a new instance func NewStatusSyncer(meshHolder mesh.Watcher, kc kubelib.Client) *StatusSyncer { c := &StatusSyncer{ meshConfig: meshHolder,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 7.9K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/status_test.go
config.IngressService = ingressService return mesh.NewFixedWatcher(config) } func makeStatusSyncer(t *testing.T, name string) *StatusSyncer { client := kubelib.NewFakeClient(testObjects...) sync := NewStatusSyncer(fakeMeshHolder(name), client) client.RunAndWait(test.NewStop(t)) go sync.Run(test.NewStop(t)) return sync } // nolint: unparam
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 5.8K bytes - Viewed (0)