- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for register_handler (0.23 sec)
-
pkg/kube/multicluster/secretcontroller.go
comp := &Component[T]{ constructor: constructor, clusters: make(map[cluster.ID]T), } c.registerHandler(comp) return comp } func (c *Controller) registerHandler(h handler) { // Intentionally no lock. The controller today requires that handlers are registered before execution and not in parallel. c.handlers = append(c.handlers, h) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 12.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
registerHandlers[*v1.Service](c, c.services, "Services", c.onServiceEvent, nil) c.endpoints = newEndpointSliceController(c) // This is for getting the node IPs of a selected set of nodes c.nodes = kclient.NewFiltered[*v1.Node](kubeClient, kclient.Filter{ObjectTransform: kubelib.StripNodeUnusedFields}) registerHandlers[*v1.Node](c, c.nodes, "Nodes", c.onNodeEvent, nil)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceimportcache.go
ObjectFilter: sic.client.ObjectFilter(), }) // Register callbacks for events. registerHandlers(sic.Controller, sic.serviceImports, "ServiceImports", sic.onServiceImportEvent, nil) sic.opts.MeshServiceController.AppendServiceHandlerForCluster(sic.Cluster(), sic.onServiceEvent) return sic }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 10.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network.go
n.gatewayResourceClient = kclient.NewDelayedInformer[*v1beta1.Gateway](c.client, gvr.KubernetesGateway, kubetypes.StandardInformer, kubetypes.Filter{}) // conditionally register this handler registerHandlers(c, n.gatewayResourceClient, "Gateways", n.handleGatewayResource, nil) } return n } // setNetworkFromNamespace sets network got from system namespace, returns whether it has changed
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 22:23:22 UTC 2024 - 15.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice.go
out := &endpointSliceController{ c: c, slices: slices, endpointCache: newEndpointSliceCache(), } registerHandlers[*v1.EndpointSlice](c, slices, "EndpointSlice", out.onEvent, nil) return out } func (esc *endpointSliceController) podArrived(name, ns string) error { ep := esc.slices.Get(name, ns) if ep == nil { return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 16.9K bytes - Viewed (0) -
cmd/kube-proxy/app/server.go
informers.WithTweakListOptions(func(options *metav1.ListOptions) { options.LabelSelector = labelSelector.String() })) // Create configs (i.e. Watches for Services, EndpointSlices and ServiceCIDRs) // Note: RegisterHandler() calls need to happen before creation of Sources because sources // only notify on changes, and the initial update (on process start) may be lost if no handlers // are registered yet.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 46.8K bytes - Viewed (0)