- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 28 for SetupProxy (0.5 sec)
-
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/mesh_network_test.go
s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{ KubernetesObjects: kubeObjects, Configs: configObjects, NetworksWatcher: meshNetworks, }) for _, w := range workloads { w.setupProxy(s) } t.Run("no gateway", func(t *testing.T) { vm.Expect(pod, "10.10.10.10:8080") vm.Test(t, s) }) t.Run("gateway added via label", func(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 24.6K 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) -
pilot/pkg/networking/core/cluster_test.go
DNSDomain: "default.example.org", Metadata: c.meta, IstioVersion: c.istioVersion, } default: panic(fmt.Sprintf("unsupported node type: %v", c.nodeType)) } clusters := cg.Clusters(cg.SetupProxy(proxy)) xdstest.ValidateClusters(c.t, clusters) if len(cg.PushContext().ProxyStatus[model.DuplicatedClusters.Name()]) > 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 108.8K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder_test.go
Instances: instances, ConfigPointers: []*config.Config{cfg}, Services: []*model.Service{tt.service}, MeshConfig: tt.meshConfig, }) proxy := cg.SetupProxy(nil) cb := NewClusterBuilder(proxy, &model.PushRequest{Push: cg.PushContext()}, nil) tt.cluster.CommonLbConfig = &cluster.Cluster_CommonLbConfig{} ec := newClusterWrapper(tt.cluster)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 110.4K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_test.go
Address: "1.1.1.1", EndpointPort: uint32(s.Ports[0].Port), }, ServicePort: s.Ports[0], } cg.MemRegistry.AddInstance(i) } listeners := cg.Listeners(cg.SetupProxy(p)) xdstest.ValidateListeners(t, listeners) l := xdstest.ExtractListener(model.VirtualInboundListenerName, listeners) httpFilters := []string{ xdsfilters.MxFilterName, // Ext auth makes 2 filters
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/xds/endpoints/ep_filters_test.go
for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { cn := fmt.Sprintf("outbound|80|%s|example.ns.svc.cluster.local", subset) proxy := ds.SetupProxy(tt.proxy) b := endpoints.NewEndpointBuilder(cn, proxy, ds.PushContext()) filtered := b.BuildClusterLoadAssignment(testShards()).Endpoints xdstest.CompareEndpointsOrFail(t, cn, filtered, tt.want)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 01:17:58 UTC 2024 - 26.8K bytes - Viewed (0) -
pilot/pkg/xds/ecds_test.go
ClusterID: constants.DefaultClusterName, }, } tt.request.Push = s.PushContext() tt.request.Push.Mesh.RootNamespace = "istio-system" resources, _, _ := gen.Generate(s.SetupProxy(proxy), &model.WatchedResource{ResourceNames: tt.watchedResources}, tt.request) gotExtensions := sets.String{} gotSecrets := sets.String{} for _, res := range resources { gotExtensions.Insert(res.Name)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 12K bytes - Viewed (0) -
pilot/pkg/networking/core/httproute_test.go
Services: tt.services, Configs: tt.config, }) vHostCache := make(map[int][]*route.VirtualHost) resource, _ := cg.ConfigGen.buildSidecarOutboundHTTPRouteConfig( cg.SetupProxy(nil), &model.PushRequest{Push: cg.PushContext()}, "80", vHostCache, nil, nil) routeCfg := &route.RouteConfiguration{} resource.Resource.UnmarshalTo(routeCfg) xdstest.ValidateRouteConfiguration(t, routeCfg)
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/gateway_test.go
cg := NewConfigGenTest(t, TestOptions{ Configs: cfgs, Services: []*pilot_model.Service{ exampleService, }, }) r := cg.ConfigGen.buildGatewayHTTPRouteConfig(cg.SetupProxy(&proxyGateway), cg.PushContext(), tt.routeName) if r == nil { t.Fatal("got an empty route configuration") } if r.MaxDirectResponseBodySizeBytes != istio_route.DefaultMaxDirectResponseBodySizeBytes {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 144K bytes - Viewed (0)