Cynosphere/nitter
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Remove Redis pipelining

Browse source
This commit is contained in:
Zed 2022-01-20 02:22:32 +01:00
parent 575cb590d7
commit a76ca3d60f
1 changed files with 0 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/redis_cache.nim
View file

@ -83,11 +83,9 @@ proc cache*(data: Profile) {.async.} =
if data.username.len == 0: return if data.username.len == 0: return
let name = toLower(data.username) let name = toLower(data.username)
pool.withAcquire(r): pool.withAcquire(r):
r.startPipelining()
dawait r.setEx(name.profileKey, baseCacheTime, compress(toFlatty(data))) dawait r.setEx(name.profileKey, baseCacheTime, compress(toFlatty(data)))
if data.id.len > 0: if data.id.len > 0:
dawait r.hSet(name.pidKey, name, data.id) dawait r.hSet(name.pidKey, name, data.id)
dawait r.flushPipeline()
proc cacheProfileId(username, id: string) {.async.} = proc cacheProfileId(username, id: string) {.async.} =
if username.len == 0 or id.len == 0: return if username.len == 0 or id.len == 0: return
@ -98,11 +96,9 @@ proc cacheProfileId(username, id: string) {.async.} =
proc cacheRss*(query: string; rss: Rss) {.async.} = proc cacheRss*(query: string; rss: Rss) {.async.} =
let key = "rss:" & query let key = "rss:" & query
pool.withAcquire(r): pool.withAcquire(r):
r.startPipelining()
dawait r.hSet(key, "rss", rss.feed) dawait r.hSet(key, "rss", rss.feed)
dawait r.hSet(key, "min", rss.cursor) dawait r.hSet(key, "min", rss.cursor)
dawait r.expire(key, rssCacheTime) dawait r.expire(key, rssCacheTime)
dawait r.flushPipeline()
proc getProfileId*(username: string): Future[string] {.async.} = proc getProfileId*(username: string): Future[string] {.async.} =
let name = toLower(username) let name = toLower(username)