- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for ExtractListener (0.33 sec)
-
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) -
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) -
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) -
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) -
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) -
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)