- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for FilterChains (0.26 sec)
-
pilot/pkg/xds/lds_test.go
// instead of looking at it as a listener with multiple filter chains l := adsc.GetHTTPListeners()["0.0.0.0_443"] if l != nil { if len(l.FilterChains) != 3 { t.Fatalf("Expected 3 filter chains, got %d\n", len(l.FilterChains)) } } } // TestLDS is running LDS tests. func TestLDS(t *testing.T) { t.Run("sidecar", func(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 13.1K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_inbound.go
fcm.TransportProtocol = "" } } l.FilterChains = append(l.FilterChains, chains...) } // If there are no filter chains, populate a dummy one that never matches. Envoy doesn't allow no chains, but removing the // entire listeners makes the errors logs more confusing (instead of "no filter chain found" we have no listener at all). if len(l.FilterChains) == 0 { l.FilterChains = []*listener.FilterChain{{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 35.1K bytes - Viewed (0) -
pilot/pkg/networking/core/gateway.go
} httpConnectionManagers := make([]*hcm.HttpConnectionManager, len(ml.Listener.FilterChains)) for i := range ml.Listener.FilterChains { filterChain := ml.Listener.FilterChains[i] opt := opts.filterChainOpts[i] ml.Listener.FilterChains[i].Metadata = opt.metadata if opt.httpOpts == nil { filterChain.Filters = opt.networkFilters
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 46.4K bytes - Viewed (0) -
pilot/pkg/xds/xds_test.go
Equals("virtualOutbound", "{.name}"). Equals("0.0.0.0", "{.address.socketAddress.address}"). Equals(wellknown.TCPProxy, "{.filterChains[1].filters[0].name}"). Equals("PassthroughCluster", "{.filterChains[1].filters[0].typedConfig.cluster}"). Equals("PassthroughCluster", "{.filterChains[1].filters[0].typedConfig.statPrefix}"). Equals(true, "{.useOriginalDst}"). CheckOrFail(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) -
pilot/pkg/networking/core/envoyfilter/listener_patch.go
continue } IncrementEnvoyFilterMetric(lp.Key(), FilterChain, true) lis.FilterChains = append(lis.FilterChains, proto.Clone(lp.Value).(*listener.FilterChain)) } } if filterChainsRemoved { lis.FilterChains = slices.FilterInPlace(lis.FilterChains, func(fc *listener.FilterChain) bool { return fc.Filters != nil }) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 15:39:29 UTC 2024 - 26.7K bytes - Viewed (0) -
pkg/adsc/delta_test.go
SocketAddress: &core.SocketAddress{ Protocol: core.SocketAddress_TCP, Address: "0.0.0.0", PortSpecifier: &core.SocketAddress_PortValue{ PortValue: 8080, }, }, }, }, FilterChains: []*listener.FilterChain{ { Filters: []*listener.Filter{ { Name: wellknown.HTTPConnectionManager, ConfigType: &listener.Filter_TypedConfig{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 09:32:41 UTC 2024 - 13.9K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_builder.go
Address: util.BuildAddress(actualWildcards[0], uint32(lb.push.Mesh.ProxyListenPort)), Transparent: isTransparentProxy, UseOriginalDst: proto.BoolTrue, FilterChains: filterChains, TrafficDirection: core.TrafficDirection_OUTBOUND, } // add extra addresses for the listener if features.EnableDualStack && len(actualWildcards) > 1 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 17.9K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_builder_test.go
if vi == nil { t.Fatalf("expect virtual inbound listener, found %s", listeners[0].Name) } byListenerName := map[string]int{} for _, fc := range vi.FilterChains { byListenerName[fc.Name]++ } for k, v := range byListenerName { if k == model.VirtualInboundListenerName && v != 3 {
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_waypoint.go
actualWildcard, _ := getActualWildcardAndLocalHost(lb.node) l := &listener.Listener{ Name: ConnectTerminate, Address: util.BuildAddress(actualWildcard, model.HBoneInboundListenPort), FilterChains: []*listener.FilterChain{ { Name: "default", TransportSocket: &core.TransportSocket{ Name: "tls",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 27.6K bytes - Viewed (0) -
pkg/adsc/adsc.go
// TODO: extract VIP and RDS or cluster continue } fc := l.FilterChains[len(l.FilterChains)-1] // Find the terminal filter filter := fc.Filters[len(fc.Filters)-1] // The actual destination will be the next to the last if the last filter is a passthrough filter if fc.GetName() == util.PassthroughFilterChain { fc = l.FilterChains[len(l.FilterChains)-2] filter = fc.Filters[len(fc.Filters)-1] }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 05 22:18:49 UTC 2024 - 35K bytes - Viewed (0)