arkiver
|
c500209e45
|
Print queue name as well on failing to sadd items.
|
9 kuukautta sitten |
arkiver
|
23a5028df8
|
Make maps in maps before use.
|
9 kuukautta sitten |
arkiver
|
9f541a1765
|
Support custom queue with queue parameter. Default queue is todo:backfeed.
|
9 kuukautta sitten |
Fusl
|
3b37b4fe5e
|
fix skipbloom/skipfeed and merge initial item pop into loop logic
|
9 kuukautta sitten |
Fusl
|
e756a64496
|
buffer persistence writes
|
9 kuukautta sitten |
Fusl
|
fece944394
|
forgor to commit structs.go
|
9 kuukautta sitten |
Fusl
|
0f206f00f1
|
allow using backfeed without bloom filters or without feeding
|
9 kuukautta sitten |
Fusl
|
f62e6f8659
|
update modules
|
1 vuosi sitten |
Fusl
|
82fb732fc4
|
don't enter retry loop in case sAddItems is empty
|
1 vuosi sitten |
Fusl
|
7c41d8541d
|
retry adding items to filter and tracker redis in case of transient failures
|
1 vuosi sitten |
Fusl
|
4f08776500
|
delete last_ts info for unlinked keys
|
1 vuosi sitten |
Fusl
|
c12f098529
|
added redisinfo endpoint
|
1 vuosi sitten |
Fusl
|
88c1489bb2
|
added filter restore endpoint
|
1 vuosi sitten |
Fusl
|
bf974d9411
|
lets reorganize some of this stuff
|
1 vuosi sitten |
Fusl
|
fdb01718e3
|
slight performance improvement
|
1 vuosi sitten |
Fusl
|
1deefc4db9
|
fix last access logic
|
1 vuosi sitten |
Fusl
|
dc25393d35
|
early bf.scandump support
|
1 vuosi sitten |
Fusl
|
1d6fc0fc46
|
that was a patch and a half
|
1 vuosi sitten |
Fusl
|
5cfe0635b4
|
support gzip/deflate encoding
|
1 vuosi sitten |
Fusl
|
45b27271ad
|
trigger ci/cd build at 2023-02-20T06:51:54Z
|
1 vuosi sitten |
Fusl
|
0ceeadd614
|
access stats
|
1 vuosi sitten |
Fusl
|
6f89d42312
|
disable channel overflow early return for now
|
1 vuosi sitten |
Fusl
|
1b7cbab592
|
update deps
|
1 vuosi sitten |
Fusl
|
91ac914dd5
|
use go 1.19 during docker build
|
1 vuosi sitten |
Fusl
|
f08b65b4d4
|
entirely get rid of legacy stuff
|
1 vuosi sitten |
Fusl
|
705dce8582
|
upgrade to go1.19, remove legacy db, add last touch timestamp, inline some conditions
|
1 vuosi sitten |
Fusl
|
65a98d4392
|
reject request if backfeed channel is overloaded
|
2 vuotta sitten |
Fusl
|
6d61987ff6
|
lets increase the redis pool size
|
2 vuotta sitten |
Fusl
|
d14917c95d
|
dont close the channel when we're done, avoids lock congestion
|
2 vuotta sitten |
Fusl
|
53842ced4b
|
add prometheus exports for redis
|
2 vuotta sitten |
Fusl
|
2fe43ae68e
|
forgot to initialize the abool struct
|
2 vuotta sitten |
Fusl
|
b88912ce0c
|
added health check endpoints
|
2 vuotta sitten |
Fusl
|
699bb1f11c
|
added metrics/debug, dont abort item batch on single server failure
|
2 vuotta sitten |
Fusl
|
72c6cf3cf9
|
remove that log line here
|
2 vuotta sitten |
Fusl
|
00def81c2a
|
need to make a []byte of length len(b), not capacity len(b)
|
2 vuotta sitten |
Fusl
|
c7bebb89f8
|
fix item name corruption + use native go-redis type-convert functions
|
2 vuotta sitten |
Fusl
|
591252f581
|
respond with 200 with additional info instead of 204
|
2 vuotta sitten |
Fusl
|
384fadb461
|
simplify RedisConfigDiffers func, fix dedupe against legacy db
|
2 vuotta sitten |
Fusl
|
f1c0315491
|
ping redis hosts on startup, add build files
|
2 vuotta sitten |
Fusl
|
f75ce467aa
|
add 2nd-stage deduplication using legacy backfeed database
|
2 vuotta sitten |
Fusl
|
fa467be11c
|
stats for dupes
|
2 vuotta sitten |
Fusl
|
69a851e582
|
initial code commit
|
2 vuotta sitten |