Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for ExtractListenerNames (0.28 sec)

  1. pilot/pkg/xds/xds_test.go

    		if !slices.EqualUnordered(endpoints["outbound|80||app.com"], []string{"1.1.1.1:80"}) {
    			t.Fatalf("expected 1.1.1.1, got %v", endpoints["outbound|80||app.com"])
    		}
    
    		assertListEqual(t, xdstest.ExtractListenerNames(s.Listeners(proxy)), []string{
    			"0.0.0.0_80",
    			"5.5.5.5_443",
    			"virtualInbound",
    			"virtualOutbound",
    		})
    	})
    
    	t.Run("Ingress Listener", func(t *testing.T) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 27 16:59:05 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  2. pilot/test/xdstest/extract.go

    					resourceNames.Insert(s.GetName())
    				}
    			}
    		}
    	}
    	resourceNames.Delete("")
    	ls := resourceNames.UnsortedList()
    	sort.Sort(sort.Reverse(sort.StringSlice(ls)))
    	return ls
    }
    
    func ExtractListenerNames(ll []*listener.Listener) []string {
    	res := []string{}
    	for _, l := range ll {
    		res = append(res, l.Name)
    	}
    	return res
    }
    
    func SilentlyUnmarshalAny[T any](a *anypb.Any) *T {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 19 22:42:42 UTC 2023
    - 13.9K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/gateway_simulation_test.go

    		sim := simulation.NewSimulation(t, s, s.SetupProxy(proxy))
    		sim.RunExpectations(tt.calls)
    		if t.Failed() && debugMode {
    			t.Log(xdstest.MapKeys(xdstest.ExtractClusters(sim.Clusters)))
    			t.Log(xdstest.ExtractListenerNames(sim.Listeners))
    			t.Log(xdstest.DumpList(t, sim.Listeners))
    			t.Log(xdstest.DumpList(t, sim.Routes))
    			t.Log(tt.config)
    			t.Log(tt.kubeConfig)
    		}
    		t.Run("validate configs", func(t *testing.T) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 10 18:27:40 UTC 2024
    - 46.5K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/gateway_test.go

    			} else {
    				proxy.Metadata = &proxyGatewayMetadata
    			}
    
    			builder := cg.ConfigGen.buildGatewayListeners(NewListenerBuilder(proxy, cg.PushContext()))
    			listeners := xdstest.ExtractListenerNames(builder.gatewayListeners)
    			sort.Strings(listeners)
    			sort.Strings(tt.expectedListeners)
    			if !reflect.DeepEqual(listeners, tt.expectedListeners) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 144K bytes
    - Viewed (0)
Back to top