Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for ExtractListener (0.21 sec)

  1. pilot/pkg/networking/core/listener_builder_test.go

    			},
    		}
    		listeners := buildListeners(t, TestOptions{Services: testServices}, proxy)
    		if vo := xdstest.ExtractListener(model.VirtualOutboundListenerName, listeners); vo == nil {
    			t.Fatalf("expect virtual listener, found %s", listeners[0].Name)
    		}
    		vi := xdstest.ExtractListener(model.VirtualInboundListenerName, listeners)
    		if vi == nil {
    			t.Fatalf("expect virtual inbound listener, found %s", listeners[0].Name)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 24.7K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/listener_test.go

    		}
    
    		explicit := xdstest.ExtractListener("0.0.0.0_8080", listeners)
    		if explicit.ListenerFiltersTimeout == nil {
    			t.Fatalf("expected timeout disabled, found ContinueOnListenerFiltersTimeout %v, ListenerFiltersTimeout %v",
    				explicit.ContinueOnListenerFiltersTimeout,
    				explicit.ListenerFiltersTimeout)
    		}
    
    		auto := xdstest.ExtractListener("0.0.0.0_9090", listeners)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 93.6K bytes
    - Viewed (0)
  3. pilot/pkg/xds/xds_test.go

    		"0.0.0.0_80",
    		"virtualInbound",
    		"virtualOutbound",
    	})
    
    	expectedEgressCluster := "outbound|5000|shiny|foo.bar"
    
    	found := false
    	for _, f := range xdstest.ExtractListener("virtualOutbound", listeners).FilterChains {
    		// We want to check the match all filter chain, as this is testing the fallback logic
    		if f.FilterChainMatch != nil {
    			continue
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 27 16:59:05 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  4. pilot/test/xdstest/extract.go

    	dst := any(new(T)).(proto.Message)
    	if err := a.UnmarshalTo(dst); err != nil {
    		t.Fatalf("failed to unmarshal to %T: %v", dst, err)
    	}
    	return any(dst).(*T)
    }
    
    func ExtractListener(name string, ll []*listener.Listener) *listener.Listener {
    	for _, l := range ll {
    		if l.Name == name {
    			return l
    		}
    	}
    	return nil
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 19 22:42:42 UTC 2023
    - 13.9K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/accesslog_test.go

    	if d := cmp.Diff(l1, l2, protocmp.Transform()); d != "" {
    		t.Fatal(d)
    	}
    	// Make sure we have exactly 1 access log
    	fc := xdstest.ExtractFilterChain("virtualOutbound-blackhole", xdstest.ExtractListener("virtualOutbound", l1))
    	if len(xdstest.ExtractTCPProxy(t, fc).GetAccessLog()) != 1 {
    		t.Fatalf("unexpected access log: %v", xdstest.ExtractTCPProxy(t, fc).GetAccessLog())
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:30 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  6. pilot/pkg/simulation/traffic.go

    	case HTTP2:
    		return "h2c"
    	default:
    		return ""
    	}
    }
    
    func matchListener(listeners []*listener.Listener, input Call) *listener.Listener {
    	if input.CallMode == CallModeInbound {
    		return xdstest.ExtractListener(model.VirtualInboundListenerName, listeners)
    	}
    	// First find exact match for the IP/Port, then fallback to wildcard IP/Port
    	// There is no wildcard port
    	for _, l := range listeners {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 19.4K bytes
    - Viewed (0)
Back to top