equal
deleted
inserted
replaced
50 if !strings.HasPrefix(mc.APIBase, "http") { |
50 if !strings.HasPrefix(mc.APIBase, "http") { |
51 return nil, errors.New("cannot create Websocket URL: unexpected API base URL") |
51 return nil, errors.New("cannot create Websocket URL: unexpected API base URL") |
52 } |
52 } |
53 |
53 |
54 // Build streaming websocket URL |
54 // Build streaming websocket URL |
55 u, err := url.Parse("ws" + mc.APIBase[4:] + "/streaming/") |
55 u, err := url.Parse("ws" + mc.APIBase[4:] + "/v1/streaming/") |
56 if err != nil { |
56 if err != nil { |
57 return nil, errors.Wrap(err, "cannot create Websocket URL") |
57 return nil, errors.Wrap(err, "cannot create Websocket URL") |
58 } |
58 } |
59 |
59 |
60 urlParams := url.Values{} |
60 urlParams := url.Values{} |