- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for AddMeshHandler (0.49 sec)
-
pilot/pkg/bootstrap/certcontroller.go
} caBundle, err = s.RA.GetRootCertFromMeshConfig(signerName) if err != nil { return err } // MeshConfig:Add callback for mesh config update s.environment.AddMeshHandler(func() { newCaBundle, _ := s.RA.GetRootCertFromMeshConfig(signerName) if newCaBundle != nil && !bytes.Equal(newCaBundle, s.istiodCertBundleWatcher.GetKeyCertBundle().CABundle) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 11.3K bytes - Viewed (0) -
pilot/pkg/model/context.go
return "", "", fmt.Errorf("invalid Istiod Port: %s, %s, %v", port, proxyConfig.DiscoveryAddress, err) } return host.Name(hostname), port, nil } func (e *Environment) AddMeshHandler(h func()) { if e != nil && e.Watcher != nil { e.Watcher.AddMeshHandler(h) } } func (e *Environment) AddNetworksHandler(h func()) { if e != nil && e.NetworksWatcher != nil { e.NetworksWatcher.AddNetworksHandler(h) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
func (s *Server) initMeshHandlers(changeHandler func(_ *meshconfig.MeshConfig)) { log.Info("initializing mesh handlers") // When the mesh config or networks change, do a full push. s.environment.AddMeshHandler(func() { changeHandler(s.environment.Mesh()) s.XDSServer.ConfigUpdate(&model.PushRequest{ Full: true, Reason: model.NewReasonStats(model.GlobalUpdate), }) }) }
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/bootstrap/istio_ca.go
} raServer, err := ra.NewIstioRA(raOpts) if err != nil { return nil, err } raServer.SetCACertificatesFromMeshConfig(s.environment.Mesh().CaCertificates) s.environment.AddMeshHandler(func() { meshConfig := s.environment.Mesh() caCertificates := meshConfig.CaCertificates s.RA.SetCACertificatesFromMeshConfig(caCertificates) }) return raServer, err
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 20.6K bytes - Viewed (0) -
pkg/kube/inject/webhook.go
log.Errorf("failed to process webhook config: %v", err) } p.Mux.HandleFunc("/inject", wh.serveInject) p.Mux.HandleFunc("/inject/", wh.serveInject) p.Env.Watcher.AddMeshHandler(func() { wh.mu.Lock() wh.meshConfig = p.Env.Mesh() wh.mu.Unlock() }) return wh, nil } // Run implements the webhook server func (wh *Webhook) Run(stop <-chan struct{}) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:59:39 UTC 2024 - 42.2K bytes - Viewed (0)