Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for newUDP (0.1 sec)

  1. pkg/test/echo/server/endpoint/instance.go

    		case protocol.HTTP, protocol.HTTPS:
    			return newHTTP(cfg), nil
    		case protocol.HTTP2, protocol.GRPC:
    			return newGRPC(cfg), nil
    		case protocol.TCP:
    			return newTCP(cfg), nil
    		case protocol.UDP:
    			return newUDP(cfg), nil
    		default:
    			return nil, fmt.Errorf("unsupported protocol: %s", cfg.Port.Protocol)
    		}
    	}
    
    	if len(cfg.UDSServer) > 0 {
    		return newHTTP(cfg), nil
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 16:20:31 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  2. pkg/test/echo/server/endpoint/udp.go

    	"github.com/google/uuid"
    
    	"istio.io/istio/pkg/test/echo"
    	"istio.io/istio/pkg/test/util/retry"
    )
    
    var _ Instance = &udpInstance{}
    
    type udpInstance struct {
    	Config
    	l net.PacketConn
    }
    
    func newUDP(config Config) Instance {
    	return &udpInstance{
    		Config: config,
    	}
    }
    
    func (s *udpInstance) GetConfig() Config {
    	return s.Config
    }
    
    func (s *udpInstance) Start(onReady OnReadyFunc) error {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 16:20:31 UTC 2023
    - 3.4K bytes
    - Viewed (0)
Back to top