- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for WasmPluginsByListenerInfo (0.79 sec)
-
pilot/pkg/networking/core/networkfilter.go
authzCustomBuilder = authz.NewBuilderForService(authz.Custom, lb.push, lb.node, useFilterState, policySvc) } var filters []*listener.Filter wasm := lb.push.WasmPluginsByListenerInfo(lb.node, model.WasmPluginListenerInfo{ Port: port, Class: class, Service: policySvc, }, model.WasmPluginTypeNetwork)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 13.7K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_builder.go
reqIDExtensionCtx := configureTracing(lb.push, lb.node, connectionManager, httpOpts.class, httpOpts.policySvc) filters := []*hcm.HttpFilter{} if !httpOpts.isWaypoint { wasm := lb.push.WasmPluginsByListenerInfo(lb.node, model.WasmPluginListenerInfo{ Port: httpOpts.port, Class: httpOpts.class, }, model.WasmPluginTypeHTTP)
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_waypoint.go
} // TODO: consider dedicated listener class for waypoint filters cls := istionetworking.ListenerClassSidecarInbound wasm := lb.push.WasmPluginsByListenerInfo(lb.node, model.WasmPluginListenerInfo{ Class: cls, Service: svc, }, model.WasmPluginTypeHTTP) // TODO: how to deal with ext-authz? It will be in the ordering twice
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 27.6K bytes - Viewed (0) -
pilot/pkg/model/push_context.go
if wsm.Name == n.Name { res = append(res, wsm) break } } } return res } // WasmPluginsByListenerInfo return the WasmPluginWrappers which are matched with TrafficSelector in the given proxy. func (ps *PushContext) WasmPluginsByListenerInfo(proxy *Proxy, info WasmPluginListenerInfo, pluginType WasmPluginType, ) map[extensions.PluginPhase][]*WasmPluginWrapper { if proxy == nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_inbound.go
func (lb *ListenerBuilder) buildInboundNetworkFiltersForHTTP(cc inboundChainConfig) []*listener.Filter { // Add network level WASM filters if any configured. httpOpts := buildSidecarInboundHTTPOpts(lb, cc) wasm := lb.push.WasmPluginsByListenerInfo(lb.node, model.WasmPluginListenerInfo{ Port: httpOpts.port, Class: httpOpts.class, }, model.WasmPluginTypeNetwork) var filters []*listener.Filter
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
proxyConfig *meshconfig.ProxyConfig, mergedGateway *model.MergedGateway, tlsHostsByPort map[uint32]map[string]string, ) { // Add network level WASM filters if any configured. wasm := builder.push.WasmPluginsByListenerInfo(builder.node, model.WasmPluginListenerInfo{ Port: opts.port, Class: istionetworking.ListenerClassGateway, }, model.WasmPluginTypeNetwork) if p.IsHTTP() {
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/networking/core/listener.go
l.ListenerFiltersTimeout = builder.push.Mesh.ProtocolDetectionTimeout } else { // Otherwise, do not have a timeout at all l.ListenerFiltersTimeout = durationpb.New(0) } wasm := builder.push.WasmPluginsByListenerInfo(builder.node, model.WasmPluginListenerInfo{ Port: le.servicePort.Port, Class: istionetworking.ListenerClassSidecarOutbound, }, model.WasmPluginTypeNetwork) for _, opt := range le.chains {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 55.1K bytes - Viewed (0) -
pilot/pkg/model/push_context_test.go
// Init a new push context pc := NewPushContext() pc.Mesh = m pc.initWasmPlugins(env) for _, tc := range testCases { t.Run(tc.name, func(t *testing.T) { result := pc.WasmPluginsByListenerInfo(tc.node, tc.listenerInfo, tc.pluginType) if !reflect.DeepEqual(tc.expectedExtensions, result) { t.Errorf("WasmPlugins did not match expectations\n\ngot: %v\n\nexpected: %v", result, tc.expectedExtensions) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 95.3K bytes - Viewed (0)