- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for SetupProxy (0.16 sec)
-
pilot/pkg/networking/core/fuzz_test.go
defer fuzz.Finalize() fg := fuzz.New(t, data) proxy := fuzz.Struct[*model.Proxy](fg) to := fuzz.Struct[TestOptions](fg) lb := fuzz.Struct[*ListenerBuilder](fg) cg := NewConfigGenTest(t, to) lb.node = cg.SetupProxy(proxy) lb.push = cg.PushContext() cg.ConfigGen.buildGatewayListeners(lb) }) } func FuzzBuildSidecarOutboundHTTPRouteConfig(f *testing.F) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 2.2K bytes - Viewed (0) -
pilot/pkg/xds/xds_test.go
}, }) proxy := s.SetupProxy(baseProxy()) assertListEqual(t, xdstest.ExtractClusterEndpoints(s.Clusters(proxy))["outbound|80||app.com"], []string{"included.com:80"}) }) } func TestSidecarListeners(t *testing.T) { t.Run("empty", func(t *testing.T) { s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) proxy := s.SetupProxy(&model.Proxy{ IPAddresses: []string{"10.2.0.1"},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 13.8K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_builder_test.go
}, }, } cg := NewConfigGenTest(t, TestOptions{Configs: getEnvoyFilterConfigs(configPatches)}) gatewayProxy := cg.SetupProxy(&model.Proxy{Type: model.Router, ConfigNamespace: "not-default"}) sidecarProxy := cg.SetupProxy(&model.Proxy{ConfigNamespace: "not-default"}) type fields struct { GatewayListeners []*listener.Listener InboundListeners []*listener.Listener
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 24.7K bytes - Viewed (0) -
pilot/pkg/xds/sds_test.go
} else { xds.DisableAuthorizationForSecret(cc) } cc.Fake.Unlock() gen := s.Discovery.Generators[v3.SecretType] tt.request.Start = time.Now() secrets, _, _ := gen.Generate(s.SetupProxy(tt.proxy), &model.WatchedResource{ResourceNames: tt.resources}, tt.request) raw := xdstest.ExtractTLSSecrets(t, xdsserver.ResourcesToAny(secrets)) got := map[string]Expected{} for _, scrt := range raw {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 17.7K bytes - Viewed (0) -
pilot/pkg/networking/core/networkfilter_test.go
clusterName: "inbound|8888||", port: model.ServiceInstancePort{ ServicePort: &model.Port{}, }, } listenerFilters := NewListenerBuilder(cg.SetupProxy(nil), cg.PushContext()).buildInboundNetworkFilters(fcc) tcp := &tcp.TcpProxy{} listenerFilters[len(listenerFilters)-1].GetTypedConfig().UnmarshalTo(tcp) if tcp.StatPrefix != tt.expectedStatPrefix {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 25.8K bytes - Viewed (0) -
tests/fuzz/xds_fuzzer.go
// Use crd.ParseInputs to verify data _, _, err := crd.ParseInputs(string(data)) if err != nil { return 0 } s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{ ConfigString: string(data), }) proxy := s.SetupProxy(&model.Proxy{ ConfigNamespace: "app", }) _ = s.Listeners(proxy) _ = s.Routes(proxy) return 1
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 1.1K bytes - Viewed (0) -
tests/fuzz/v1alpha3_fuzzer.go
if err != nil { return 0 } err = f.GenerateStruct(&proxy) if err != nil || !proxy.FuzzValidate() { return 0 } cg := core.NewConfigGenTest(utils.NopTester{}, to) p := cg.SetupProxy(&proxy) _ = cg.Clusters(p) _ = cg.Routes(p) return 1
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 1.6K bytes - Viewed (0) -
pilot/pkg/networking/core/fake.go
f.ServiceEntryRegistry.ResyncEDS() } // SetupProxy initializes a proxy for the current environment. This should generally be used when creating // any proxy. For example, `p := SetupProxy(&model.Proxy{...})`. func (f *ConfigGenTest) SetupProxy(p *model.Proxy) *model.Proxy { // Setup defaults if p == nil { p = &model.Proxy{} } if p.Metadata == nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 11.5K bytes - Viewed (0) -
pilot/pkg/xds/cds_test.go
} // Run multiple assertions to verify idempotency; previous versions had issues here. for i := 0; i < 2; i++ { clusters := s.Clusters(s.SetupProxy(&model.Proxy{ConfigNamespace: "test"})) assertSANs(t, clusters, "outbound|80||example.default.svc.cluster.local", tt.sans) t.Logf("iteration %d passed", i) } }) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 01 02:06:39 UTC 2024 - 9.2K bytes - Viewed (0) -
pilot/pkg/xds/vm_test.go
AutoRegisterGroup: "wg", Namespace: "namespace", Network: "network1", Labels: map[string]string{"merge": "meta", "meta": "2"}, }, } ds.Connect(ds.SetupProxy(proxy), nil, nil) var we *config.Config retry.UntilSuccessOrFail(t, func() error { we = ds.Store().Get(gvk.WorkloadEntry, "wg-1.1.1.1-network1", "namespace") if we == nil { return fmt.Errorf("no WE found") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 2.3K bytes - Viewed (0)