Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for WasmPluginsByListenerInfo (0.79 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
Back to top