Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for tcpFilters (0.36 sec)

  1. pilot/pkg/networking/plugin/authz/authorization.go

    	return &Builder{builder: b}
    }
    
    func (b *Builder) BuildTCP() []*listener.Filter {
    	if b == nil || b.builder == nil {
    		return nil
    	}
    	if b.tcpBuilt {
    		return b.tcpFilters
    	}
    	b.tcpBuilt = true
    	b.tcpFilters = b.builder.BuildTCP()
    
    	return b.tcpFilters
    }
    
    func (b *Builder) BuildHTTP(class networking.ListenerClass) []*hcm.HttpFilter {
    	if b == nil || b.builder == nil {
    		return nil
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  2. pilot/pkg/model/telemetry.go

    	if res := t.telemetryFilters(proxy, class, networking.ListenerProtocolHTTP, svc); res != nil {
    		return res.([]*hcm.HttpFilter)
    	}
    	return nil
    }
    
    // TCPFilters computes the TCPFilters for a given proxy/class
    func (t *Telemetries) TCPFilters(proxy *Proxy, class networking.ListenerClass, svc *Service) []*listener.Filter {
    	if res := t.telemetryFilters(proxy, class, networking.ListenerProtocolTCP, svc); res != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 18:14:09 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/networkfilter.go

    func buildNetworkFiltersStack(p protocol.Instance, tcpFilter *listener.Filter, statPrefix string, clusterName string) []*listener.Filter {
    	filterstack := make([]*listener.Filter, 0)
    	switch p {
    	case protocol.Mongo:
    		if features.EnableMongoFilter {
    			filterstack = append(filterstack, buildMongoFilter(statPrefix), tcpFilter)
    		} else {
    			filterstack = append(filterstack, tcpFilter)
    		}
    	case protocol.Redis:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/listener_inbound.go

    		IdleTimeout:      parseDuration(lb.node.Metadata.IdleTimeout),
    	}
    	tcpFilter := setAccessLogAndBuildTCPFilter(lb.push, lb.node, tcpProxy, istionetworking.ListenerClassSidecarInbound, fcc.policyService)
    	networkFilterstack := buildNetworkFiltersStack(fcc.port.Protocol, tcpFilter, statPrefix, fcc.clusterName)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 35.1K bytes
    - Viewed (0)
Back to top