(sessionID string)
| 219 | } |
| 220 | |
| 221 | func (c *apiClient) wsURL(sessionID string) string { |
| 222 | u, err := url.Parse(c.baseURL) |
| 223 | if err != nil { |
| 224 | return "" |
| 225 | } |
| 226 | switch u.Scheme { |
| 227 | case "https": |
| 228 | u.Scheme = "wss" |
| 229 | default: |
| 230 | u.Scheme = "ws" |
| 231 | } |
| 232 | u.Path = "/v0/management/sessions/" + sessionID + "/ws" |
| 233 | return u.String() |
| 234 | } |
| 235 | |
| 236 | func (c *apiClient) observeWsURL(sessionID string) string { |
| 237 | u, err := url.Parse(c.baseURL) |