Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for TestOptions (0.23 sec)

  1. pilot/pkg/networking/core/route/route_test.go

    		out.IstioVersion.Minor = 21
    		return out
    	}
    
    	gatewayNames := sets.New("some-gateway")
    
    	t.Run("for virtual service", func(t *testing.T) {
    		g := NewWithT(t)
    		cg := core.NewConfigGenTest(t, core.TestOptions{})
    
    		t.Setenv("ISTIO_DEFAULT_REQUEST_TIMEOUT", "0ms")
    
    		routes, err := route.BuildHTTPRoutesForVirtualService(node(cg), virtualServicePlain, serviceRegistry, nil, 8080, gatewayNames, route.RouteOptions{})
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 14:12:39 UTC 2024
    - 88.1K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/listener_test.go

    	t.Helper()
    	listeners := buildListeners(t, TestOptions{Services: services}, proxy)
    	verifyFilterChainMatch(t, xdstest.ExtractListener(model.VirtualInboundListenerName, listeners))
    }
    
    func testInboundListenerConfigWithConflictPort(t *testing.T, proxy *model.Proxy, services ...*model.Service) {
    	t.Helper()
    	listeners := buildListeners(t, TestOptions{Services: services}, proxy)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 93.6K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/httproute_test.go

    			// ensure services are ordered
    			t0 := time.Now()
    			for _, svc := range tt.services {
    				svc.CreationTime = t0
    				t0 = t0.Add(time.Minute)
    			}
    			cg := NewConfigGenTest(t, TestOptions{
    				Services: tt.services,
    				Configs:  tt.config,
    			})
    
    			vHostCache := make(map[int][]*route.VirtualHost)
    			resource, _ := cg.ConfigGen.buildSidecarOutboundHTTPRouteConfig(
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 51.4K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/sidecar_simulation_test.go

    		name := tt.name
    		if tt.proxy == nil {
    			tt.proxy = proxy
    		} else {
    			name += "-" + tt.proxy.Metadata.IstioVersion
    		}
    
    		t.Run(name, func(t *testing.T) {
    			s := core.NewConfigGenTest(t, core.TestOptions{
    				Services:  tt.services,
    				Instances: tt.instances,
    				Configs:   tt.configs,
    				MeshConfig: func() *meshconfig.MeshConfig {
    					m := mesh.DefaultMeshConfig()
    					if tt.disableInboundPassthrough {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 84.7K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go

    	}
    
    	if e.DeleteStrategy == nil {
    		return fmt.Errorf("store for %s must have DeleteStrategy set", e.DefaultQualifiedResource.String())
    	}
    
    	if options.RESTOptions == nil {
    		return fmt.Errorf("options for %s must have RESTOptions set", e.DefaultQualifiedResource.String())
    	}
    
    	attrFunc := options.AttrFunc
    	if attrFunc == nil {
    		if isNamespaced {
    			attrFunc = storage.DefaultNamespaceScopedAttr
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 23:22:44 UTC 2024
    - 60.8K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler.go

    	structuralSchemaGK    schema.GroupKind
    	preserveUnknownFields bool
    }
    
    func (t crdConversionRESTOptionsGetter) GetRESTOptions(resource schema.GroupResource) (generic.RESTOptions, error) {
    	ret, err := t.RESTOptionsGetter.GetRESTOptions(resource)
    	if err == nil {
    		d := schemaCoercingDecoder{delegate: ret.StorageConfig.Codec, validator: unstructuredSchemaCoercer{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 19:06:46 UTC 2024
    - 52.9K bytes
    - Viewed (0)
Back to top