- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for initControllers (0.11 sec)
-
pilot/pkg/bootstrap/server.go
s.certMu.RLock() defer s.certMu.RUnlock() if s.istiodCert != nil { return s.istiodCert, nil } return nil, fmt.Errorf("cert not initialized") } // initControllers initializes the controllers. func (s *Server) initControllers(args *PilotArgs) error { log.Info("initializing controllers") s.initMulticluster(args) s.initSDSServer() if features.EnableNodeUntaintControllers {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/multicluster_test.go
t.Helper() assert.EventuallyEqual(t, func() int { return len(m.component.All()) }, expectedControllerCount, retry.Message(timeoutName), retry.Delay(time.Millisecond*10), retry.Timeout(time.Second*5)) } func initController(client kube.CLIClient, ns string, stop <-chan struct{}) *multicluster.Controller { sc := multicluster.NewController(client, ns, "cluster-1", mesh.NewFixedWatcher(nil))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 16:44:32 UTC 2024 - 6.7K bytes - Viewed (0)