eosswedenorg/thalos
1
0
Fork 0
mirror of https://github.com/eosswedenorg/thalos synced 2026-06-16 04:24:56 +02:00
Code Releases Activity

cmd/thalos/main.go: Fix some log lines to use structured logging.

Browse source
This commit is contained in:
Henrik Hautakoski 2023-08-30 15:50:40 +02:00
parent 0f5c94f8de
commit 16ab7d1fcf
1 changed files with 10 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

14
cmd/thalos/main.go
View file

@ -69,7 +69,10 @@ func readerLoop(processor *app.ShipProcessor) {
connectOp := func() error {
recon_cnt++
log.Infof("Connecting to ship at: %s (Try %d)", conf.Ship.Url, recon_cnt)
log.WithFields(log.Fields{
"url": conf.Ship.Url,
"try": recon_cnt,
}).Info("Connecting to ship")
if err := shClient.Connect(conf.Ship.Url); err != nil {
return err
@ -108,7 +111,10 @@ func readerLoop(processor *app.ShipProcessor) {
}
recon_cnt = 0
log.Infof("Connected, Start: %d, End: %d", shClient.StartBlock, shClient.EndBlock)
log.WithFields(log.Fields{
"start": shClient.StartBlock,
"end": shClient.EndBlock,
}).Info("Connected to ship")
if err := shClient.Run(); err != nil {
@ -183,7 +189,7 @@ func main() {
// Write PID file
if len(*pidFile) > 0 {
log.Infof("Writing pid to: %s", *pidFile)
log.WithField("file", *pidFile).Info("Writing pid to file")
err = pid.Save(*pidFile)
if err != nil {
log.WithError(err).Fatal("failed to write pid file")
@ -258,7 +264,7 @@ func main() {
return
}
log.Printf("Get chain info from api at: %s", conf.Api)
log.WithField("api", conf.Api).Info("Get chain info from api")
eosClient := eos.New(conf.Api)
chainInfo, err = eosClient.GetInfo(context.Background())
if err != nil {