- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for AddMeshHandler (0.25 sec)
-
pilot/pkg/config/kube/ingress/status.go
// Ingress selector matches this pod, enqueue everything c.enqueueAll() } })) // Mesh may have changed ingress fields, enqueue everything c.meshConfig.AddMeshHandler(c.enqueueAll) return c } // runningAddresses returns a list of IP addresses and/or FQDN in the namespace // where the ingress controller is currently running
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 7.9K bytes - Viewed (0) -
pkg/kube/namespace/filter.go
) kubetypes.DynamicObjectFilter { // convert LabelSelectors to Selectors f := &discoveryNamespacesFilter{ namespaces: namespaces, discoveryNamespaces: sets.New[string](), } mesh.AddMeshHandler(func() { f.selectorsChanged(mesh.Mesh().GetDiscoverySelectors(), true) }) namespaces.AddEventHandler(controllers.EventHandler[*corev1.Namespace]{ AddFunc: func(ns *corev1.Namespace) { f.lock.Lock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 17:12:52 UTC 2024 - 9.3K bytes - Viewed (0) -
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)