Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for TransportProtocolTCP (0.21 sec)

  1. pilot/pkg/networking/networking.go

    		return ListenerProtocolAuto
    	}
    }
    
    type TransportProtocol uint8
    
    const (
    	// TransportProtocolTCP is a TCP listener
    	TransportProtocolTCP = iota
    	// TransportProtocolQUIC is a QUIC listener
    	TransportProtocolQUIC
    )
    
    func (tp TransportProtocol) String() string {
    	switch tp {
    	case TransportProtocolTCP:
    		return "tcp"
    	case TransportProtocolQUIC:
    		return "quic"
    	}
    	return "unknown"
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Aug 18 09:42:04 UTC 2023
    - 2.5K bytes
    - Viewed (0)
  2. pilot/pkg/networking/networking_test.go

    			}
    		})
    	}
    }
    
    func TestString(t *testing.T) {
    	tests := []struct {
    		name  string
    		value uint
    		want  string
    	}{
    		{
    			"test String method for tcp transport protocol",
    			TransportProtocolTCP,
    			"tcp",
    		},
    		{
    			"test String method for quic transport protocol",
    			TransportProtocolQUIC,
    			"quic",
    		},
    		{
    			"test String method for invalid transport protocol",
    			3,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Aug 01 02:46:15 UTC 2023
    - 2.5K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/listener.go

    		ListenerFiltersTimeout:           durationpb.New(0),
    	}
    	switch transport {
    	case istionetworking.TransportProtocolTCP:
    		// TODO: need to sanitize the opts.bind if its a UDS socket, as it could have colons, that envoy doesn't like
    		res.Name = getListenerName(opts.bind, opts.port, istionetworking.TransportProtocolTCP)
    		log.Debugf("buildGatewayListener: building TCP listener %s", res.Name)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/gateway.go

    		// to make testing a little easier.
    		transportToServers := map[istionetworking.TransportProtocol]map[model.ServerPort]*model.MergedServers{
    			istionetworking.TransportProtocolTCP:  mergedGateway.MergedServers,
    			istionetworking.TransportProtocolQUIC: mergedGateway.MergedQUICTransportServers,
    		}
    
    		for transport, gwServers := range transportToServers {
    			if gwServers == nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 46.4K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/listener_inbound.go

    		}
    		return model.VirtualInboundListenerName
    	}
    	// Everything else derived from bind/port
    	return getListenerName(cc.bind, int(cc.port.TargetPort), istionetworking.TransportProtocolTCP)
    }
    
    // ToFilterChainMatch builds the FilterChainMatch for the config
    func (cc inboundChainConfig) ToFilterChainMatch(opt FilterChainMatchOptions) *listener.FilterChainMatch {
    	match := &listener.FilterChainMatch{}
    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/util/util.go

    	}, nil
    }
    
    // BuildAddress returns a SocketAddress with the given ip and port or uds.
    func BuildAddress(bind string, port uint32) *core.Address {
    	address := BuildNetworkAddress(bind, port, istionetworking.TransportProtocolTCP)
    	if address != nil {
    		return address
    	}
    
    	return &core.Address{
    		Address: &core.Address_Pipe{
    			Pipe: &core.Pipe{
    				Path: strings.TrimPrefix(bind, model.UnixAddressPrefix),
    			},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 28.5K bytes
    - Viewed (0)
Back to top