- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for TestOptions (0.23 sec)
-
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) -
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) -
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) -
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) -
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) -
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)