- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for SetupProxy (0.15 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) -
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/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) -
pilot/pkg/networking/apigen/apigen_test.go
// Verify we can receive the DNS cluster IPs using XDS t.Run("adsc", func(t *testing.T) { proxy := &model.Proxy{Metadata: &model.NodeMetadata{ Generator: "api", }} adscConn := ds.ConnectUnstarted(ds.SetupProxy(proxy), xds.APIWatches()) store := memory.Make(collections.Pilot) configController := memory.NewController(store) adscConn.Store = configController err := adscConn.Run() if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 2.3K bytes - Viewed (0) -
pilot/pkg/xds/nds_test.go
s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) gen := s.Discovery.Generators[v3.NameTableType] tt.request.Start = time.Now() nametable, _, _ := gen.Generate(s.SetupProxy(tt.proxy), &model.WatchedResource{ResourceNames: tt.resources}, tt.request) if len(tt.nameTable) == 0 { if len(nametable) != 0 { t.Errorf("unexpected nametable. want: %v, got: %v", tt.nameTable, nametable) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 4.6K bytes - Viewed (0)