preserve the form of the wss url for websocket_endpoint

This commit is contained in:
Michael Quigley 2023-04-07 13:15:34 -04:00
parent 35f991d42b
commit e0e3e0286c
No known key found for this signature in database
GPG Key ID: 9B60314A9DD20A62

View File

@ -27,8 +27,8 @@ func init() {
} }
type WebsocketSourceConfig struct { type WebsocketSourceConfig struct {
WebsocketEndpoint string WebsocketEndpoint string // wss://127.0.0.1:1280/fabric/v1/ws-api
ApiEndpoint string ApiEndpoint string // https://127.0.0.1:1280
Username string Username string
Password string `cf:"+secret"` Password string `cf:"+secret"`
} }
@ -41,7 +41,7 @@ func loadWebsocketSourceConfig(v interface{}, _ *cf.Options) (interface{}, error
} }
return &websocketSource{cfg: cfg}, nil return &websocketSource{cfg: cfg}, nil
} }
return nil, errors.New("invalid config struture for 'websocketSource'") return nil, errors.New("invalid config structure for 'websocketSource'")
} }
type websocketSource struct { type websocketSource struct {