peter/ekster
1
0
Fork 0
Code Issues 3 Pull Requests Projects 3 Releases 1 Wiki Activity

Extract updateChannelInRedis

Browse Source
This commit is contained in:
Peter Stuifzand 2018-10-03 18:56:26 +02:00
parent cec5fd0672
commit 2288e70e85
Signed by: peter
GPG Key ID: 374322D56E5209E8
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
cmd/eksterd/memory.go
View File

@ -227,16 +227,18 @@ func (b *memoryBackend) ChannelsCreate(name string) (microsub.Channel, error) {
channel := b.createChannel(name) channel := b.createChannel(name)
b.setChannel(channel) b.setChannel(channel)
b.setChannel(channel)
conn := pool.Get() conn := pool.Get()
defer conn.Close() defer conn.Close()
updateChannelInRedis(channel, conn)
return channel, nil
}
func updateChannelInRedis(channel microsub.Channel, conn redis.Conn) {
uid := channel.UID uid := channel.UID
conn.Do("SADD", "channels", uid) conn.Do("SADD", "channels", uid)
conn.Do("SETNX", "channel_sortorder_"+uid, 99999) conn.Do("SETNX", "channel_sortorder_"+uid, 99999)
return channel, nil
} }
// ChannelsUpdate updates a channels // ChannelsUpdate updates a channels