highperfocused/khatru
1
0
Fork 0
mirror of https://github.com/fiatjaf/khatru.git synced 2025-04-06 10:58:45 +02:00
Code Issues Packages Projects Releases Wiki Activity

actually we don't need all that fluff.

Browse Source
This commit is contained in:
fiatjaf 2024-09-16 17:39:54 -03:00
parent 635e91f360
commit e25400a61a
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
policies/helpers.go
View File

@ -1,7 +1,6 @@
package policies
import (
"iter"
"sync/atomic"
"time"
@ -19,7 +18,7 @@ func startRateLimitSystem[K comparable](
go func() {
for {
time.Sleep(interval)
for key, bucket := range iter.Seq2[K, *atomic.Int32](negativeBuckets.Range) {
for key, bucket := range negativeBuckets.Range {
newv := bucket.Add(int32(-tokensPerInterval))
if newv <= 0 {
negativeBuckets.Delete(key)