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

ship_processor.go: Send hearthbeat every 10'th block.

Browse source
This commit is contained in:
Henrik Hautakoski 2022-11-29 15:04:50 +01:00
parent 3694bc1c42
commit 770f0a48ef
1 changed files with 15 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

15
ship_processor.go
View file

@ -44,6 +44,21 @@ func processBlock(block *ship.GetBlocksResultV0) {
if block.ThisBlock.BlockNum%100 == 0 { if block.ThisBlock.BlockNum%100 == 0 {
log.Infof("Current: %d, Head: %d\n", block.ThisBlock.BlockNum, block.Head.BlockNum) log.Infof("Current: %d, Head: %d\n", block.ThisBlock.BlockNum, block.Head.BlockNum)
} }
if block.ThisBlock.BlockNum%10 == 0 {
hb := HearthBeat{
BlockNum: block.ThisBlock.BlockNum,
LastIrreversibleBlockNum: block.LastIrreversible.BlockNum,
HeadBlockNum: block.Head.BlockNum,
}
encodeQueue("hearthbeat", hb)
_, err := redis.Send()
if err != nil {
log.WithError(err).Error("Failed to send redis")
}
}
} }
func processTraces(traces []*ship.TransactionTraceV0) { func processTraces(traces []*ship.TransactionTraceV0) {