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

ship_processor.go: use redis pipelines for publishing.

Browse source
This commit is contained in:
Henrik Hautakoski 2022-01-20 11:52:31 +01:00
parent 90df18562c
commit ad37945951
No known key found for this signature in database
GPG key ID: 608414D93E862CCD
1 changed files with 6 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

7
ship_processor.go
View file

@ -53,10 +53,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)
}
}