Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for apiservice (0.16 sec)

  1. pkg/proxy/servicechangetracker_test.go

    		},
    	}
    }
    
    func makeServiceMap(fake *FakeProxier, allServices ...*v1.Service) {
    	for i := range allServices {
    		fake.addService(allServices[i])
    	}
    }
    
    func (proxier *FakeProxier) addService(service *v1.Service) {
    	proxier.serviceChanges.Update(nil, service)
    }
    
    func (proxier *FakeProxier) updateService(oldService *v1.Service, service *v1.Service) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go

    // by this controller if an associated CRD is deleted.
    func OverlappingBuiltInResources() map[schema.GroupResource]bool {
    	return map[schema.GroupResource]bool{
    		{Group: "apiregistration.k8s.io", Resource: "apiservices"}:             true,
    		{Group: "apiextensions.k8s.io", Resource: "customresourcedefinitions"}: true,
    	}
    }
    
    // CRDFinalizer is a controller that finalizes the CRD by deleting all the CRs associated with it.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  3. pilot/pkg/xds/endpoints/ep_filters_test.go

    	//  - 1 IP gateway for network3
    	//  - 0 gateways for network4
    	ds := environment(t)
    	origServices := ds.Env().Services()
    	origGateways := ds.Env().NetworkGateways()
    	ds.MemRegistry.AddService(&model.Service{
    		Hostname: "istio-ingressgateway.istio-system.svc.cluster.local",
    		Attributes: model.ServiceAttributes{
    			ClusterExternalAddresses: &model.AddressMap{
    				Addresses: map[cluster.ID][]string{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 01:17:58 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  4. pilot/pkg/xds/eds_sh_test.go

    		})
    	}
    
    	svcLabels := map[string]string{
    		"version": "v1.1",
    	}
    
    	// Explicit test service, in the v2 memory registry. Similar with mock.MakeService,
    	// but easier to read.
    	memRegistry.AddService(&model.Service{
    		Hostname:       "service5.default.svc.cluster.local",
    		DefaultAddress: "10.10.0.1",
    		Ports: []*model.Port{
    			{
    				Name:     "http-main",
    				Port:     1080,
    				Protocol: protocol.HTTP,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jan 12 18:20:36 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/gateway.go

    		if httpRoute.GetMirror() != nil {
    			addService(host.Name(httpRoute.GetMirror().GetHost()))
    		}
    
    		for _, mirror := range httpRoute.GetMirrors() {
    			if mirror.GetDestination() != nil {
    				addService(host.Name(mirror.GetDestination().GetHost()))
    			}
    		}
    
    		for _, route := range httpRoute.GetRoute() {
    			if route.GetDestination() != nil {
    				addService(host.Name(route.GetDestination().GetHost()))
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 46.4K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/handler_test.go

    			quoted = strconv.Quote(etag)
    		}
    		req.Header.Set("If-None-Match", quoted)
    	}
    
    	handler.ServeHTTP(w, req)
    
    	bytes := w.Body.Bytes()
    	return w.Result(), bytes
    }
    
    // Add all builtin APIServices to the manager and check the output
    func TestBasicResponse(t *testing.T) {
    	manager := discoveryendpoint.NewResourceManager("apis")
    
    	apis := fuzzAPIGroups(1, 3, 10)
    	manager.SetGroups(apis.Items)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 02 00:29:39 UTC 2024
    - 28.6K bytes
    - Viewed (0)
Back to top