eosswedenorg/thalos
1
0
Fork 0
mirror of https://github.com/eosswedenorg/thalos synced 2026-07-04 12:03:41 +02:00
Code Releases Activity

cmd/thalos/server.go: Don't log error if we get a (normal) close message from ship.

Browse source
This commit is contained in:
Henrik Hautakoski 2024-02-18 20:28:02 +01:00
parent 9dcb8c4f0c
commit 3cb25a5717
1 changed files with 6 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

6
cmd/thalos/server.go
View file

@ -15,6 +15,7 @@ import (
"github.com/cenkalti/backoff/v4" "github.com/cenkalti/backoff/v4"
eos "github.com/eoscanada/eos-go" eos "github.com/eoscanada/eos-go"
shipclient "github.com/eosswedenorg-go/antelope-ship-client" shipclient "github.com/eosswedenorg-go/antelope-ship-client"
shipws "github.com/eosswedenorg-go/antelope-ship-client/websocket"
"github.com/eosswedenorg-go/pid" "github.com/eosswedenorg-go/pid"
"github.com/eosswedenorg/thalos/api/message" "github.com/eosswedenorg/thalos/api/message"
_ "github.com/eosswedenorg/thalos/api/message/json" _ "github.com/eosswedenorg/thalos/api/message/json"
@ -113,6 +114,11 @@ func readerLoop(conf *config.Config, running *bool, shClient *shipclient.Stream,
return return
} }
if shipws.IsCloseError(err) {
log.Info("SHIP Connection closed")
return
}
log.WithError(err).Error("Failed to read from ship") log.WithError(err).Error("Failed to read from ship")
} }
} }