Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 28 for SetupProxy (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top