Skip to content
Snippets Groups Projects

Tls websockets

Open
Jonah Hussonrequested to merge
tls-websockets into release
6 open threads
4 files
+ 38
15
Compare changes
  • Side-by-side
  • Inline

Files

+ 1
8
@@ -382,15 +382,8 @@ func (t *webSocketTransport) writeMessage(msg int, b []byte) error {
@@ -382,15 +382,8 @@ func (t *webSocketTransport) writeMessage(msg int, b []byte) error {
}
}
var NewWSStream = func(host, endpoint string, opts *ConnectOptions) (WebsocketStreamingTransport, error) {
var NewWSStream = func(host, endpoint string, opts *ConnectOptions) (WebsocketStreamingTransport, error) {
h := http.Header{}
h.Set("Sec-WebSocket-Protocol", "grpc-websockets")
var conn *websocket.Conn
var conn *websocket.Conn
dialer := &websocket.DialOptions{}
dialer := initWsDialer()
dialer.HTTPClient = http.DefaultClient
// Set weebsocket dialer http header
dialer.HTTPHeader = h
// Set websocket dialer subprotocol
dialer.Subprotocols = []string{"grpc-websockets"}
scheme := "ws"
scheme := "ws"
if opts.WithTLS {
if opts.WithTLS {
scheme = "wss"
scheme = "wss"
Loading