Chore: Enable goprintffuncname and nakedret linters (#26376)
* Chore: Enable goprintffuncname linter * Chore: Enable nakedret linter Signed-off-by: Arve Knudsen <arve.knudsen@gmail.com>
This commit is contained in:
@@ -76,14 +76,14 @@ func (c *connection) readPump() {
|
||||
func (c *connection) handleMessage(message []byte) {
|
||||
json, err := simplejson.NewJson(message)
|
||||
if err != nil {
|
||||
log.Error(3, "Unreadable message on websocket channel. error: %v", err)
|
||||
log.Errorf(3, "Unreadable message on websocket channel. error: %v", err)
|
||||
}
|
||||
|
||||
msgType := json.Get("action").MustString()
|
||||
streamName := json.Get("stream").MustString()
|
||||
|
||||
if len(streamName) == 0 {
|
||||
log.Error(3, "Not allowed to subscribe to empty stream name")
|
||||
log.Errorf(3, "Not allowed to subscribe to empty stream name")
|
||||
return
|
||||
}
|
||||
|
||||
|
||||
@@ -27,11 +27,11 @@ func NewStreamManager() *StreamManager {
|
||||
}
|
||||
|
||||
func (sm *StreamManager) Run(context context.Context) {
|
||||
log.Debug("Initializing Stream Manager")
|
||||
log.Debugf("Initializing Stream Manager")
|
||||
|
||||
go func() {
|
||||
sm.hub.run(context)
|
||||
log.Info("Stopped Stream Manager")
|
||||
log.Infof("Stopped Stream Manager")
|
||||
}()
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user