Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for register_handler (0.21 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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