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: encodeQueue should accept and redis.ChannelInterface instead of redis.Channel to make it more generic.

Browse source
This commit is contained in:
Henrik Hautakoski 2023-01-06 17:17:01 +01:00
parent 723b0786cb
commit 83a4c9f70f
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
ship_processor.go
View file

@ -31,7 +31,7 @@ func queueMessage(channel redis.ChannelInterface, payload []byte) bool {
return true
}
func encodeQueue(channel redis.Channel, v interface{}) bool {
func encodeQueue(channel redis.ChannelInterface, v interface{}) bool {
if payload, ok := encodeMessage(v); ok {
if queueMessage(channel, payload) {
return true