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

Merge branch 'performance-fix'

Browse source 
# Conflicts:
#	go.mod
#	go.sum
#	redis.go
This commit is contained in:
Henrik Hautakoski 2022-02-02 16:08:53 +01:00
commit c13b2d49c6
11 changed files with 1101 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

7
ship_processor.go
View file

@ -63,10 +63,15 @@ func processTraces(traces []*ship.TransactionTraceV0) {
}
for _, channel := range channels {
if err := RedisPublish(channel, payload).Err(); err != nil {
if err := RedisRegisterPublish(channel, payload).Err(); err != nil {
log.Printf("Failed to post to channel '%s': %s", channel, err)
}
}
}
}
_, err := RedisSend()
if err != nil {
log.Println("Failed to send redis command:", err)
}
}