- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 31 for FilterChains (0.54 sec)
-
pilot/pkg/networking/core/gateway_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 144K 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) -
pilot/pkg/simulation/traffic.go
if alpn := protocolToAlpn(input.Protocol); alpn != "" && input.TLS == Plaintext { input.Alpn = alpn } } fc, err := sim.matchFilterChain(l.FilterChains, l.DefaultFilterChain, input, hasTLSInspector) if err != nil { result.Error = err return } result.FilterChainMatched = fc.Name // Plaintext to TLS is an error
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 19.4K bytes - Viewed (0) -
pilot/pkg/networking/core/fake.go
} return cfgs } // copied from xdstest to avoid import issues func ExtractRoutesFromListeners(ll []*listener.Listener) []string { routes := []string{} for _, l := range ll { for _, fc := range l.FilterChains { for _, filter := range fc.Filters { if filter.Name == wellknown.HTTPConnectionManager { h := &hcm.HttpConnectionManager{} _ = filter.GetTypedConfig().UnmarshalTo(h)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 11.5K bytes - Viewed (0) -
pilot/test/xdstest/extract.go
for _, v := range res { s.Insert(v.Name) } return s } func ExtractRoutesFromListeners(ll []*listener.Listener) []string { routes := []string{} for _, l := range ll { for _, fc := range l.FilterChains { for _, filter := range fc.Filters { if filter.Name == wellknown.HTTPConnectionManager { h := SilentlyUnmarshalAny[hcm.HttpConnectionManager](filter.GetTypedConfig())
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/grpcgen/lds.go
SocketAddress: &core.SocketAddress{ Address: listenHost, PortSpecifier: &core.SocketAddress_PortValue{ PortValue: uint32(listenPort), }, }, }}, FilterChains: buildInboundFilterChains(node, push, si, mtlsPolicy), // the following must not be set or the client will NACK ListenerFilters: nil, UseOriginalDst: nil, } // add extra addresses for the listener
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 14.6K bytes - Viewed (0) -
pilot/pkg/networking/core/accesslog_test.go
t.Fatal("expected filter config in listener access log configuration") } // Verify listener access log. verify(t, tc.encoding, l.AccessLog[0], tc.wantFormat) for _, fc := range l.FilterChains { for _, filter := range fc.Filters { switch filter.Name { case wellknown.TCPProxy: tcpConfig := &tcp.TcpProxy{} if err := filter.GetTypedConfig().UnmarshalTo(tcpConfig); err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 19.9K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener.go
} if l.Type != "" && !strings.EqualFold(retrieveListenerType(listener), l.Type) { return false } return true } func getFilterChains(l *listener.Listener) []*listener.FilterChain { res := l.FilterChains if l.DefaultFilterChain != nil { res = append(res, l.DefaultFilterChain) } return res } // retrieveListenerType classifies a Listener as HTTP|TCP|HTTP+TCP|UNKNOWN
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Nov 29 12:37:14 UTC 2023 - 18.1K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
err = l.ActiveState.Listener.UnmarshalTo(listenerTyped) if err != nil { return nil, err } if listenerTyped.Name == model.VirtualInboundListenerName { for _, filterChain := range listenerTyped.FilterChains { for _, filter := range filterChain.Filters { hcm := &hcm.HttpConnectionManager{} if err := filter.GetTypedConfig().UnmarshalTo(hcm); err == nil { return hcm, nil } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 50.4K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier_test.go
iptablesData: bytes.NewBuffer(nil), filterChainsData: bytes.NewBuffer(nil), natChains: proxyutil.NewLineBuffer(), natRules: proxyutil.NewLineBuffer(), filterChains: proxyutil.NewLineBuffer(), filterRules: proxyutil.NewLineBuffer(), netlinkHandle: netlinkHandle, ipsetList: ipsetList,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 186.8K bytes - Viewed (0)