go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2025-10-22 09:56:12 +08:00
Code Issues Projects Releases Wiki Activity

Declare ReclaimStaleAggregationSets

Browse Source
This commit is contained in:
Ken Hibino
2022-03-11 10:44:12 -08:00
parent 1f23b66e60
commit df85894c5c
5 changed files with 142 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
internal/testbroker/testbroker.go
View File

@@ -288,3 +288,12 @@ func (tb *TestBroker) DeleteAggregationSet(ctx context.Context, qname, gname, ag
}
return tb.real.DeleteAggregationSet(ctx, qname, gname, aggregationSetID)
}
func (tb *TestBroker) ReclaimStaleAggregationSets(qname string) error {
tb.mu.Lock()
defer tb.mu.Unlock()
if tb.sleeping {
return errRedisDown
}
return tb.real.ReclaimStaleAggregationSets(qname)
}