- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 53 for TestOptions (0.22 sec)
-
pilot/pkg/networking/core/gateway_test.go
t.Errorf("got diff: %v", diff) } }) } } func TestCreateGatewayHTTPFilterChainOpts(t *testing.T) { cg := NewConfigGenTest(t, TestOptions{}) testCases := []struct { name string node *pilot_model.Proxy server *networking.Server routeName string proxyConfig *meshconfig.ProxyConfig
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 144K 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) -
pkg/kubeapiserver/options/authentication_test.go
} if len(errs) == 0 && len(testcase.expectErr) != 0 { t.Errorf("Got err nil, Expected err: %s", testcase.expectErr) } }) } } func TestToAuthenticationConfig(t *testing.T) { testOptions := &BuiltInAuthenticationOptions{ Anonymous: &AnonymousAuthenticationOptions{ Allow: false, }, ClientCert: &apiserveroptions.ClientCertAuthenticationOptions{ ClientCA: "testdata/root.pem", },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 36.5K bytes - Viewed (0) -
pkg/bootstrap/option/instances_test.go
meshAPI "istio.io/api/mesh/v1alpha1" networkingAPI "istio.io/api/networking/v1alpha3" "istio.io/istio/pkg/bootstrap/option" "istio.io/istio/pkg/model" ) // nolint: lll func TestOptions(t *testing.T) { cases := []struct { testName string key string option option.Instance expectError bool expected any }{ { testName: "proxy config",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 20:38:02 UTC 2024 - 22.4K bytes - Viewed (0) -
pilot/test/xds/fake.go
DomainSuffix: "cluster.local", }) defaultKubeClient.RunAndWait(stop) var gwc *gateway.Controller cg := core.NewConfigGenTest(t, core.TestOptions{ Configs: opts.Configs, ConfigString: opts.ConfigString, ConfigTemplateInput: opts.ConfigTemplateInput, ConfigController: configController, MeshConfig: m,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.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) -
src/net/http/serve_test.go
len(requestBody), requestBody) if !<-bodyOkay { // already failed. return } conn.Close() <-gotCloseNotify } func TestOptions(t *testing.T) { run(t, testOptions, []testMode{http1Mode}) } func testOptions(t *testing.T, mode testMode) { uric := make(chan string, 2) // only expect 1, but leave space for 2 mux := NewServeMux() mux.HandleFunc("/", func(w ResponseWriter, r *Request) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/fixtures/server.go
restOptions, err := RESTOptionsGetter.GetRESTOptions(schema.GroupResource{Group: "hopefully-ignored-group", Resource: "hopefully-ignored-resources"}) if err != nil { return nil, nil, nil, nil, "", err } tlsInfo := transport.TLSInfo{ CertFile: restOptions.StorageConfig.Transport.CertFile, KeyFile: restOptions.StorageConfig.Transport.KeyFile,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/registry/resource/resourceclassparameters/storage/storage_test.go
etcdStorage, server := registrytest.NewEtcdStorage(t, resource.GroupName) restOptions := generic.RESTOptions{ StorageConfig: etcdStorage, Decorator: generic.UndecoratedStorage, DeleteCollectionWorkers: 1, ResourcePrefix: "resourceclassparameters", } resourceClassStorage, err := NewREST(restOptions) if err != nil { t.Fatalf("unexpected error from REST storage: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:21:16 UTC 2024 - 4K bytes - Viewed (0) -
pkg/controlplane/apiserver/config_test.go
} restOptions, err := genericConfig.RESTOptionsGetter.GetRESTOptions(schema.GroupResource{Group: "", Resource: ""}) if err != nil { t.Fatal(err) } if restOptions.StorageConfig.StorageObjectCountTracker != genericConfig.StorageObjectCountTracker { t.Errorf("There are different StorageObjectCountTracker in restOptions and serverConfig") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 12:14:06 UTC 2024 - 2.5K bytes - Viewed (0)