Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for register_handler (0.25 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top